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 ca387fb..ce3dfad 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 @@ -204,7 +204,7 @@ public class ExecutorService { configuration.setString(DeploymentOptions.TARGET, YarnDeploymentTarget.APPLICATION.getName()); if (StrUtil.isNotBlank(hudiConfiguration.getVictoriaPushUrl())) { - configuration.setString("metrics.reporter.victoria.class", "com.eshore.odcp.hudi.connector.utils.executor.metrics.VictoriaMetricsReporter"); + configuration.setString("metrics.reporter.victoria.class", "com.lanyuanxiaoyao.service.executor.metrics.VictoriaMetricsReporter"); configuration.setString("metrics.reporter.victoria.endpoint", hudiConfiguration.getVictoriaPushUrl()); configuration.setBoolean("metrics.reporter.victoria.enable.auth", true); configuration.setString("metrics.reporter.victoria.auth.username", "EsCFVuNkiDWv7PKmcF"); diff --git a/service-launcher/src/main/resources/services/org.apache.flink.metrics.reporter.MetricReporterFactory b/service-launcher/src/main/resources/services/org.apache.flink.metrics.reporter.MetricReporterFactory index e16bdb6..fb74259 100644 --- a/service-launcher/src/main/resources/services/org.apache.flink.metrics.reporter.MetricReporterFactory +++ b/service-launcher/src/main/resources/services/org.apache.flink.metrics.reporter.MetricReporterFactory @@ -1 +1 @@ -com.eshore.odcp.hudi.connector.utils.executor.metrics.VictoriaMetricsReporterFactory \ No newline at end of file +com.lanyuanxiaoyao.service.executor.metrics.VictoriaMetricsReporterFactory \ No newline at end of file diff --git a/utils/executor/src/main/java/com/lanyuanxiaoyao/service/executor/metrics/VictoriaMetricsReporterFactory.java b/utils/executor/src/main/java/com/lanyuanxiaoyao/service/executor/metrics/VictoriaMetricsReporterFactory.java index 4a24be6..dee70d0 100644 --- a/utils/executor/src/main/java/com/lanyuanxiaoyao/service/executor/metrics/VictoriaMetricsReporterFactory.java +++ b/utils/executor/src/main/java/com/lanyuanxiaoyao/service/executor/metrics/VictoriaMetricsReporterFactory.java @@ -17,7 +17,7 @@ import static com.lanyuanxiaoyao.service.executor.metrics.VictoriaMetricsOptions * @date 2022-06-22 */ @InterceptInstantiationViaReflection( - reporterClassName = "com.eshore.odcp.hudi.connector.utils.executor.metrics.VictoriaMetricsReporter") + reporterClassName = "com.lanyuanxiaoyao.service.executor.metrics.VictoriaMetricsReporter") public class VictoriaMetricsReporterFactory implements MetricReporterFactory { private static final Logger logger = LoggerFactory.getLogger(VictoriaMetricsReporterFactory.class); diff --git a/utils/executor/src/main/resources/services/org.apache.flink.metrics.reporter.MetricReporterFactory b/utils/executor/src/main/resources/services/org.apache.flink.metrics.reporter.MetricReporterFactory index e16bdb6..fb74259 100644 --- a/utils/executor/src/main/resources/services/org.apache.flink.metrics.reporter.MetricReporterFactory +++ b/utils/executor/src/main/resources/services/org.apache.flink.metrics.reporter.MetricReporterFactory @@ -1 +1 @@ -com.eshore.odcp.hudi.connector.utils.executor.metrics.VictoriaMetricsReporterFactory \ No newline at end of file +com.lanyuanxiaoyao.service.executor.metrics.VictoriaMetricsReporterFactory \ No newline at end of file