com.dtstack.flinkx.metrics.CustomPrometheusReporter
Open
- Dominant language
- Java
- Stars
- 4.1k
- Forks
- 1.7k
- PR merge metrics
- No merged PRs in 30d
Description
你好，想问下，yarnper模式，CustomPrometheusReporter这个类调前我加了一些日志，jobmanager中没有找到相关日志，我在怀疑这个类是不是没用到啊，
flink-conf.yml中配置：metrics.reporter.promgateway.class: com.dtstack.flinkx.metrics.CustomPrometheusReporter
新增日志：com.dtstack.flinkx.inputformat.BaseRichInputFormat
private void initPrometheusReporter() {
LOG.info("initPrometheusReporter:" + "aaaaaaaaaaaaaaaaa");
if (useCustomPrometheusReporter()) {
Contributor guide
Assessment
This issue has not been assessed yet.