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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
