Hi,
I developed a Flink application that read data from files and inserts them into the database. During the job running, I attempted to get a savepoint and cancel the job but I got the following error:
Caused by: java.util.concurrent.CompletionException: org.apache.flink.runtime.checkpoint.Checkpo
intTriggerException: Failed to trigger savepoint. Decline reason: Not all required tasks are cur
rently running.
at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:593)
at java.util.concurrent.CompletableFuture.uniApplyStage(CompletableFuture.java:614)
at java.util.concurrent.CompletableFuture.thenApply(CompletableFuture.java:1983)
at org.apache.flink.runtime.jobmaster.JobMaster.triggerSavepoint(JobMaster.java:966)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:
247)
at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:162
)
... 15 more
Caused by: org.apache.flink.runtime.checkpoint.CheckpointTriggerException: Failed to trigger sav
epoint. Decline reason: Not all required tasks are currently running.
at org.apache.flink.runtime.checkpoint.CheckpointCoordinator.triggerSavepoint(Checkpoint
Coordinator.java:379)
The Flink version is 1.7.2 and I use Java Oracle 1.8.0_91-b14
Any idea?
Best regards,
Soheil
Locked
