オペレーターの場合、入力ストリームはその出力ストリームよりも高速であるため、その入力バッファーは、データをこのオペレーターに転送する前のオペレーターの出力スレッドをブロックします。右？
Flink と Spark は両方とも、スレッドをブロックすることでバックプレッシャーを処理しますか? それで、それらの違いは何ですか？
データ ソースの場合、データを継続的に生成していますが、その出力スレッドがブロックされている場合はどうなるでしょうか? バッファがオーバーフローしますか?
質問する
3071 次