update

src/main/java/com/dsk/flink/dsc/sync/SyncCustomerDataSource.java

@@ -64,7 +64,7 @@ public class SyncCustomerDataSource {
                 .name("canalJsonStream")
                 .uid("canalJsonStream");
 
-        canalJsonStream.print("canal stream");
+        //canalJsonStream.print("canal stream");
 
         SingleOutputStreamOperator<String> sqlResultStream = AsyncDataStream.orderedWait(canalJsonStream, new AsyncMysqlDataTransferFunction(envProps), 1200L, TimeUnit.SECONDS, 20)
                 .filter(new FilterFunction<String>() {
@@ -76,7 +76,7 @@ public class SyncCustomerDataSource {
                 .name("sqlResultStream")
                 .uid("sqlResultStream");
 
-        sqlResultStream.print("sql result");
+        //sqlResultStream.print("sql result");
 
         sqlResultStream.addSink(new MysqlDataTransferSink(envProps)).name("sqlSinkStream").uid("sqlSinkStream");
         env.execute();

src/main/java/com/dsk/flink/dsc/utils/EnvPropertiesUtil.java

@@ -163,13 +163,4 @@ public class EnvPropertiesUtil {
 		return "application_[a-z]{3,5}\\.properties";
 	}
 
-
-
-	public static void main(String[] args) throws IOException {
-		String filePath = "D:\\Env\\application_pro.properties";
-		System.out.println(getPropertiesFromArgsPath(filePath).toString());
-		EnvProperties envProperties = getPropertiesFromArgsPath(filePath);
-		System.out.println(envProperties.getDb_database());
-	}
-
 }