问题描述
如何在 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 (将#修改为@)