From 99bade761b6b38ccc6f576c1b718ec18281717d9 Mon Sep 17 00:00:00 2001 From: Hengyuan Date: Tue, 3 Dec 2024 19:44:13 +0800 Subject: [PATCH] [INLONG-1083][Doc] Correct description of connector name for sort-connector Kafka and ElasticSearch (#1084) --- docs/data_node/extract_node/kafka.md | 2 +- .../current/data_node/extract_node/kafka.md | 2 +- .../current/data_node/load_node/elasticsearch.md | 2 +- .../version-2.0.0/data_node/load_node/elasticsearch.md | 2 +- .../version-2.0.0/data_node/load_node/kafka.md | 2 +- versioned_docs/version-2.0.0/data_node/extract_node/kafka.md | 2 +- 6 files changed, 6 insertions(+), 6 deletions(-) diff --git a/docs/data_node/extract_node/kafka.md b/docs/data_node/extract_node/kafka.md index 6f1f360d92f..68b47c99842 100644 --- 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 index ff61be058ee..48bf45958d6 100644 --- 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/i18n/zh-CN/docusaurus-plugin-content-docs/current/data_node/load_node/elasticsearch.md b/i18n/zh-CN/docusaurus-plugin-content-docs/current/data_node/load_node/elasticsearch.md index e01248355c5..fe4d489e3fe 100644 --- a/i18n/zh-CN/docusaurus-plugin-content-docs/current/data_node/load_node/elasticsearch.md +++ b/i18n/zh-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/i18n/zh-CN/docusaurus-plugin-content-docs/version-2.0.0/data_node/load_node/elasticsearch.md b/i18n/zh-CN/docusaurus-plugin-content-docs/version-2.0.0/data_node/load_node/elasticsearch.md index e01248355c5..fe4d489e3fe 100644 --- a/i18n/zh-CN/docusaurus-plugin-content-docs/version-2.0.0/data_node/load_node/elasticsearch.md +++ b/i18n/zh-CN/docusaurus-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/i18n/zh-CN/docusaurus-plugin-content-docs/version-2.0.0/data_node/load_node/kafka.md b/i18n/zh-CN/docusaurus-plugin-content-docs/version-2.0.0/data_node/load_node/kafka.md index ba389cb15f6..606d86cb2c8 100644 --- a/i18n/zh-CN/docusaurus-plugin-content-docs/version-2.0.0/data_node/load_node/kafka.md +++ b/i18n/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 index 6f1f360d92f..68b47c99842 100644 --- 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';