Flink 從checkpoint恢復，並行度改變後，狀態重分配

前提： 當Flink左右從checkpoint恢復，或者從savepoint中重啓的時候，就回涉及到狀態的重新分配，尤其是當並行度發生改變的時候。   Operator State Redistribute 當operator改變並行度的時候(Rescale),會觸發狀態的Redistribute，即Operator State裏的數據會重新分配到Operator的Task實例。這裏有三種方式，舉

>>阅读原文<<