You are correct. Thanks! I misused the job ID. Sorry for bothering you guys.
Best regards, Chang from iPhone > On 4 Sep 2018, at 18:06, Chesnay Schepler <ches...@apache.org> wrote: > > Please check that the job ID is correct. > >> On 04.09.2018 15:48, Chang Liu wrote: >> Dear All, >> >> I had the following issue when trying to cancel a job from CLI. I am >> wondering am I in the proper way of canceling a job? Or, there is more >> elegant way to do this, both in code or in CLI? Many Thanks! >> >> BTW, I am have streaming coming from Kafka and producing to another Kafka >> topic. >> >> ./bin/flink cancel b89f45024cf2e45914eaa920df95907f >> Cancelling job b89f45024cf2e45914eaa920df95907f. >> >> ------------------------------------------------------------ >> The program finished with the following exception: >> >> org.apache.flink.util.FlinkException: Could not cancel job >> b89f45024cf2e45914eaa920df95907f. >> at >> org.apache.flink.client.cli.CliFrontend.lambda$cancel$5(CliFrontend.java:603) >> at >> org.apache.flink.client.cli.CliFrontend.runClusterAction(CliFrontend.java:955) >> at >> org.apache.flink.client.cli.CliFrontend.cancel(CliFrontend.java:596) >> at >> org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:1029) >> at >> org.apache.flink.client.cli.CliFrontend.lambda$main$9(CliFrontend.java:1096) >> at >> org.apache.flink.runtime.security.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:30) >> at >> org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1096) >> Caused by: java.util.concurrent.ExecutionException: >> org.apache.flink.runtime.concurrent.FutureUtils$RetryException: Could not >> complete the operation. Exception is not retryable. >> at >> java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357) >> at >> java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1915) >> at >> org.apache.flink.client.program.rest.RestClusterClient.cancel(RestClusterClient.java:380) >> at >> org.apache.flink.client.cli.CliFrontend.lambda$cancel$5(CliFrontend.java:601) >> ... 6 more >> Caused by: org.apache.flink.runtime.concurrent.FutureUtils$RetryException: >> Could not complete the operation. Exception is not retryable. >> at >> org.apache.flink.runtime.concurrent.FutureUtils.lambda$retryOperationWithDelay$5(FutureUtils.java:214) >> at >> java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760) >> at >> java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736) >> at >> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474) >> at >> java.util.concurrent.CompletableFuture.postFire(CompletableFuture.java:561) >> at >> java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:929) >> at >> java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:442) >> at >> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) >> at >> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) >> at java.lang.Thread.run(Thread.java:748) >> Caused by: java.util.concurrent.CompletionException: >> org.apache.flink.runtime.rest.util.RestClientException: [Job could not be >> found.] >> at >> java.util.concurrent.CompletableFuture.encodeRelay(CompletableFuture.java:326) >> at >> java.util.concurrent.CompletableFuture.completeRelay(CompletableFuture.java:338) >> at >> java.util.concurrent.CompletableFuture.uniRelay(CompletableFuture.java:911) >> at >> java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:953) >> at >> java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:926) >> ... 4 more >> Caused by: org.apache.flink.runtime.rest.util.RestClientException: [Job >> could not be found.] >> at >> org.apache.flink.runtime.rest.RestClient.parseResponse(RestClient.java:225) >> at >> org.apache.flink.runtime.rest.RestClient.lambda$submitRequest$3(RestClient.java:209) >> at >> java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:952) >> ... 5 more >> >> >> Best regards/祝好, >> >> Chang Liu 刘畅 >> >
