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
>
>
>
>
