apache flink:cassandra sink度量

kkbh8khc  于 2021-06-25  发布在  Flink
关注(0)|答案(1)|浏览(461)

我用CassandraFlume写了一个flink应用程序。一切都很好,但是没有生成各种度量(比如延迟、numrecordsinpersecond等)。
以下图表是唯一显示信息的图表。

我真的需要flink提供的延迟度量,但它没有显示任何数据。
我需要做些别的事情来让其他的图工作吗?尤其是潜伏期。
谢谢。

m4pnthwp

m4pnthwp1#

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

相关问题