fix(launcher): 修复sync包路径引用

2024-03-01 15:05:37 +08:00
parent 9a6eb1e0a4
commit 36c31df2c1
1 changed files with 2 additions and 2 deletions
--- 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)
        );
    }