use env.getCheckpointConfig().disableCheckpointing() to disable checkpoint

baisui1981 · baisui1981 · commit f4592ee65176 · 2025-12-25T17:18:29.000+08:00
diff --git a/tis-incr/tis-realtime-flink/src/main/java/com/qlangtech/plugins/incr/flink/launch/ckpt/CKOff.java b/tis-incr/tis-realtime-flink/src/main/java/com/qlangtech/plugins/incr/flink/launch/ckpt/CKOff.java
@@ -32,7 +32,7 @@
 public class CKOff extends CheckpointFactory {
     @Override
     public void setProps(StreamExecutionEnvironment env) {
-        env.enableCheckpointing(-1);
+        env.getCheckpointConfig().disableCheckpointing();
     }
 
     @Override

Original file line number	Diff line number	Diff line change
`@@ -32,7 +32,7 @@`
`32`	`32`	`public class CKOff extends CheckpointFactory {`
`33`	`33`	`@Override`
`34`	`34`	`public void setProps(StreamExecutionEnvironment env) {`
`35`		`- env.enableCheckpointing(-1);`
	`35`	`+ env.getCheckpointConfig().disableCheckpointing();`
`36`	`36`	`}`
`37`	`37`
`38`	`38`	`@Override`