pyflink.common.job_client.JobClient.trigger_savepoint

JobClient.trigger_savepoint(savepoint_directory: str | None = None) → 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.

Added in version 1.11.0.