Re: Container JMX port setting / discovery for Flink on YARN

2016-11-25 Thread Yury Ruchin
Thanks Robert, it works like a charm. 2016-11-25 12:55 GMT+03:00 Robert Metzger : > Hi Yury, > > Flink is using its own JMX server instance (not the JVM's one). Therefore, > you can configure the server yourself. > Check out this documentation page: https://ci.apache.org/ > projects/flink/flink-d

Re: Container JMX port setting / discovery for Flink on YARN

2016-11-25 Thread Robert Metzger
Hi Yury, Flink is using its own JMX server instance (not the JVM's one). Therefore, you can configure the server yourself. Check out this documentation page: https://ci.apache.org/projects/flink/flink-docs-release-1.2/monitoring/metrics.html#reporter metrics.reporter.my_jmx_reporter.class: org.ap

Re: Container JMX port setting / discovery for Flink on YARN

2016-11-25 Thread Yury Ruchin
Thanks Stefan! I think this would help if I had just one container per node. But that's not my case - there are multiple TaskManagers running on the same node, so setting the same value will likely result in port conflict. 2016-11-25 12:28 GMT+03:00 Stefan Richter : > Hi, > > can you try adding t

Re: Container JMX port setting / discovery for Flink on YARN

2016-11-25 Thread Stefan Richter
Hi, can you try adding the following to your flink.yaml? env.java.opts: -Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.port= -Dcom.sun.management.jmxremote.authenticate=false -Dcom.sun.management.jmxremote.ssl=false Best, Stefan > Am 24.11.2016 um 16:47 schrieb Yury Ruchi