From 36c31df2c19fe9833e3255fed1012e066f5f550e Mon Sep 17 00:00:00 2001 From: lanyuanxiaoyao Date: Fri, 1 Mar 2024 15:05:37 +0800 Subject: [PATCH] =?UTF-8?q?fix(launcher):=20=E4=BF=AE=E5=A4=8Dsync?= =?UTF-8?q?=E5=8C=85=E8=B7=AF=E5=BE=84=E5=BC=95=E7=94=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/lanyuanxiaoyao/service/launcher/ExecutorService.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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) ); }