Hi, I think you can check the client side and JobManager side log to get more info.
Best, Ron Dennis Jung <inylov...@gmail.com> 于2023年8月18日周五 10:41写道： > Hello people, > > I'm facing failure when I try to stop running Flink job with REST API > 'jobs/:jobid/stop' > > ``` > ... > java.util.concurrent.CompletionException: > org.apache.flink.runtime.checkpoint.CheckpointException: Task has failed. > java.base/java.util.concurrent.CompletableFuture.encodeRelay(Unknown > Source) > ... > ... > > java.base/java.util.concurrent.CompletableFuture.completeExceptionally(Unknown > Source) > > org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1298) > > > org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$null$1(ClassLoadingUtils.java:93) > > > org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) > > > org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92) > java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(Unknown > Source) > > java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(Unknown > Source) > ... > ... > java.base/java.util.concurrent.ForkJoinWorkerThread.run(Unknown > Source)\nCaused by: > org.apache.flink.runtime.checkpoint.CheckpointException: Task has failed. > > > org.apache.flink.runtime.checkpoint.PendingCheckpoint.abort(PendingCheckpoint.java:545) > > > org.apache.flink.runtime.checkpoint.CheckpointCoordinator.abortPendingCheckpoint(CheckpointCoordinator.java:2147) > > > org.apache.flink.runtime.checkpoint.CheckpointCoordinator.receiveDeclineMessage(CheckpointCoordinator.java:1106) > > > org.apache.flink.runtime.scheduler.ExecutionGraphHandler.lambda$declineCheckpoint$2(ExecutionGraphHandler.java:103) > > > org.apache.flink.runtime.scheduler.ExecutionGraphHandler.lambda$processCheckpointCoordinatorMessage$3(ExecutionGraphHandler.java:119) > java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown > Source) > java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown > Source) > java.base/java.lang.Thread.run(Unknown Source)\nCaused by: > org.apache.flink.runtime.checkpoint.CheckpointException: > org.apache.flink.runtime.checkpoint.CheckpointException: Task name with > subtask : Source: kafka-source (1/2)#0 Failure reason: Task has failed. > > org.apache.flink.runtime.taskmanager.Task.declineCheckpoint(Task.java:1395) > > > org.apache.flink.runtime.taskmanager.Task.lambda$triggerCheckpointBarrier$3(Task.java:1338) > ... > ``` > > Was there some similar issue? > > Regards > > >
