[ 
https://issues.apache.org/jira/browse/FLINK-10202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16592593#comment-16592593
 ] 

Stephan Ewen commented on FLINK-10202:
--------------------------------------

Starting from Flink 1.5, all checkpoints are externally addressable, and 
external metadata is always in the same directory as state data. So the one 
checkpoint directory that you pass to the FsStateBackend should be enough...

> Enable configuration for state.checkpoint.dir in StreamExecutionEnvironment
> ---------------------------------------------------------------------------
>
>                 Key: FLINK-10202
>                 URL: https://issues.apache.org/jira/browse/FLINK-10202
>             Project: Flink
>          Issue Type: Improvement
>            Reporter: buptljy
>            Priority: Major
>
> 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 
> {code:java}
> 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 + "'.");
> {code}
> I wonder if we could provide a public method in *StreamExecutionEnvironment* 
> so that developers can use it to set state.checkpoint.dir for job.



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

Reply via email to