flink checkpoint

 flink checkpoint的时候会将window的watermark一并保存下来吗?从故障中恢复window operation的时候是怎样的过程呢?

wangxiaolei

赞同来自:

嗯  昨天讲的internaltimerservice也会做容错处理  里面会保存和时间相关的一些信息

爱疯才会赢

赞同来自:

分享两篇Flink时间窗口相关的博文,讲得挺清楚的 Flink Event Time Processing and Watermarks http://vishnuviswanath.com/flink_eventtime Session Windows in Apache Flink http://vishnuviswanath.com/fli ... .html

要回复问题请先登录注册