Commit e9e03a99 authored by 薛鹏飞's avatar 薛鹏飞

Merge branch 'liuzhe' into 'master'

update checkout time from 1s to 5m

See merge request !2
parents 42bc3ea7 f4fde7b3
......@@ -92,8 +92,8 @@ public class PreciseExposureStreaming {
/*
checkpoint设置
*/
//start a checkpoint every 1000 ms
env.enableCheckpointing(1000);
//start a checkpoint every 300000 ms(时间设置太短导致checkout还未完成就已超时,目前设置为5分钟)
env.enableCheckpointing(300000);
//set mode to exactly-once (this is the default)
env.getCheckpointConfig().setCheckpointingMode(CheckpointingMode.EXACTLY_ONCE);
//make sure 500 ms of progress happen between checkpoints
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment