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)
