With Flink 1.11 reporters were refactored to plugins, and are now
accessible by default (so you no longer have to bother with copying jars
around).
Your configuration appears to be correct, so I suggest to take a look at
the log files.
On 10/25/2020 9:52 PM, Diwakar Jha wrote:
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.
