Skip to content

W
wj-datacenter-platform
Commit c335a8d1 authored by zhoushiguang's avatar zhoushiguang
Browse files
Options

setMaxConcurrentCheckpoints

parent 25261090
Hide whitespace changes
Inline Side-by-side
Showing with 1 addition and 1 deletion
wj-realtime-computing/src/main/java/com/wanji/indicators/task/lightstatus/TrackLightStatusMain.java
View file @ c335a8d1
......@@ -69,7 +69,7 @@ public class TrackLightStatusMain {
env.enableCheckpointing(2 * 60 * 1000);
env.getCheckpointConfig().setTolerableCheckpointFailureNumber(3);
env.getCheckpointConfig().setCheckpointTimeout(10 * 60 * 1000);
env.getCheckpointConfig().setMaxConcurrentCheckpoints(10);
// env.getCheckpointConfig().setMaxConcurrentCheckpoints(10);
env.getCheckpointConfig().setCheckpointStorage(new FileSystemCheckpointStorage(properties.getProperty("check.point.uri")));
env.getCheckpointConfig().setExternalizedCheckpointCleanup(CheckpointConfig.ExternalizedCheckpointCleanup.DELETE_ON_CANCELLATION);
//============================================================================================//
......
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