lanyuanxiaoyao/hudi-service
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(executpr): 修复报名错误导致flink指标无法输出

Browse Source
This commit is contained in:
v-zhangjc9
2024-04-30 10:15:06 +08:00
parent ed06992b51
commit b36311863c
4 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
service-launcher/src/main/java/com/lanyuanxiaoyao/service/launcher/ExecutorService.java
View File

@@ -204,7 +204,7 @@ public class ExecutorService {
configuration.setString(DeploymentOptions.TARGET, YarnDeploymentTarget.APPLICATION.getName()); configuration.setString(DeploymentOptions.TARGET, YarnDeploymentTarget.APPLICATION.getName());
if (StrUtil.isNotBlank(hudiConfiguration.getVictoriaPushUrl())) { 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.setString("metrics.reporter.victoria.endpoint", hudiConfiguration.getVictoriaPushUrl());
configuration.setBoolean("metrics.reporter.victoria.enable.auth", true); configuration.setBoolean("metrics.reporter.victoria.enable.auth", true);
configuration.setString("metrics.reporter.victoria.auth.username", "EsCFVuNkiDWv7PKmcF"); configuration.setString("metrics.reporter.victoria.auth.username", "EsCFVuNkiDWv7PKmcF");

2
service-launcher/src/main/resources/services/org.apache.flink.metrics.reporter.MetricReporterFactory
View File

@@ -1 +1 @@
com.eshore.odcp.hudi.connector.utils.executor.metrics.VictoriaMetricsReporterFactory com.lanyuanxiaoyao.service.executor.metrics.VictoriaMetricsReporterFactory

2
utils/executor/src/main/java/com/lanyuanxiaoyao/service/executor/metrics/VictoriaMetricsReporterFactory.java
View File

@@ -17,7 +17,7 @@ import static com.lanyuanxiaoyao.service.executor.metrics.VictoriaMetricsOptions
* @date 2022-06-22 * @date 2022-06-22
*/ */
@InterceptInstantiationViaReflection( @InterceptInstantiationViaReflection(
reporterClassName = "com.eshore.odcp.hudi.connector.utils.executor.metrics.VictoriaMetricsReporter") reporterClassName = "com.lanyuanxiaoyao.service.executor.metrics.VictoriaMetricsReporter")
public class VictoriaMetricsReporterFactory implements MetricReporterFactory { public class VictoriaMetricsReporterFactory implements MetricReporterFactory {
private static final Logger logger = LoggerFactory.getLogger(VictoriaMetricsReporterFactory.class); private static final Logger logger = LoggerFactory.getLogger(VictoriaMetricsReporterFactory.class);

2
utils/executor/src/main/resources/services/org.apache.flink.metrics.reporter.MetricReporterFactory
View File

@@ -1 +1 @@
com.eshore.odcp.hudi.connector.utils.executor.metrics.VictoriaMetricsReporterFactory com.lanyuanxiaoyao.service.executor.metrics.VictoriaMetricsReporterFactory