Flink代碼kill掉yarn任務,並且實現自動savepoint。

一,最近在做平臺,就是前後端分離的項目,簡單的說就是對各種組件整合一下子,所以呢,提交任務啥的都在平臺上搞了。 二,這裏實現的功能很簡單吧。就是代碼模式,執行任務就可以kill掉yarn上的Flink任務。並且能自動生成savapoint 三,我們需要寫入的參數是:    1)yarn 任務id  String appId = "application_1600222031782_0023";  
相關文章
相關標籤/搜索