yaml - Flink 配置自定义 jar 报告器到 yaml，并通过 JMX 控制台连接主机

Question

我是一名学习者，需要帮助。

我有一个实现 Flink MetricsReporter interface 的 Java maven 项目，作为我的自定义记者发送指标。

在我本地的 Flink 中，我能够:

1. 添加Flink JMX reporter config在本地 flink-conf.yaml 文件中。
2. 在端口 8789 上启动 flink
3. 使用JConsole(JMX控制台)连接远程localhost:8789
4. 重启 flink，查看 JConsole Beans 下的 flink 指标。

在工作流有效的概念验证之后，我想做的是:

1. 我写了一个自定义报告程序来实现 metrics interface ，然后我将 reporter 构建到一个 jar 中，其中包含所有必要的依赖项。
2. 我按照 The important paragraph of the Reporter documentation 的建议将 jar 移到了 flink lib/ 文件夹下

我的 jar 名为 x-y-reporter-1.0-SNAPSHOT.jarpom

  <groupId>a.b.c</groupId>
  <artifactId>x-y-reporter</artifactId>
  <version>1.0-SNAPSHOT</version>

我将下面的配置更新为 flink-conf.yaml

metrics.reporters: x-y-reporter
metrics.reporter.x-y-reporter.class: com.b.c.xyreporter.XYReporter
metrics.reporter.x-y-reporter.class.host: localhost
metrics.reporter.x-y-reporter.port: 8789

问题:

• 我想在 flink-conf.yaml 中将 JMX 配置替换为我自己的报告器配置。上面的配置不起作用。请问我该怎么做？请问每个参数是什么意思？
• 我想从 JMX 控制台(如 JMX 报告程序)查看指标。是不是也是通过端口号配置？

非常感谢。

Answer 1

按照问题中的配置重启flink后查看flink日志。事实证明，我的自定义类中存在错误。修复错误后，通过连接到 JConsole 中的本地 apache-flink 进程，我可以在 MBean 列表下看到该类。我不需要连接到远程或本地主机。