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

Reply via email to