Cómo usar las métricas de Flink

Tengo un clúster Apache Flink con el modo independiente, quiero configurar Flink Metrics.

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

excepción

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)

que necesito hacer

use un programa para escuchar el puerto 10000 en 10.0.0.203 u otro

Respuesta 1

Sí, que está informando a la acogida 10.0.0.203:10000, por lo que necesita un puerto de escucha del programa 10000de 10.0.0.203. De lo contrario, Flink no puede enviarle un mensaje. En este caso, debe comenzar Graphiteen este host. Ver el doc .

Respuesta: 2

Tengo que hacer coincidir la siguiente llamada para devolver un objeto: String [] [] parámetros = new String [] [] {new String [] {eq ("proveedor"), eq ("...

Tengo un nodo Json: {"nombre": {"primer": "Tatu", "último": "Saloranta"}, "título": "fundador de Jackson", "compañía": "FasterXML"} Tengo otro Json nodo (el ...

¿Quiero comprobar en un evento de clic de botón si el color de texto actual de ese botón es rojo o no? Lo he hecho hasta ahora: ColorStateList mList = gridcell.getTextColors (); int col = mList ....

Tengo objeto, esto es describirlo? Public MemberSkills (Usuario usuario, habilidades BasicSkills, Nivel corto, Estado corto, LocalDateTime confirmDate, Comentario de cadena) {this.user = user; this.skills ...