From b36311863ceca0b7af4ac4d513cc8b35e7d8c8df Mon Sep 17 00:00:00 2001 From: v-zhangjc9 Date: Tue, 30 Apr 2024 10:15:06 +0800 Subject: [PATCH] =?UTF-8?q?fix(executpr):=20=E4=BF=AE=E5=A4=8D=E6=8A=A5?= =?UTF-8?q?=E5=90=8D=E9=94=99=E8=AF=AF=E5=AF=BC=E8=87=B4flink=E6=8C=87?= =?UTF-8?q?=E6=A0=87=E6=97=A0=E6=B3=95=E8=BE=93=E5=87=BA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/lanyuanxiaoyao/service/launcher/ExecutorService.java | 2 +- .../org.apache.flink.metrics.reporter.MetricReporterFactory | 2 +- .../executor/metrics/VictoriaMetricsReporterFactory.java | 2 +- .../org.apache.flink.metrics.reporter.MetricReporterFactory | 2 +- 4 files changed, 4 insertions(+), 4 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 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