[jira] [Created] (FLINK-34210) DefaultExecutionGraphBuilder#isCheckpointingEnabled may return Wrong Value when checkpoint disabled

["Yue Ma (Jira)" <ji...@apache.org>]

Yue Ma created FLINK-34210:
------------------------------

             Summary: DefaultExecutionGraphBuilder#isCheckpointingEnabled may return Wrong Value when checkpoint disabled
                 Key: FLINK-34210
                 URL: https://issues.apache.org/jira/browse/FLINK-34210
             Project: Flink
          Issue Type: Bug
          Components: Runtime / Checkpointing
    Affects Versions: 1.18.1, 1.19.0
            Reporter: Yue Ma


The *DefaultExecutionGraphBuilder* will call 
_isCheckpointingEnabled(JobGraph jobGraph)_
to determine whether the job has enabled Checkpoint and whether to initialize CheckpointCoordinator related components such as CheckpointCoordinator, CheckpointIDCounter , etc.

The problem is that the logic for determining isCheckpointingEnable here is inaccurate, as *jobGraph. getCheckpointingSettings()* will not be NULL when checkpoint is not enabled, but with CheckpointCoordinatorConfiguration.DISABLED_CHECKPOINT_INTERVAL Interval

The method to fix this problem is also quite clear. We need to directly reuse the result of jobGraph.isCheckpointingEnable() here

 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)