Hi All

I am creating a poc where i am trying the out of box feature of flink
for managed state of operator . I am able to create the checkpoint while
running my app in eclipse but when i am trying to restart the app . I am
unable to restore
the state.

Please find attached below snippet.

step followed
1) ran the application that generate tuple automatically.
2) check-pointing is triggering as  it configured.(able to see the data
being written in files)
3) stopped the app in eclipse
4) restart the application (unable to restore)



-- 
*Cheers *

*Puneet*

Attachment: TestCheckPointing.java
Description: Binary data

Reply via email to