我已经能够使用 Flink 运行 JMX,并将以下配置应用于集群中所有节点的 flink-conf.yaml 文件:
metrics.reporters: jmx
metrics.reporter.jmx.class: org.apache.flink.metrics.jmx.JMXReporter
metrics.reporter.jmx.port: 9020-9022
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
当我运行 JConsole 并侦听端口 master-IP:9999/slave-IP:9020 时,我能够看到系统指标,如 CPU、内存等。
如何访问任务指标及其各自的图表,如字节读取、延迟等,这些图表是为每个子任务收集的,并显示在 GUI 上。
你可以
去jconsole上的mbeans tab
,在那里你会看到RHS上以作业和任务的名义下的各种下拉菜单。如果您有任何问题,请告诉我。