[FLINK-10794] Do not create checkpointStorage when checkpoint is disabled

• Type: Improvement
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Component/s: Runtime / Checkpointing
• Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned
• Assignee: Unassigned
• Reporter: Congxian Qiu
• Created: 05/Nov/18 12:09
• Updated: 26/Dec/21 10:39

Description

In `StreamTask#invoke` will create CheckpointStore by `stateBackend.createCheckpointStorage`, and create some directories.

But if the checkpoint is disabled, we could skip the creation of checkpointStore.

 

IMO, the code could change to something like below

boolean enabledCheckpoint = configuration.getConfiguration().getBoolean("checkpointing", false);
if (enabledCheckpoint) {
   checkpointStorage = stateBackend.createCheckpointStorage(getEnvironment().getJobID());
}

 

or just skip the directories creation when create CheckpointStorage