[fix](flinkCDC Demo):fix flinkcdc demo execution error (#13148)

2022-10-09 09:13:18 +08:00
parent b8b18e5153
commit d16ff79217
1 changed files with 0 additions and 1 deletions
--- 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();
    }
 }