Hello everyone, my flink job had some s3 exceptio...
# troubleshooting
y
Hello everyone, my flink job had some s3 exceptions due to the failing checkpoint when the traffic is high and state is big. After my investigation, looks like in the flink filesystem implementation, the action for upload and download are configured with retry mecanism but the action for delete has no re-try mecanism, so when delete failed we have many interruptedException which interrupt the re-try process and failed the checkpoint. So do you know if there is a way to disable the delete of old checkpoint ? I can use object storage's mecanism to handle it (ex: s3 lifecycle) πŸ™‚