如果我flink程序掛掉了,我從checkpoint重啟的話,會從source那裏重新計算,還是從中

阿裏雲問答 2022-01-07 23:13:47 阅读数:321

flink 程序 掉了 checkpoint source

如果我flink程序掛掉了,我從checkpoint重啟的話,會從source那裏重新計算,還是從中間某個算子開始計算?




采納答案1:

所有算子加載各自的狀態,source裏面會加載offset開始消費,流向下遊


版权声明:本文为[阿裏雲問答]所创,转载请带上原文链接,感谢。 https://gsmany.com/2022/01/202201072313466551.html