Flink並行度

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