[ 
https://issues.apache.org/jira/browse/FLINK-10202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

buptljy updated FLINK-10202:
----------------------------
    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, 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.

  was:
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, 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}


> Enable configuration for state.checkpoint.dir with environment
> --------------------------------------------------------------
>
>                 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, 
> 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