This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.11 by this push:
new 1b75ae8 [hotfix][python][docs] Fix the mistakes of connector options
in the examples
1b75ae8 is described below
commit 1b75ae81fd1a2201dfabe98b8dc133f6382a0b41
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 f930e06..8554d02 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'
@@ -99,7 +99,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',
@@ -112,7 +112,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 9f125e6..29511ec 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'
@@ -99,7 +99,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',
@@ -112,7 +112,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 0d61f49..da3fa7e 100644
--- a/docs/dev/python/table_api_tutorial.md
+++ b/docs/dev/python/table_api_tutorial.md
@@ -73,9 +73,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'
)
"""
@@ -84,9 +84,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 a780c4b..cdb21eb 100644
--- a/docs/dev/python/table_api_tutorial.zh.md
+++ b/docs/dev/python/table_api_tutorial.zh.md
@@ -77,9 +77,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'
)
"""
@@ -88,9 +88,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'
)
"""
