check checkpoint open

Author: todd5167

core/src/main/java/com/dtstack/flink/sql/environment/StreamEnvConfigManager.java

@@ -117,7 +117,7 @@ public static void streamExecutionEnvironmentConfig(StreamExecutionEnvironment s
 
         // checkpoint config
         Optional<Boolean> checkpointingEnabled = isCheckpointingEnabled(confProperties);
-        if (checkpointingEnabled.get()) {
+        if (!checkpointingEnabled.get()) {
             Optional<Long> checkpointInterval = getCheckpointInterval(confProperties);
             streamEnv.enableCheckpointing(checkpointInterval.get());