Thanks David, in case of manual restart; to get checkpoint path
programmatically I'm using the following code to retrieve JobId and
CheckpointID so i could pass along while restarting with "-s" but seems I'm
missing something as I'm getting empty TimestampedFileSplit array.
GlobFilePathFilter
If your job crashes, Flink will automatically restart from the latest
checkpoint, without any manual intervention. JobManager HA is only needed
for automatic recovery after the failure of the Job Manager.
You only need externalized checkpoints and "-s :checkpointPath" if you want
to use
Hi,
I'm running Flink job in distributed mode deployed in Yarn; I've enabled
externalized checkpoint to save in Hdfs, but I don't have access to read
checkpoints folder. To restart Flink job from the last saved checkpoint is
it possible to do without passing "-s :checkpointPath". If this is not
