[FLINK-34210][Runtime/Checkpointing] Fix DefaultExecutionGraphBuilder…

…#isCheckpointingEnabled return wrong value when checkpoint disabled
apache · Jan 24, 2024 · ee2d9ee · ee2d9ee
1 parent 551bb9e
commit ee2d9ee
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...e/src/main/java/org/apache/flink/runtime/executiongraph/DefaultExecutionGraphBuilder.java b/...e/src/main/java/org/apache/flink/runtime/executiongraph/DefaultExecutionGraphBuilder.java
@@ -347,7 +347,7 @@ public static DefaultExecutionGraph buildGraph(
     }
 
     public static boolean isCheckpointingEnabled(JobGraph jobGraph) {
-        return jobGraph.getCheckpointingSettings() != null;
+        return jobGraph.isCheckpointingEnabled();
     }
 
     // ------------------------------------------------------------------------