Hi Chesnay, Another log message:
2020-10-26 23:33:08,516 WARN org.apache.flink.runtime.metrics.ReporterSetup - The reporter factory (org.apache.flink.metrics.graphite.GraphiteReporterFactory) could not be found for reporter grph. Available factories: [org.apache.flink.runtime.metrics.ReporterSetupTest$ConfigExposingReporterFactory, org.apache.flink.runtime.metrics.ReporterSetupTest$TestReporterFactory, org.apache.flink.runtime.metrics.ReporterSetupTest$InstantiationTypeTrackingTestReporterFactory, org.apache.flink.runtime.metrics.ReporterSetupTest$FailingFactory]. 2020-10-26 23:33:08,517 INFO org.apache.flink.runtime.metrics.MetricRegistryImpl - No metrics reporter configured, no metrics will be exposed/reported. Regards, Vijay On Mon, Oct 26, 2020 at 2:34 PM Vijayendra Yadav <contact....@gmail.com> wrote: > Hi Chesnay, > > I have the same, and I am exporting the flinkconf like below, where i have > flink-conf.yaml with configuration you have given.What else can I try ? > > export FLINK_CONF_DIR=${app_install_path}/flinkconf/ > > regards, > Vijay > > On Sun, Oct 25, 2020 at 8:03 AM Chesnay Schepler <ches...@apache.org> > wrote: > >> Ah wait, in 1.11 it should not longer be necessary to explicitly copy the >> reporter jar. >> >> Please update your reporter configuration to this: >> >> metrics.reporter.grph.factory.class: >> org.apache.flink.metrics.graphite.GraphiteReporterFactory >> >> On 10/25/2020 4:00 PM, Chesnay Schepler wrote: >> >> Have you followed the documentation, specifically this bit? >> >> > In order to use this reporter you must copy >> /opt/flink-metrics-influxdb-1.11.2.jar into the plugins/influxdb folder >> of your Flink distribution. >> >> On 10/24/2020 12:17 AM, Vijayendra Yadav wrote: >> >> Hi Team, >> >> for Flink 1.11 Graphite Metrics. I see the following Error in the log. >> Any suggestions? >> >> 020-10-23 21:55:14,652 ERROR org.apache.flink.runtime.metrics.ReporterSetup >> - Could not instantiate metrics reporter grph. Metrics might >> not be exposed/reported. >> java.lang.ClassNotFoundException: >> org.apache.flink.metrics.graphite.GraphiteReporter >> at java.net.URLClassLoader.findClass(URLClassLoader.java:382) >> at java.lang.ClassLoader.loadClass(ClassLoader.java:418) >> at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:352) >> at java.lang.ClassLoader.loadClass(ClassLoader.java:351) >> at java.lang.Class.forName0(Native Method) >> at java.lang.Class.forName(Class.java:264) >> at >> org.apache.flink.runtime.metrics.ReporterSetup.loadViaReflection(ReporterSetup.java:313) >> at >> org.apache.flink.runtime.metrics.ReporterSetup.loadReporter(ReporterSetup.java:274) >> at >> org.apache.flink.runtime.metrics.ReporterSetup.setupReporters(ReporterSetup.java:235) >> at >> org.apache.flink.runtime.metrics.ReporterSetup.fromConfiguration(ReporterSetup.java:148) >> at >> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.createMetricRegistry(ClusterEntrypoint.java:316) >> at >> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.initializeServices(ClusterEntrypoint.java:270) >> at >> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runCluster(ClusterEntrypoint.java:208) >> at >> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.lambda$startCluster$0(ClusterEntrypoint.java:169) >> at java.security.AccessController.doPrivileged(Native Method) >> at javax.security.auth.Subject.doAs(Subject.java:422) >> at >> org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1893) >> at >> org.apache.flink.runtime.security.contexts.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41) >> at >> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:168) >> at >> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runClusterEntrypoint(ClusterEntrypoint.java:517) >> at >> org.apache.flink.yarn.entrypoint.YarnJobClusterEntrypoint.main(YarnJobClusterEntrypoint.java:89) >> >> >> Regards, >> Vijay >> >> >> >>