Re: Question about checkpoints and savepoints

2021-03-29 Thread Robert Metzger
Mh, did you also check the TaskManger logs? I'm not aware of any known or issues in the past in that direction, the codepaths for checkpoint / savepoint are fairly similar when it comes to storing the data. You could also try to run Flink on DEBUG log level, maybe that reveals something?! On

Re: Question about checkpoints and savepoints

2021-03-26 Thread Robert Cullen
Here’s a snippet from the logs, there are no errors in the logs 2021-03-23 13:11:52,247 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint[] - 2021-03-23 13:11:52,249 INFO

Re: Question about checkpoints and savepoints

2021-03-26 Thread Robert Metzger
Hi, has the "state.savepoints.dir" configuration key the same value as "state.checkpoints.dir"? If not, can you post your configuration keys, and the invocation how you trigger a savepoint? Have you checked the logs? Maybe there's an error message? On Thu, Mar 25, 2021 at 7:17 PM Robert Cullen

Question about checkpoints and savepoints

2021-03-25 Thread Robert Cullen
When I run a job on my Kubernetes session cluster only the checkpoint directories are created but not the savepoints. (Filesystem configured to S3 Minio) Any ideas? -- Robert Cullen 240-475-4490