[ https://issues.apache.org/jira/browse/FLINK-10794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Flink Jira Bot updated FLINK-10794: ----------------------------------- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major) Priority: Minor (was: Major) This issue was labeled "stale-major" 7 ago and has not received any updates so it is being deprioritized. If this ticket is actually Major, please raise the priority and ask a committer to assign you the issue or revive the public discussion. > Do not create checkpointStorage when checkpoint is disabled > ----------------------------------------------------------- > > Key: FLINK-10794 > URL: https://issues.apache.org/jira/browse/FLINK-10794 > Project: Flink > Issue Type: Improvement > Components: Runtime / Checkpointing > Reporter: Congxian Qiu > Priority: Minor > Labels: auto-deprioritized-major, auto-unassigned > > 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 > {code:java} > boolean enabledCheckpoint = > configuration.getConfiguration().getBoolean("checkpointing", false); > if (enabledCheckpoint) { > checkpointStorage = > stateBackend.createCheckpointStorage(getEnvironment().getJobID()); > } > {code} > > or just skip the directories creation when create CheckpointStorage -- This message was sent by Atlassian Jira (v8.3.4#803005)