This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 39ffff0 [hotfix][python][docs] Fix the mistakes of connector options
in the examples
39ffff0 is described below
commit 39ffff038dbcafd3390c11301bc9303ccb505efa
Author: Dian Fu <[email protected]>
AuthorDate: Sun Nov 8 20:20:52 2020 +0800
[hotfix][python][docs] Fix the mistakes of connector options in the examples
---
.../table-api-users-guide/python_table_api_connectors.md | 8 ++++----
.../table-api-users-guide/python_table_api_connectors.zh.md | 8 ++++----
docs/dev/python/table_api_tutorial.md | 12 ++++++------
docs/dev/python/table_api_tutorial.zh.md | 12 ++++++------
4 files changed, 20 insertions(+), 20 deletions(-)
diff --git
a/docs/dev/python/table-api-users-guide/python_table_api_connectors.md
b/docs/dev/python/table-api-users-guide/python_table_api_connectors.md
index ee76437..fbe2d99 100644
--- a/docs/dev/python/table-api-users-guide/python_table_api_connectors.md
+++ b/docs/dev/python/table-api-users-guide/python_table_api_connectors.md
@@ -51,7 +51,7 @@ source_ddl = """
a VARCHAR,
b INT
) WITH (
- 'type' = 'kafka',
+ 'connector' = 'kafka',
'topic' = 'source_topic',
'properties.bootstrap.servers' = 'kafka:9092',
'properties.group.id' = 'test_3',
@@ -64,7 +64,7 @@ sink_ddl = """
CREATE TABLE sink_table(
a VARCHAR
) WITH (
- 'type' = 'kafka',
+ 'connector' = 'kafka',
'topic' = 'sink_topic',
'properties.bootstrap.servers' = 'kafka:9092',
'format' = 'json'
@@ -98,7 +98,7 @@ def log_processing():
a VARCHAR,
b INT
) WITH (
- 'type' = 'kafka',
+ 'connector' = 'kafka',
'topic' = 'source_topic',
'properties.bootstrap.servers' = 'kafka:9092',
'properties.group.id' = 'test_3',
@@ -111,7 +111,7 @@ def log_processing():
CREATE TABLE sink_table(
a VARCHAR
) WITH (
- 'type' = 'kafka',
+ 'connector' = 'kafka',
'topic' = 'sink_topic',
'properties.bootstrap.servers' = 'kafka:9092',
'format' = 'json'
diff --git
a/docs/dev/python/table-api-users-guide/python_table_api_connectors.zh.md
b/docs/dev/python/table-api-users-guide/python_table_api_connectors.zh.md
index 3fcf89a..535932e 100644
--- a/docs/dev/python/table-api-users-guide/python_table_api_connectors.zh.md
+++ b/docs/dev/python/table-api-users-guide/python_table_api_connectors.zh.md
@@ -51,7 +51,7 @@ source_ddl = """
a VARCHAR,
b INT
) WITH (
- 'type' = 'kafka',
+ 'connector' =' = 'kafka',
'topic' = 'source_topic',
'properties.bootstrap.servers' = 'kafka:9092',
'properties.group.id' = 'test_3',
@@ -64,7 +64,7 @@ sink_ddl = """
CREATE TABLE sink_table(
a VARCHAR
) WITH (
- 'type' = 'kafka',
+ 'connector' = 'kafka',
'topic' = 'sink_topic',
'properties.bootstrap.servers' = 'kafka:9092',
'format' = 'json'
@@ -98,7 +98,7 @@ def log_processing():
a VARCHAR,
b INT
) WITH (
- 'type' = 'kafka',
+ 'connector' = 'kafka',
'topic' = 'source_topic',
'properties.bootstrap.servers' = 'kafka:9092',
'properties.group.id' = 'test_3',
@@ -111,7 +111,7 @@ def log_processing():
CREATE TABLE sink_table(
a VARCHAR
) WITH (
- 'type' = 'kafka',
+ 'connector' = 'kafka',
'topic' = 'sink_topic',
'properties.bootstrap.servers' = 'kafka:9092',
'format' = 'json'
diff --git a/docs/dev/python/table_api_tutorial.md
b/docs/dev/python/table_api_tutorial.md
index dc11e11d1..e7924b2 100644
--- a/docs/dev/python/table_api_tutorial.md
+++ b/docs/dev/python/table_api_tutorial.md
@@ -97,9 +97,9 @@ my_source_ddl = """
create table mySource (
word VARCHAR
) with (
- 'connector.type' = 'filesystem',
- 'format.type' = 'csv',
- 'connector.path' = '/tmp/input'
+ 'connector' = 'filesystem',
+ 'format' = 'csv',
+ 'path' = '/tmp/input'
)
"""
@@ -108,9 +108,9 @@ my_sink_ddl = """
word VARCHAR,
`count` BIGINT
) with (
- 'connector.type' = 'filesystem',
- 'format.type' = 'csv',
- 'connector.path' = '/tmp/output'
+ 'connector' = 'filesystem',
+ 'format' = 'csv',
+ 'path' = '/tmp/output'
)
"""
diff --git a/docs/dev/python/table_api_tutorial.zh.md
b/docs/dev/python/table_api_tutorial.zh.md
index 8519c9e..fcfc623 100644
--- a/docs/dev/python/table_api_tutorial.zh.md
+++ b/docs/dev/python/table_api_tutorial.zh.md
@@ -100,9 +100,9 @@ my_source_ddl = """
create table mySource (
word VARCHAR
) with (
- 'connector.type' = 'filesystem',
- 'format.type' = 'csv',
- 'connector.path' = '/tmp/input'
+ 'connector' = 'filesystem',
+ 'format' = 'csv',
+ 'path' = '/tmp/input'
)
"""
@@ -111,9 +111,9 @@ my_sink_ddl = """
word VARCHAR,
`count` BIGINT
) with (
- 'connector.type' = 'filesystem',
- 'format.type' = 'csv',
- 'connector.path' = '/tmp/output'
+ 'connector' = 'filesystem',
+ 'format' = 'csv',
+ 'path' = '/tmp/output'
)
"""
