From d16ff792178f2c65cf940c607dd87b23ab9dd96b Mon Sep 17 00:00:00 2001
From: DongLiang-0 <46414265+DongLiang-0@users.noreply.github.com>
Date: Sun, 9 Oct 2022 09:13:18 +0800
Subject: [PATCH] [fix](flinkCDC Demo):fix flinkcdc demo execution error
 (#13148)

---
 .../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();
     }
 }