Re: Restoring a job from a savepoint

2022-07-07 Thread John Tipper
Thank you all, that’s very helpful. It looks like there’s something else that’s causing my cluster to not load my savepoints, so I’ve submitted a separate query for that. Many thanks, John Sent from my iPhone On 6 Jul 2022, at 21:24, Alexander Fedulov wrote:  Hi John, use $ bin/flink run

Re: Restoring a job from a savepoint

2022-07-06 Thread Alexander Fedulov
Hi John, use *$ bin/flink run -s s3://my_bucket/path/to/savepoints/ *(no trailing slash, including schema). where should contain a valid _metadata file. You should see logs like this: *INFO o.a.f.r.c.CheckpointCoordinator [] - Starting job foobar from savepoint s3://my_bucket/path/to/savepoi

Re: Restoring a job from a savepoint

2022-07-06 Thread Yaroslav Tkachenko
Hi John, I've been using a path like this: s3:savepoint- (no trailing slash). I'm pretty sure you need to specify the full path. Yes, you can see savepoint restore in logs. It's also fairly easy to see it in the Flink UI, under the Checkpoints section (it shows the information about the lates