Apache : Cassandra Sink度量

Question

我用卡桑德拉水槽写了一个Flink应用程序。一切都运行得很好，但是没有生成各种指标(比如延迟、NumRecordsInPerSecond等)。

下面的图表是唯一显示信息的图表。

​

我确实需要Flink提供的延迟度量，但它确实显示了任何数据。

我是否需要做一些其他的事情来让其他的图表工作呢？尤其是潜伏期一号。

谢谢。

Answer 1

确保您没有禁用LatencyMarker。默认情况下，LatencyMarker将每2秒发出一次，以计算每个操作符的延迟。可以设置通过LatencyMarker通过env.getConfig().setLatencyTrackingInterval(1000L);发送env.getConfig().setLatencyTrackingInterval(1000L);的间隔。