?
Thanks
Thomas
De : Thomas Lamirault [thomas.lamira...@ericsson.com]
Envoyé : vendredi 19 février 2016 10:56
À : user@flink.apache.org
Objet : RE:Flink HA
After set this configuration, I have some exceptions :
java.lang.Exception: Could not restore
After set this configuration, I have some exceptions :
java.lang.Exception: Could not restore checkpointed state to operators and
functions
at
org.apache.flink.streaming.runtime.tasks.StreamTask.restoreStateLazy(StreamTask.java:414)
at
org.apache.flink.streaming.runtime.tasks.St
Thanks for the quick reply !
> state.backend.fs.checkpointdir
Is actually pointing to a hdfs directory but I will modify the
recovery.zookeeper.path.root
> This is only relevant if you are using YARN. From your complete
Yes, I omit to say we will use YARN.
>Does this help?
Yes, a lot :-)
Thom
