在即将到来的学士学位论文中,我想开发一个工具,从apache flink收集系统和应用程序数据,并将这些数据以某种“事件”的形式发送到另一个系统。此工具将安装在flink作业和taskmanager节点上。除了来自像dstat这样的linux系统实用程序的数据之外,我还想收集jmx数据。
我的问题是,我不知道如何通过远程jmx连接使用端口连接到flinks jobmanager。虽然收集器将在同一台机器上,但我确实尽量避免使用--javaagent访问flink的jvm的jmx数据。
另一个问题是,我有一个基于https://github.com/apache/flink/tree/master/flink-contrib/docker-flink 更新为flink-1.0.2,我无法通过jconsole连接,因为我不知道如何为作业和任务管理器“打开”jmx远程端口。
有没有办法做到这一点?
提前谢谢,有任何想法都非常感谢。
1条答案
按热度按时间qlfbtfca1#
解决了的!
我需要补充一下
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。