Hi,
I am using flink 1.15.3 and have written a custom metric reporter. I want to consume it as a plugin and have followed all necessary steps. My reporter factory implements the MetricReporterFactory and my actual reporter class implements MetricReporter. I have added the shaded jar under a subfolder in plugins directory.
I added the relevant metric.reporters.reporter_name.factory.class config in flink-conf.yaml and when I see the cluster logs, it clearly says that my reporter factory was not found and it is also not in the list of available factories. To be sure of the factory class definition, I explored my jar using
jar xf <name>.jar
and the path clearly exists and is correctly defined in flink-conf.yaml.
My plugins dir looks like:
plugins
metrics-nihar
custom_reporter.jar
Can you please let me know how to debug this further?