3.4　Flink流數據分區

Flink應用程序本質上是并行和分布式的。在程序執行期間，一個流被切分為一個或多個流分區，每個運算符有一個或多個運算子任務。運算子任務彼此獨立，并在不同的線程中執行，也可能在不同的機器或容器上執行。運算子任務的數量是該運算符的并行度。

有狀態運算符的并行實例集實際上是切分的key-value存儲。每個并行實例負責處理特定key組的事件，這些key的狀態保存在本地。