[jira] [Created] (FLINK-10794) Do not create checkpointStorage when checkpoint is disabled

[Shang Yuanchun (Jira)]

Congxian Qiu created FLINK-10794:
------------------------------------

             Summary: 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
            Reporter: Congxian Qiu


In `StreamTask#invoke` will create CheckpointStore by `stateBackend.createCheckpointStorage`, and create some directories if needed. but if the checkpoint is disabled, the checkpointstore could never be created. 

 

IMO, the code could change to something like below

`
{code:java}
boolean enabledCheckpoint = "true".equalsIgnoreCase(configuration.getConfiguration().getString("checkpointing", "false"));
if (enabledCheckpoint) {
   checkpointStorage = stateBackend.createCheckpointStorage(getEnvironment().getJobID());
}
{code}



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)