Can you provide us with the job code?
I assume that checkpointing runs properly if you submit the same job to
a normal cluster?
On 25.07.2018 13:15, Vinay Patil wrote:
No error in the logs. That is why I am not able to understand why
checkpoints are not getting triggered.
Regards,
Vinay Patil
On Wed, Jul 25, 2018 at 4:44 PM Vinay Patil <vinay18.pa...@gmail.com
<mailto:vinay18.pa...@gmail.com>> wrote:
Hi Chesnay,
No error in the logs. That is why I am not able to understand why
checkpoints are getting triggered.
Regards,
Vinay Patil
On Wed, Jul 25, 2018 at 4:36 PM Chesnay Schepler
<ches...@apache.org <mailto:ches...@apache.org>> wrote:
Please check the job- and taskmanager logs for anything
suspicious.
On 25.07.2018 12:33, Vinay Patil wrote:
Hi,
I am starting the cluster using bootstrap application where
in I am calling Job Manager and Task Manager main class to
form the cluster. The HA cluster is formed correctly and I am
able to submit jobs to this cluster using
RemoteExecutionEnvironment but when I enable checkpointing in
code I do not see any checkpoints triggered on Flink UI.
Am I missing any configurations to be set for the
RemoteExecutionEnvironment for checkpointing to work.
Regards,
Vinay Patil
