Apache Flink：Cassandra Sink metrics

Question

私はCassandra Sinkを使ってFlinkアプリを書いた。すべて正常に動作しますが、Latency、NumRecordsInPerSecondなどのさまざまな指標が生成されていません。

次のグラフは、情報を表示する唯一のグラフです。

私は実際にFlinkが提供するレイテンシメトリックが必要ですが、それはすべてのデータを表示します。

他のグラフを使用するには何か他の操作を行う必要がありますか？特に、レイテンシ1。

ありがとうございました。

Answer 1

LatencyMarkerを無効にしていないことを確認してください。デフォルトでは、各オペレータの待ち時間を計算するためにLatencyMarkerが2秒ごとに発行されます。 LatencyMarkerを送信する間隔をenv.getConfig().setLatencyTrackingInterval(1000L);