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)
