This is an automated email from the ASF dual-hosted git repository.
zykkk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 312576b93c [typo](docs) modify flink connector document error (#23967)
312576b93c is described below
commit 312576b93cc9e6dc7771fefd691b3bd1f35194c6
Author: Euporia <[email protected]>
AuthorDate: Mon Sep 25 10:11:33 2023 +0800
[typo](docs) modify flink connector document error (#23967)
---
docs/en/docs/ecosystem/flink-doris-connector.md | 2 +-
docs/zh-CN/docs/ecosystem/flink-doris-connector.md | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/docs/en/docs/ecosystem/flink-doris-connector.md
b/docs/en/docs/ecosystem/flink-doris-connector.md
index 961459436d..fa368cd0ae 100644
--- a/docs/en/docs/ecosystem/flink-doris-connector.md
+++ b/docs/en/docs/ecosystem/flink-doris-connector.md
@@ -596,7 +596,7 @@ CREATE TABLE DORIS_SINK(
'sink.properties.columns' = 'id, name, __DORIS_DELETE_SIGN__' -- Display
the import column of the specified streamload
);
-INSERT INTO KAFKA_SOURCE
+INSERT INTO DORIS_SINK
SELECT json_value(data,'$.id') as id,
json_value(data,'$.name') as name,
if(op_type='delete',1,0) as __DORIS_DELETE_SIGN__
diff --git a/docs/zh-CN/docs/ecosystem/flink-doris-connector.md
b/docs/zh-CN/docs/ecosystem/flink-doris-connector.md
index 9c9c46755c..7799d6686c 100644
--- a/docs/zh-CN/docs/ecosystem/flink-doris-connector.md
+++ b/docs/zh-CN/docs/ecosystem/flink-doris-connector.md
@@ -598,7 +598,7 @@ CREATE TABLE DORIS_SINK(
'sink.properties.columns' = 'id, name, __DORIS_DELETE_SIGN__' --
显示指定streamload的导入列
);
-INSERT INTO KAFKA_SOURCE
+INSERT INTO DORIS_SINK
SELECT json_value(data,'$.id') as id,
json_value(data,'$.name') as name,
if(op_type='delete',1,0) as __DORIS_DELETE_SIGN__
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
