[
https://issues.apache.org/jira/browse/FLINK-10794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17323443#comment-17323443
]
Flink Jira Bot commented on FLINK-10794:
----------------------------------------
This issue is assigned but has not received an update in 7 days so it has been
labeled "stale-assigned". If you are still working on the issue, please give an
update and remove the label. If you are no longer working on the issue, please
unassign so someone else may work on it. In 7 days the issue will be
automatically unassigned.
> 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
> Assignee: Congxian Qiu
> Priority: Major
> Labels: stale-assigned
>
> 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)
