Hi,
I think you need to create a savepoint and restore from there.
https://ci.apache.org/projects/flink/flink-docs-release-1.3/setup/savepoints.html
Checkpoint are for automatic recovery within the lifetime of a job,
they're deleted when you stop the job manually.
Regards,
Kien
On 7/10/17 7:20 PM, Aftab Ansari wrote:
Hi,
I am new to flink. I am facing issue implementing checkpoint.
checkpoint related code:
long checkpointInterval =5000;
StreamExecutionEnvironment env = StreamUtils.getEnvironment(params);
//specify backend //env.setStateBackend(new
FsStateBackend("s3n://xxx/flink-state/"), true)); env.setStateBackend(new FsStateBackend("file:///Users/aftabansari/flink-state/",true));
//enable checkpoint env.enableCheckpointing(checkpointInterval,
CheckpointingMode.EXACTLY_ONCE);
env.getCheckpointConfig().setMinPauseBetweenCheckpoints(500);
When I run the code, I can see flink-state being written in my local
machine. but when I stop the job , wait for a few minutes and restart
the job, it does not pick up from the time it left but it starts from
when I started the job.
Could you point out what i am doing wrong. I am testing it locally
from ideaIntellij. below is what i see from localhost. Any help would
be appreciated. Thanks
Inline images 1
Br,
--
Aftab Ansari
Analytics Developer
aftab.ans...@rovio.com <mailto:aftab.ans...@rovio.com>
rovio_logo.gif
Rovio Entertainment Ltd.
Keilaranta 7, FIN - 02150 Espoo, Finland
Mobile: + 358 (0)46 923 3060
www.rovio.com <http://www.rovio.com/>
