理解Flink並行處理

理解Flink並行處理 ··························· 分佈式計算中,Flink 將算子(operator)的 subtask *鏈接(chain)*成 task【類似於Spark中的Stage階段】。每個 task 由一個線程執行。把算子鏈接成 tasks 能夠減少線程間切換和緩衝的開銷,在降低延遲的同時提高了整體吞吐量。 當前的flink應用由3個Task,5個SubT
相關文章
相關標籤/搜索