如何通过JMX远程连接Flink？

Question

对于我即将毕业的学士论文，我想开发一种工具，该工具可以从Apache Flink收集系统和应用程序数据，并将这些数据以某种“事件”的形式发送到另一个系统。该工具将安装在Flink作业和任务管理器节点上。除了来自dstat之类的linux系统实用程序的数据外，我还想收集JMX数据。

我的问题是，我无法弄清楚如何使用Flinks jobmanager的端口通过远程JMX连接进行连接。尽管收集器将在同一台计算机上，但我确实尝试避免使用--javaagent访问Flink JVM的JMX数据。

另一个问题是，我有一个基于https://github.com/apache/flink/tree/master/flink-contrib/docker-flink的本地docker 设置，并更新为flink-1.0.2，无法通过jconsole连接因为我不知道如何为作业和任务管理器“打开” JMX远程端口。

有什么办法可以做到这一点？

在此先感谢，任何想法都非常感谢。

Answer 1

解决了！

我需要添加 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

在flink-conf.yaml中。

不，可以通过jconsole连接jobmanager。