Hi John, I've been using a path like this: s3://<bucket>/<path>/savepoint-<savepoint_id> (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 latest restore). On Wed, Jul 6, 2022 at 12:51 PM John Tipper <john_tip...@hotmail.com> wrote: > Hi all, > > > The docs on restoring a job from a savepoint ( > https://nightlies.apache.org/flink/flink-docs-master/docs/ops/state/savepoints/#resuming-from-savepoints) > state that the syntax is: > > $ bin/flink run -s :savepointPath [:runArgs] > > > and where "you may give a path to either the savepoint’s directory or the > _metadata file." > > > If I am using S3 as my store of state: > > state.savepoints.dir: s3://my_bucket/path/to/savepoints > > > and an example savepoint is at: > > > s3://my_bucket/path/to/savepoints/<savepoint id>/_metadata > > > > then what am I supposed to supply to the flink run​ command? Is it: > > > 1. The full path including filesystem: > s3://my_bucket/path/to/savepoints/<savepoint > id>/_metadata or s3://my_bucket/path/to/savepoints/<savepoint id> > 2. or the full path: my_bucket/path/to/savepoints/<savepoint > id>/_metadata or my_bucket/path/to/savepoints/<savepoint id> > 3. or the path relative to the savepoints directory: <savepoint > id>/_metadata or <savepoint id> > > If I supply a directory, do I need to specify a trailing slash? > > Also, is there anything that I will see in the logs that will indicate > that the restore from a savepoint has been successful? > > Many thanks, > > John > >
