Flink並行度

並行執行java 本節介紹如何在Flink中配置程序的並行執行。FLink程序由多個任務(轉換/操做符、數據源和sinks)組成。任務被分紅多個並行實例來執行,每一個並行實例處理任務的輸入數據的子集。任務的並行實例的數量稱之爲並行性。後端 若是要使用保存點,還應該考慮設置最大並行性(或最大並行性)。當從保存點還原時,能夠改變特定運算符或整個程序的並行性,而且該設置指定並行性的上限。這是必需的,由於
相關文章
相關標籤/搜索