Details
-
Improvement
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
-
None
-
None
-
None
Description
Usually we can set state.checkpoint.dir in flink-conf.yaml, but sometimes we run a flink job locally, and we're not able to set state.checkpoint.dir for background wrapped cluster, which will cause
throw new IllegalStateException("CheckpointConfig says to persist periodic " + "checkpoints, but no checkpoint directory has been configured. You can " + "configure configure one via key '" + ConfigConstants.CHECKPOINTS_DIRECTORY_KEY + "'.");
I wonder if we could provide a public method in StreamExecutionEnvironment so that developers can use it to set state.checkpoint.dir for job.