1.1-Flink概念:運行環境

本內容主要參考 flink-runtime 整理 任務和算子鏈 分佈式計算中,Flink 將算子(operator)的 subtask 鏈接(chain)成 task。 每個 task 由一個線程執行。 把算子鏈接成 tasks 能夠減少線程間切換和緩衝的開銷,在降低延遲的同時提高了整體吞吐量。 鏈接操作的配置詳情可參考:chaining docs 下圖的 dataflow 由五個 subtask
相關文章
相關標籤/搜索