Flink Savepoint error

[Soheil Pourbafrani <so...@gmail.com>]

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

Re: Flink Savepoint error

[Tzu-Li Tai <tz...@gmail.com>]

Hi,

Could you let me know what data source / connector you are using?
My gut feeling is that perhaps some sources have already reached EOF and
terminated, which may explain the exception (which is expected behaviour).

Cheers,
Gordon



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/