Flink 原理架構總結

1、流式任務執行過程 1.任務並行      按照本身的理解，一個流程以下圖所示，除非經歷shuffle過程，不然流程並行度將由source的並行度決定，好比kafka分區數目，shuffle以後的並行度，可能會改變，Operator子任務(Task)彼此獨立，而且能夠在不一樣的線程中執行，而且可能在不一樣的機器或容器上執行。java 2.OperatorChain     原理同Spark 的S

>>阅读原文<<