We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents 372d55e + ecb563c commit 6c2cceeCopy full SHA for 6c2ccee
core/src/main/java/com/dtstack/flink/sql/environment/StreamEnvConfigManager.java
@@ -119,7 +119,7 @@ public static void streamExecutionEnvironmentConfig(StreamExecutionEnvironment s
119
120
// checkpoint config
121
Optional<Boolean> checkpointingEnabled = isCheckpointingEnabled(confProperties);
122
- if (checkpointingEnabled.get()) {
+ if (!checkpointingEnabled.get()) {
123
Optional<Long> checkpointInterval = getCheckpointInterval(confProperties);
124
streamEnv.enableCheckpointing(checkpointInterval.get());
125
0 commit comments