pyflink.common.job_client.JobClient.cancel

JobClient.cancel() → CompletableFuture

Cancels the associated job.

Returns:

A CompletableFuture for canceling the associated job.

Added in version 1.11.0.