1.6 Apache Flink 基本概念 — 分佈式Runtime

分佈式運行時環境 1. 任務與算子鏈 分佈式計算中，Flink會將算子（operator） 的子task鏈式組成tasks，每個task由一個線程執行。把算子鏈化爲tasks是一個非常好的優化：它減少了線程之間的通信和緩衝，而且還能增加吞吐量降低延遲。鏈化操作的配置詳情可參考： chaining docs 下圖中dataflow有5個subtasks，因此有5個線程併發進行處理。 2. Job M

>>阅读原文<<