Hi Ramya, I think this message is better suited for the user ML list. Which version of Flink are you using? Have you checked the Flink logs to see whether they contain anything suspicious?
Cheers, Till On Thu, Jan 30, 2020 at 1:09 PM Ramya Ramamurthy <hair...@gmail.com> wrote: > Hi, > > I am trying to dynamically increase the parallelism of the job. In the > process of it, while I am trying to trigger the savepoint, i get > the following error. Any help would be appreciated. > > The URL triggered is : > > http://stgflink.ssdev.in:8081/jobs/2865c1f40340bcb19a88a01d6ef8ff4f/savepoints/ > { > "target-directory" : > "gs://xxxx-bucket/flink/flink-gcs/flink-savepoints", > "cancel-job" : "false" > } > > Error as below: > > > {"status":{"id":"COMPLETED"},"operation":{"failure-cause":{"class":"java.util.concurrent.CompletionException","stack-trace":"java.util.concurrent.CompletionException: > java.util.concurrent.CompletionException: > org.apache.flink.runtime.checkpoint.CheckpointTriggerException: Failed to > trigger savepoint. Decline reason: An Exception occurred while triggering > the checkpoint.\n\tat > > org.apache.flink.runtime.jobmaster.JobMaster.lambda$triggerSavepoint$13(JobMaster.java:972)\n\tat > > java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:836)\n\tat > > java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:811)\n\tat > > java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:456)\n\tat > > org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:332)\n\tat > > org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:158)\n\tat > > org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:70)\n\tat > > org.apache.flink.runtime.rpc.akka.AkkaRpcActor.onReceive(AkkaRpcActor.java:142)\n\tat > > org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.onReceive(FencedAkkaRpcActor.java:40)\n\tat > > akka.actor.UntypedActor$$anonfun$receive$1.applyOrElse(UntypedActor.scala:165)\n\tat > akka.actor.Actor$class.aroundReceive(Actor.scala:502)\n\tat > akka.actor.UntypedActor.aroundReceive(UntypedActor.scala:95)\n\tat > akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)\n\tat > akka.actor.ActorCell.invoke(ActorCell.scala:495)\n\tat > akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)\n\tat akka.dis >
