Hi, I want to cancel a running job from a Java program. However, I don't know how to do it. The Client class (org.apache.flink.client.program.Client) that is used to submit a job, does not provide a method for it (a "Client.cancel(JobId)" would be nice).
There is also the Scala JobClient classm that seems to have the capability to forward a "cancelJob" message to the JobManager. However, there is no method to call, either. I guess, the simplest way would be to add a new method here to the JobClient-object defined there. However, I don't speak Scala... Any suggestions? -Matthias
signature.asc
Description: OpenPGP digital signature
