Задание Flink успешно выполняется, но не создается метрика mbean в jconsole в среде EMR.
То же задание создает Mbean в локальной среде, как показано на скриншоте ниже: https://i.stack.imgur.com/GJC6m.png
Локально я скачал flink-1.8.0-bin-scala_2.11 для запуска задания flink, jar метрик присутствует в локальной среде (в папках lib и opt), показанной ниже на скриншоте:
opt folder: https://i.stack.imgur.com/MjkI2.png
Папка Lib: https://i.stack.imgur.com/vkeUc.png
Details of softwares used:
1) AWS EMR version- 5.24.1
2) FLink version - 1.8.0
3) jdk version 1.8.0_31
Tried adding below libraries didn't helped:
flink-metrics-core-1.8.1.jar
flink-metrics-statsd-1.8.1.jar
configured flink-conf.yaml with below on both local and EMR environment:
metrics.reporters: jmx
metrics.reporter.jmx.class: org.apache.flink.metrics.jmx.JMXReporter
metrics.reporter.jmx.port: Portno( 9000)