org.apache.flink.runtime.rest.handler.job.savepoints

Class SavepointHandlers

java.lang.Object

org.apache.flink.runtime.rest.handler.async.AbstractAsynchronousOperationHandlers<AsynchronousJobOperationKey,String>

org.apache.flink.runtime.rest.handler.job.savepoints.SavepointHandlers

public class SavepointHandlers
extends AbstractAsynchronousOperationHandlers<AsynchronousJobOperationKey,String>

HTTP handlers for asynchronous triggering of savepoints.

Drawing savepoints is a potentially long-running operation. To avoid blocking HTTP connections, savepoints must be drawn in two steps. First, an HTTP request is issued to trigger the savepoint asynchronously. The request will be assigned a TriggerId, which is returned in the response body. Next, the returned id should be used to poll the status of the savepoint until it is finished.

A savepoint is triggered by sending an HTTP POST request to /jobs/:jobid/savepoints. The HTTP request may contain a JSON body to specify the target directory of the savepoint, e.g.,

 { "target-directory": "/tmp" }
 

If the body is omitted, or the field target-property is null, the default savepoint directory as specified by CheckpointingOptions.SAVEPOINT_DIRECTORY will be used. As written above, the response will contain a request id, e.g.,

 { "request-id": "7d273f5a62eb4730b9dea8e833733c1e" }
 

To poll for the status of an ongoing savepoint, an HTTP GET request is issued to /jobs/:jobid/savepoints/:savepointtriggerid. If the specified savepoint is still ongoing, the response will be

 {
     "status": {
         "id": "IN_PROGRESS"
     }
 }
 

If the specified savepoint has completed, the status id will transition to COMPLETED, and the response will additionally contain information about the savepoint, such as the location:

 {
     "status": {
         "id": "COMPLETED"
     },
     "operation": {
         "location": "/tmp/savepoint-d9813b-8a68e674325b"
     }
 }
 

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	SavepointHandlers.SavepointStatusHandler HTTP handler to query for the status of the savepoint.
class	SavepointHandlers.SavepointTriggerHandler HTTP handler to trigger savepoints.
class	SavepointHandlers.StopWithSavepointHandler HTTP handler to stop a job with a savepoint.

Nested classes/interfaces inherited from class org.apache.flink.runtime.rest.handler.async.AbstractAsynchronousOperationHandlers

AbstractAsynchronousOperationHandlers.StatusHandler<T extends RestfulGateway,V,M extends MessageParameters>, AbstractAsynchronousOperationHandlers.TriggerHandler<T extends RestfulGateway,B extends RequestBody,M extends MessageParameters>

Constructor Summary

Constructors

Constructor and Description
SavepointHandlers(String defaultSavepointDir)

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SavepointHandlers

public SavepointHandlers(@Nullable
                         String defaultSavepointDir)