diff --git a/service-launcher/src/main/java/com/lanyuanxiaoyao/service/launcher/ExecutorService.java b/service-launcher/src/main/java/com/lanyuanxiaoyao/service/launcher/ExecutorService.java index 7aa22c0..96f2934 100644 --- a/service-launcher/src/main/java/com/lanyuanxiaoyao/service/launcher/ExecutorService.java +++ b/service-launcher/src/main/java/com/lanyuanxiaoyao/service/launcher/ExecutorService.java @@ -279,7 +279,7 @@ public class ExecutorService { return Runner.run( configuration, - "com.eshore.odcp.hudi.connector.sync.Synchronizer", + "com.lanyuanxiaoyao.service.sync.Synchronizer", syncArgs(flinkJob, tableMetaList, cluster) ); } @@ -334,7 +334,7 @@ public class ExecutorService { return Runner.run( configuration, - "com.eshore.odcp.hudi.connector.sync.Compactor", + "com.lanyuanxiaoyao.service.sync.Compactor", compactionArgs(flinkJob, tableMeta, instants, cluster) ); }