java - 如何使用 Flink Metrics
问题描述
我有一个独立模式的 Apache Flink 集群,我想配置 Flink Metrics。
在 flink-conf.yaml 中配置
metrics.reporters: my_jmx_reporter,my_other_reporter
metrics.reporter.my_jmx_reporter.class: org.apache.flink.metrics.jmx.JMXReporter
metrics.reporter.my_jmx_reporter.port: 9020-9040
metrics.reporter.my_other_reporter.class: org.apache.flink.metrics.graphite.GraphiteReporter
metrics.reporter.my_other_reporter.host: 10.0.0.203
metrics.reporter.my_other_reporter.port: 10000
例外
2019-01-17 20:54:25.758 [Flink-MetricRegistry-thread-1] WARN com.codahale.metrics.graphite.GraphiteReporter - Unable to report to Graphite
java.net.ConnectException: Connection refused (Connection refused)
at java.net.PlainSocketImpl.socketConnect(Native Method)
at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
at java.net.Socket.connect(Socket.java:589)
at java.net.Socket.connect(Socket.java:538)
at java.net.Socket.<init>(Socket.java:434)
at java.net.Socket.<init>(Socket.java:244)
at javax.net.DefaultSocketFactory.createSocket(SocketFactory.java:277)
at com.codahale.metrics.graphite.Graphite.connect(Graphite.java:128)
at com.codahale.metrics.graphite.GraphiteReporter.report(GraphiteReporter.java:166)
at org.apache.flink.dropwizard.ScheduledDropwizardReporter.report(ScheduledDropwizardReporter.java:231)
at org.apache.flink.runtime.metrics.MetricRegistryImpl$ReporterTask.run(MetricRegistryImpl.java:427)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:748)
我需要做什么
在 10.0.0.203 或其他东西上使用程序监听 10000 端口
解决方案
推荐阅读
- node.js - NODE express route 无法GET /
- amazon-web-services - AWS CONSOLE 我可以使用不在我的组织中的用户吗
- javascript - 如何在 KaiOS 应用中启用模拟光标?
- android - Android 10 中没有设备过滤器的 USB_DEVICE_ATTACHED
- windev - 是否可以将基于 Windows 操作系统的 WINDEV 部署到 Linux 操作系统中?
- momentjs - 显示相对时间时结合天数和小时数
- linux - 为 txt 文件中的列提取一组字符
- c - sprintf() 函数更改输入参数
- javascript - 关于负载均衡的快递上传文件?
- git - Azure Devops Git 历史树视图 - 树未连接?