クラウドデータフローストリーミングジョブのシステム遅延をリセットする

Question

定義ごとに、システム遅延は、要素が処理を待っている最大時間です。データフローがクラウドPubSubからのメッセージを消費していると仮定します。何らかの理由で承認されなかったメッセージがあった場合、システム・ラグは上昇し続けます（その1メッセージのため）。ジョブを終了せずにストリーミングジョブのシステム遅延をリセットする方法はありますか？

Answer 1

システム遅延を手動でリセットすることはできません。システム・ラグは、パイプラインの健全性を示すものです。あなたが言及した1つのメッセージに起因する大きなシステム・ラグは、パイプラインの問題をすばやく見るのに役立ちます。ブロッキングメッセージが処理されると、システムの遅延は現在のパイプライン状態を示す新しい値で更新されます。