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
