95-136-070-源碼-Operator-擴展有狀態的operators

1.美圖 2.概述 ​ 對於流處理程序來說，一個常見的需求是：根據輸入數據的速率，調節operators的並行度。對於無狀態的operators 來說，擴展是很簡單的。但是對於有狀態的operators，會更具挑戰性，因爲他們的state需要被重新分區，並分配給更多或是更少的並行tasks。Flink支持四種模式，用於擴展不同類型的state。 ​ 對於keyed state的operators，

>>阅读原文<<