【Flink原理和應用】:Blink作了哪些改進

1. Runtime 引入了可插拔的Shuffle策略。 自定義調度器,開發者根據計算模型自身的特色定製不一樣調度器。 Blink能夠更加靈活地將算子chain在一塊兒,避免沒必要要的數據傳輸。 引入全新的JM FailOver機制,JM 發生錯誤以後,新的 JM 會從新接管整個 JOB 而不是重啓 JOB,從而大大減小了 JM FailOver 對 JOB 的影響。 2. SQL/TableAP
相關文章
相關標籤/搜索