2016-08-29 13 views
0

演算子の場合、入力ストリームは出力ストリームより高速です。したがって、入力バッファは、この演算子にデータを転送する前の演算子の出力スレッドをブロックします。右?Apache Flink:バックプレッシャーはどのように処理されますか?

スレッドをブロックすることで、FlinkとSparkの両方が背圧を処理しますか?だから彼らの違いは何ですか?

データソースについては、データを継続的に生成していますが、出力スレッドがブロックされている場合はどうなりますか?バッファがオーバーフローしますか?

答えて

関連する問題