init

dw-flink/src/main/java/com/saga/flink/cdc/app/FlinkPhoenixDML.java

@@ -1,7 +1,6 @@
 package com.saga.flink.cdc.app;
 
 import com.alibaba.fastjson.JSONObject;
-import com.saga.flink.cdc.bean.User;
 import com.saga.flink.cdc.sink.PhoenixSinkFunction;
 import com.saga.flink.cdc.source.JSONDebeziumDeserializationSchema;
 import com.ververica.cdc.connectors.mysql.MySqlSource;
@@ -37,10 +36,5 @@ public class FlinkPhoenixDML {
             e.printStackTrace();
         }
 
-        try {
-            env.execute();
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
     }
 }