有没有flink checkpoint的设置示例?

提问者:帅平 问题分类:大数据
有没有flink checkpoint的设置示例?
1 个回答
宁愿短发披肩
宁愿短发披肩
flink相关的checkpoint设置示例如下:
// 每 60s 做一次 checkpoint
​env.enableCheckpointing(60000);
​// checkpoint 语义设置为 EXACTLY_ONCE,这是默认语义​
env.getCheckpointConfig().setCheckpointingMode(CheckpointingMode.EXACTLY_ONCE);​
// 两次 checkpoint 的间隔时间至少为 1 s,默认是 0,立即进行下一次 checkpoint​
env.getCheckpointConfig().setMinPauseBetweenCheckpoints(1000);​
// checkpoint 必须在 60s 内结束,否则被丢弃,默认是 10 分钟​
env.getCheckpointConfig().setCheckpointTimeout(60000);​
// 同一时间只能允许有一个 checkpoint​
env.getCheckpointConfig().setMaxConcurrentCheckpoints(1);
​// 最多允许 checkpoint 失败 3 次​
env.getCheckpointConfig().setTolerableCheckpointFailureNumber(3);
发布于:3个月前 (02-06) IP属地:四川省
我来回答