Hello Everyone, I'm new to flink and i'm trying to upgrade from flink 1.8 to flink 1.11 on an emr cluster. after upgrading to flink1.11 One of the differences that i see is i don't get any metrics. I found out that flink 1.11 does not have *org.apache.flink.metrics.statsd.StatsDReporterFactory* jar in /usr/lib/flink/opt which was the case for flink 1.8. Could anyone have any pointer to locate *org.apache.flink.metrics.statsd.StatsDReporterFactory* jar or how to use metrics in flink.1.11?
Things i tried : a) the below setup metrics.reporters: stsd metrics.reporter.stsd.factory.class: org.apache.flink.metrics.statsd.StatsDReporterFactory metrics.reporter.stsd.host: localhost metrics.reporter.stsd.port: 8125 b) I tried downloading the statsd jar from https://mvnrepository.com/artifact/org.apache.flink/flink-metrics-statsd putting it inside plugins/statsd directory. -- Best, Diwakar Jha.
