Skip to content

D
dsk-dsc-flink
Commit 7dbb7b90 authored by liaowenwu's avatar liaowenwu
Browse files
Options

增加并行度

parent 4a492dfd
Show whitespace changes
Inline Side-by-side
Showing with 2 additions and 2 deletions
src/main/java/com/dsk/flink/dsc/sync/SyncCustomerDataSource.java
View file @ 7dbb7b90
...@@ -50,9 +50,9 @@ public class SyncCustomerDataSource { ...@@ -50,9 +50,9 @@ public class SyncCustomerDataSource {
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
//env.setParallelism(1); //env.setParallelism(1);
env.setRestartStrategy(RestartStrategies.fixedDelayRestart(50, 30000)); env.setRestartStrategy(RestartStrategies.fixedDelayRestart(50, 30000));
env.enableCheckpointing(120000); env.enableCheckpointing(300000);
env.getCheckpointConfig().setCheckpointingMode(CheckpointingMode.EXACTLY_ONCE); env.getCheckpointConfig().setCheckpointingMode(CheckpointingMode.EXACTLY_ONCE);
env.getCheckpointConfig().setMinPauseBetweenCheckpoints(120000); env.getCheckpointConfig().setMinPauseBetweenCheckpoints(300000);
env.getCheckpointConfig().setCheckpointTimeout(7200000); env.getCheckpointConfig().setCheckpointTimeout(7200000);
env.getCheckpointConfig().setMaxConcurrentCheckpoints(1); env.getCheckpointConfig().setMaxConcurrentCheckpoints(1);
env.getCheckpointConfig().setExternalizedCheckpointCleanup(CheckpointConfig.ExternalizedCheckpointCleanup.RETAIN_ON_CANCELLATION); env.getCheckpointConfig().setExternalizedCheckpointCleanup(CheckpointConfig.ExternalizedCheckpointCleanup.RETAIN_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