You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by yi...@apache.org on 2022/10/09 01:13:26 UTC
[doris] branch master updated: [fix](flinkCDC Demo):fix flinkcdc demo execution error (#13148)
This is an automated email from the ASF dual-hosted git repository.
yiguolei 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 d16ff79217 [fix](flinkCDC Demo):fix flinkcdc demo execution error (#13148)
d16ff79217 is described below
commit d16ff792178f2c65cf940c607dd87b23ab9dd96b
Author: DongLiang-0 <46...@users.noreply.github.com>
AuthorDate: Sun Oct 9 09:13:18 2022 +0800
[fix](flinkCDC Demo):fix flinkcdc demo execution error (#13148)
---
.../src/main/java/org/apache/doris/demo/flink/Cdc2DorisSQLDemo.java | 1 -
1 file changed, 1 deletion(-)
diff --git a/samples/doris-demo/flink-demo-v1.1/src/main/java/org/apache/doris/demo/flink/Cdc2DorisSQLDemo.java b/samples/doris-demo/flink-demo-v1.1/src/main/java/org/apache/doris/demo/flink/Cdc2DorisSQLDemo.java
index 0d1f61fa3e..bfe5e0dd4d 100644
--- a/samples/doris-demo/flink-demo-v1.1/src/main/java/org/apache/doris/demo/flink/Cdc2DorisSQLDemo.java
+++ b/samples/doris-demo/flink-demo-v1.1/src/main/java/org/apache/doris/demo/flink/Cdc2DorisSQLDemo.java
@@ -63,6 +63,5 @@ public class Cdc2DorisSQLDemo {
//insert into mysql table to doris table
tEnv.executeSql("INSERT INTO doris_test_sink select id,name from cdc_test_source");
- env.execute();
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org