Flink 原理與實現:理解 Flink 中的計算資源

Operator Chains 爲了更高效地分佈式執行,Flink會盡可能地將operator的subtask鏈接(chain)在一起形成task。每個task在一個線程中執行。將operators鏈接成task是非常有效的優化:它能減少線程之間的切換,減少消息的序列化/反序列化,減少數據在緩衝區的交換,減少了延遲的同時提高整體的吞吐量。 我們仍以經典的 WordCount 爲例(參考前文Job例
相關文章
相關標籤/搜索