Apache Flink: Cassandra Sink metrics

Question

I wrote a Flink app, using a Cassandra Sink. Everything works really well, but various metrics are not being generated (like Latency, NumRecordsInPerSecond, etc).

The following graphs are the only ones that show information.

I really need the latency metric Flink offers, but It doenst show any data.

Do I need to do something else to get the others graphs to work? Especially, the latency one.

Thanks.

Answer 1

Make sure you have not disabled LatencyMarker. By default, the LatencyMarker will be emitted every 2 seconds to calculate latency for each operator. You can set the interval to send LatencyMarker through env.getConfig().setLatencyTrackingInterval(1000L);