我用CassandraFlume写了一个flink应用程序。一切都很好,但是没有生成各种度量(比如延迟、numrecordsinpersecond等)。以下图表是唯一显示信息的图表。我真的需要flink提供的延迟度量,但它没有显示任何数据。我需要做些别的事情来让其他的图工作吗?尤其是潜伏期。谢谢。
m4pnthwp1#
确保未禁用latencymarker。默认情况下,latencymarker将每2秒发出一次,以计算每个操作符的延迟。您可以设置发送latencymarker的间隔 env.getConfig().setLatencyTrackingInterval(1000L);
env.getConfig().setLatencyTrackingInterval(1000L);
1条答案
按热度按时间m4pnthwp1#
确保未禁用latencymarker。默认情况下,latencymarker将每2秒发出一次,以计算每个操作符的延迟。您可以设置发送latencymarker的间隔
env.getConfig().setLatencyTrackingInterval(1000L);