pyflink.common.job_client.JobClient.trigger_savepoint

JobClient.trigger_savepoint(savepoint_directory: Optional[str] = None) → pyflink.common.completable_future.CompletableFuture

Triggers a savepoint for the associated job. The savepoint will be written to the given savepoint directory.

Parameters

savepoint_directory – Directory the savepoint should be written to.

Returns

A CompletableFuture containing the path where the savepoint is located.

New in version 1.11.0.