[INLONG-1083][Doc] Correct description of connector name for sort-con…

…nector Kafka and ElasticSearch (#1084)
apache · Dec 3, 2024 · 99bade7 · 99bade7
1 parent f0e10f8
commit 99bade7
Show file tree

Hide file tree

Showing 6 changed files with 6 additions and 6 deletions.
diff --git a/docs/data_node/extract_node/kafka.md b/docs/data_node/extract_node/kafka.md
@@ -59,7 +59,7 @@ Flink SQL> CREATE TABLE kafka_extract_node (
 -- Read data
 Flink SQL> SELECT * FROM kafka_extract_node;
 ```
-* connector is `upsert-kafka`
+* connector is `upsert-kafka-inlong`
 ```sql
 -- Set checkpoint every 3000 milliseconds                       
 Flink SQL> SET 'execution.checkpointing.interval' = '3s';

diff --git a/i18n/zh-CN/docusaurus-plugin-content-docs/current/data_node/extract_node/kafka.md b/i18n/zh-CN/docusaurus-plugin-content-docs/current/data_node/extract_node/kafka.md
@@ -57,7 +57,7 @@ Flink SQL> CREATE TABLE kafka_extract_node (
 -- 读取数据
 Flink SQL> SELECT * FROM kafka_extract_node;
 ```
-* 连接器是 `upsert-kafka`
+* 连接器是 `upsert-kafka-inlong`
 ```sql
 -- 设置 Checkpoint 为 3000 毫秒                       
 Flink SQL> SET 'execution.checkpointing.interval' = '3s';

diff --git a/...-CN/docusaurus-plugin-content-docs/current/data_node/load_node/elasticsearch.md b/...-CN/docusaurus-plugin-content-docs/current/data_node/load_node/elasticsearch.md
@@ -58,7 +58,7 @@ CREATE TABLE myUserTable (
   pv BIGINT,
   PRIMARY KEY (user_id) NOT ENFORCED
 ) WITH (
-  'connector' = 'elasticsearch-7',
+  'connector' = 'elasticsearch7-inlong',
   'hosts' = 'http://localhost:9200',
   'index' = 'users'
 );

diff --git a/...cusaurus-plugin-content-docs/version-2.0.0/data_node/load_node/elasticsearch.md b/...cusaurus-plugin-content-docs/version-2.0.0/data_node/load_node/elasticsearch.md
@@ -58,7 +58,7 @@ CREATE TABLE myUserTable (
   pv BIGINT,
   PRIMARY KEY (user_id) NOT ENFORCED
 ) WITH (
-  'connector' = 'elasticsearch-7',
+  'connector' = 'elasticsearch7-inlong',
   'hosts' = 'http://localhost:9200',
   'index' = 'users'
 );

diff --git a/...zh-CN/docusaurus-plugin-content-docs/version-2.0.0/data_node/load_node/kafka.md b/...zh-CN/docusaurus-plugin-content-docs/version-2.0.0/data_node/load_node/kafka.md
@@ -49,7 +49,7 @@ Flink SQL> CREATE TABLE kafka_load_node (
            'format' = 'csv'
            )
 ```
-* 连接器是 `upsert-kafka`
+* 连接器是 `upsert-kafka-inlong`
 ```sql
 -- 使用 Flink SQL 创建 Kafka 表 'kafka_load_node'
 Flink SQL> CREATE TABLE kafka_load_node (

diff --git a/versioned_docs/version-2.0.0/data_node/extract_node/kafka.md b/versioned_docs/version-2.0.0/data_node/extract_node/kafka.md
@@ -59,7 +59,7 @@ Flink SQL> CREATE TABLE kafka_extract_node (
 -- Read data
 Flink SQL> SELECT * FROM kafka_extract_node;
 ```
-* connector is `upsert-kafka`
+* connector is `upsert-kafka-inlong`
 ```sql
 -- Set checkpoint every 3000 milliseconds                       
 Flink SQL> SET 'execution.checkpointing.interval' = '3s';