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

Reply via email to