Hi Yangze,
I add that file and it works! Thanks for helping with this!
Best,
Fan
From: Yangze Guo
Sent: Tuesday, May 11, 2021 7:12 PM
To: Fan Xie
Cc: user@flink.apache.org
Subject: Re: Customized Metric Reporter can not be found by Flink
Hi, Fan
Flink loaded
Hi, Fan
Flink loaded the custom reporter through the service loader mechanism.[1]
Do you add the service file in the "resources/META-INF/services" directory?
[1] https://docs.oracle.com/javase/9/docs/api/java/util/ServiceLoader.html
Best,
Yangze Guo
On Wed, May 12, 2021 at 7:53 AM Fan Xie wrot
Hi Flink Community,
Recently I implemented a customized metric reporter (named:
DiagnosticsMessageReporter) to report Flink metrics to a Kafka topic. I built
this reporter into a jar file and copy it to
/opt/flink/plugins/DiagnosticsMessageReporter/DiagnosticsMessageReporter.jar
for both the J
