Enabling savepoints for Flink applications
Beside checkpointing, you are also able to create a savepoint of your executed Flink jobs. Savepoints are not automatically created, so you need to trigger them in case of upgrade or maintenance. You can also resume your applications from savepoint.
You can set the default savepoint directory in flink-conf.yaml under
state.savepoints.dir property.
The following command lines can be used to maintain savepoints:
| Trigger savepoint | $ bin/flink savepoint -yid <yarnAppID>
<jobId> [targetDirectory] |
| Stop job with savepoint | $ bin/flink stop -yid <yarnAppID>
<jobId> |
| Resume from savepoint | $ bin/flink run -s <savepointPath>
[runArgs] |
| Deleting savepoint | $ bin/flink savepoint -d
<savepointPath> |
