pyflink.common.job_client.JobClient.cancel

JobClient.cancel() → CompletableFuture

Cancels the associated job.

Returns

A CompletableFuture for canceling the associated job.

New in version 1.11.0.