通过 Jolokia 代理在 Apache Flink 中启用监控

问题描述

如何在 Apache Flink 上启用监控?我想在 ELK 堆栈上监控 flink。我正在使用 Jolokia 从 Flink 获取指标。到目前为止,我能够获得作业管理器的指标,但无法获得任务管理器的指标。

我在 taskmanager.sh 和 jobmanager.sh 上都添加了以下行

export FLINK_ENV_JAVA_OPTS="-javaagent:/data/applications/flink-1.11.3/lib/jolokia-jvm-1.6.2-agent.jar=port=8778,host=0.0.0.0"

我正在使用 jolokia_JVM 代理运行 flink 代码。下面是 flink-conf.yaml 文件中的 JMX 设置。

metrics.reporters: jmx
metrics.reporter.jmx.class: org.apache.flink.metrics.jmx.JMXReporter
metrics.reporter.jmx.port: 8789
metrics.delimiter: .
env.java.opts: -Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.port=9999 -Dcom.sun.management.jmxremote.authenticate=false -Dcom.sun.management.jmxremote.ssl=false -javaagent:/data/applications/flink-1.11.3/lib/jolokia-jvm-1.6.2-agent.jar=8778

如何通过 JMX 获取任务管理器和作业管理器指标。

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)

相关问答

Selenium Web驱动程序和Java。元素在(x,y)点处不可单击。其...
Python-如何使用点“。” 访问字典成员?
Java 字符串是不可变的。到底是什么意思?
Java中的“ final”关键字如何工作?(我仍然可以修改对象。...
“loop:”在Java代码中。这是什么,为什么要编译?
java.lang.ClassNotFoundException:sun.jdbc.odbc.JdbcOdbc...