Future$PromiseCompletingRunnable.run(Future.scala:24)
>> at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:41)
>> at
>> akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:401)
>> at scala.concurrent.forkjoin.ForkJoinTask.do
new program. This indicates that the
> program has been changed in a non-compatible way after the savepoint.
> at
> org.apache.flink.runtime.checkpoint.savepoint.SavepointCoordinator.restoreSavepoint(SavepointCoordinator.java:248)
> at
> org.apache.flink.runtime.executiongr
org.apache.flink.runtime.jobmanager.JobManager$$anonfun$org$apache$flink$runtime$jobmanager$JobManager$$submitJob$1.apply$mcV$sp(JobManager.scala:1302)
... 10 more
Thanks.
From: Anirudh Mallem
Date: Tuesday, October 18, 2016 at 2:07 PM
To: "user@flink.apache.org<mailto:user@flink.apache.org>"
Subject: Issue while restartin
Hi,
I am relatively new to Flink and I was experimenting with the save points
feature. I have an HA cluster running with 1 Master and 4 Workers. The
flink-config.yaml is as follows :
#==
# Common
#===
