Flink無法將指標發送給Graphite

我有兩個Apache Flink集羣：生產中的1.1.3和分段中的1.3.2。Flink無法將指標發送給Graphite

我有興趣將指標發送到Graphite服務器，因此我按照https://ci.apache.org/projects/flink/flink-docs-release-1.3/monitoring/metrics.html中的說明進行設置。

我得到它在我的1.1.3羣集，但不是在1.3.2。我加入弗林克lib目錄下的jar文件：

在1.1.3：

在1.3.2 ：

我添加的設置是兩個相同的（除了它們發送到不同的石墨服務器）：

metrics.reporters: grph 
metrics.reporter.grph.class: org.apache.flink.metrics.graphite.GraphiteReporter 
metrics.reporter.grph.host: 10.x.x.x 
metrics.reporter.grph.port: 2003 
metrics.reporter.grph.prefix: flink 
metrics.reporter.grph.protocol: TCP

我在分段集羣中看到的錯誤消息（1 .3.2）是：

2017-08-07 13:13:15.892 main ERROR org.apache.flink.runtime.metrics.MetricRegistry Could not instantiate metrics reporter grph. Metrics might not be exposed/reported. 
java.lang.NoClassDefFoundError: com/codahale/metrics/Reporter 
    at java.lang.ClassLoader.defineClass1(Native Method) 
    at java.lang.ClassLoader.defineClass(ClassLoader.java:763) 
    at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142) 
    at java.net.URLClassLoader.defineClass(URLClassLoader.java:467) 
    at java.net.URLClassLoader.access$100(URLClassLoader.java:73) 
    at java.net.URLClassLoader$1.run(URLClassLoader.java:368) 
    at java.net.URLClassLoader$1.run(URLClassLoader.java:362) 
    at java.security.AccessController.doPrivileged(Native Method) 
    at java.net.URLClassLoader.findClass(URLClassLoader.java:361) 
    at java.lang.ClassLoader.loadClass(ClassLoader.java:424) 
    at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:335) 
    at java.lang.ClassLoader.loadClass(ClassLoader.java:357) 
    at java.lang.ClassLoader.defineClass1(Native Method) 
    at java.lang.ClassLoader.defineClass(ClassLoader.java:763) 
    at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142) 
    at java.net.URLClassLoader.defineClass(URLClassLoader.java:467) 
    at java.net.URLClassLoader.access$100(URLClassLoader.java:73) 
    at java.net.URLClassLoader$1.run(URLClassLoader.java:368) 
    at java.net.URLClassLoader$1.run(URLClassLoader.java:362) 
    at java.security.AccessController.doPrivileged(Native Method) 
    at java.net.URLClassLoader.findClass(URLClassLoader.java:361) 
    at java.lang.ClassLoader.loadClass(ClassLoader.java:424) 
    at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:335) 
    at java.lang.ClassLoader.loadClass(ClassLoader.java:357) 
    at java.lang.Class.forName0(Native Method) 
    at java.lang.Class.forName(Class.java:264) 
    at org.apache.flink.runtime.metrics.MetricRegistry.<init>(MetricRegistry.java:123) 
    at org.apache.flink.runtime.taskexecutor.TaskManagerServices.fromConfiguration(TaskManagerServices.java:188) 
    at org.apache.flink.runtime.taskmanager.TaskManager$.startTaskManagerComponentsAndActor(TaskManager.scala:1921) 
    at org.apache.flink.runtime.taskmanager.TaskManager$.runTaskManager(TaskManager.scala:1819) 
    at org.apache.flink.runtime.taskmanager.TaskManager$.selectNetworkInterfaceAndRunTaskManager(TaskManager.scala:1673) 
    at org.apache.flink.runtime.taskmanager.TaskManager$$anon$2.call(TaskManager.scala:1574) 
    at org.apache.flink.runtime.taskmanager.TaskManager$$anon$2.call(TaskManager.scala:1572) 
    at org.apache.flink.runtime.security.HadoopSecurityContext$1.run(HadoopSecurityContext.java:43) 
    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:1657) 
    at org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:40) 
    at org.apache.flink.runtime.taskmanager.TaskManager$.main(TaskManager.scala:1572) 
    at org.apache.flink.runtime.taskmanager.TaskManager.main(TaskManager.scala) 
Caused by: java.lang.ClassNotFoundException: com.codahale.metrics.Reporter 
    at java.net.URLClassLoader.findClass(URLClassLoader.java:381) 
    at java.lang.ClassLoader.loadClass(ClassLoader.java:424) 
    at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:335) 
    at java.lang.ClassLoader.loadClass(ClassLoader.java:357) 
    ... 40 common frames omitted

任何幫助將不勝感激！

來源

2017-08-07 yosi1984

您必須將io.dropwizard.metrics：metrics-core 3.1.0添加到/ lib文件夾。原因是在1.1版本中，Flink運行時本身使用了metrics-core，這在1.3中已不再是這種情況。

另外，你也可以使用flink-metrics-graphite jar -with-dependencies，它應該包含你需要的所有東西。

來源

2017-08-07 16:16:07

我沒有提到它，但我在兩個集羣上均有提及（http://central.maven.org/maven2/io/dropwizard/metrics/metrics-graphite/3.1.0/metrics-graphite-3.1.0 .jar） – yosi1984

這就是metrics-graphite，我正在談論metrics-core。 http://central.maven.org/maven2/io/dropwizard/metrics/metrics-core/3.1.0/metrics-core-3.1.0.jar –

我的不好，對此感到遺憾......它沒有，然而，有什麼區別。日誌文件仍然抱怨缺少的方法（java.lang.NoSuchMethodError：com.codahale.metrics.graphite.GraphiteReporter $ Buil der.build（Lcom/codahale/metrics/graphite/Graphite;）Lcom/codahale/metrics/graphit e/GraphiteReporter;）還有什麼我可能會失蹤？ – yosi1984

Flink無法將指標發送給Graphite

回答

相關問題