Hey Team, I am using NFS mount to store checkpoint...
# troubleshooting
a
Hey Team, I am using NFS mount to store checkpoints from my flink job running in HA application mode with checkpoint retention count as 10. But i get the following error:
Copy code
WARN  org.apache.flink.runtime.checkpoint.CheckpointFailureManager [] - Failed to trigger or complete checkpoint 1 for job 000000006e6b13320000000000000000. (0 consecutive failed attempts so far)
org.apache.flink.runtime.checkpoint.CheckpointException: Failure to finalize checkpoint.

Caused by: java.io.IOException: Target file file:/opt/flink/pm/checkpoint/000000006e6b13320000000000000000/chk-1/_metadata already exists.
	at org.apache.flink.runtime.state.filesystem.FsCheckpointMetadataOutputStream.getOutputStreamWrapper(FsCheckpointMetadataOutputStream.java:168)
And each time if it finds that the folder is already present for the checkpoint its about to create, it throws error, and Job restarts. How to handle it gracefully, or any way if flink job is able to rewrite metadata file in this folder, thus preventing the job to restart. Thanks in advance!