pyflink.common.job_client.JobClient.cancel

JobClient.cancel() → pyflink.common.completable_future.CompletableFuture

Cancels the associated job.

Returns

A CompletableFuture for canceling the associated job.

New in version 1.11.0.