[hotfix] fix typo in upsert-kafka docs (apache#14363)

Co-authored-by: zhuxiaoshang <[email protected]>
todd5167 · Dec 11, 2020 · fa48f76 · fa48f76
1 parent 91e81ee
commit fa48f76
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/docs/dev/table/connectors/upsert-kafka.md b/docs/dev/table/connectors/upsert-kafka.md
@@ -64,7 +64,7 @@ CREATE TABLE pageviews_per_region (
   user_region STRING,
   pv BIGINT,
   uv BIGINT,
-  PRIMARY KEY (region) NOT ENFORCED
+  PRIMARY KEY (user_region) NOT ENFORCED
 ) WITH (
   'connector' = 'upsert-kafka',
   'topic' = 'pageviews_per_region',

diff --git a/docs/dev/table/connectors/upsert-kafka.zh.md b/docs/dev/table/connectors/upsert-kafka.zh.md
@@ -55,7 +55,7 @@ CREATE TABLE pageviews_per_region (
   user_region STRING,
   pv BIGINT,
   uv BIGINT,
-  PRIMARY KEY (region) NOT ENFORCED
+  PRIMARY KEY (user_region) NOT ENFORCED
 ) WITH (
   'connector' = 'upsert-kafka',
   'topic' = 'pageviews_per_region',