フライイングなしでFlinkのタプルがウィンドウなし

Question

がウィンドウ演算子を使用しない場合でも、Flinkはアウトオブオーダーのタプルを処理します？例えば

：

withTimestampsAndWatermarks 
     .keyBy(...) 
     .map(...) // some stateful function 
     .addSink(...); 

はmap正しい透かしを受信するまでの要素を処理するために待機するか、待たずに要素を処理しますか？

問題は、mapというパーティション状態が、タプルの順序外処理の影響を受ける可能性があることです。

は事前

Answer 1

短い答えはノーあるにありがとう。マップ演算子はウォーターマークではまったく動作しません。 入力ストリームと同じ順序で要素を取得します。

StreamMap演算子の実装を確認してください。ウォーターマークの要素が出力に転送されるだけです。