Re: standalone flink savepoint restoration

2019-10-17 Thread Congxian Qiu
ime/scheduler/LegacyScheduler.java#L190 > > Best > Yun Tang > -- > *From:* Matt Anger > *Sent:* Thursday, October 17, 2019 5:46 > *To:* user@flink.apache.org > *Subject:* standalone flink savepoint restoration > > Hello everyone, > I am run

Re: standalone flink savepoint restoration

2019-10-16 Thread Yun Tang
/runtime/scheduler/LegacyScheduler.java#L190 Best Yun Tang From: Matt Anger Sent: Thursday, October 17, 2019 5:46 To: user@flink.apache.org Subject: standalone flink savepoint restoration Hello everyone, I am running a flink job in k8s as a standalone HA job. Now I

standalone flink savepoint restoration

2019-10-16 Thread Matt Anger
Hello everyone, I am running a flink job in k8s as a standalone HA job. Now I updated my job w/ some additional sinks, which I guess have made the checkpoints incompatible with the newer version, meaning flink now crashes on bootup with the following: Caused by: java.lang.IllegalStateException: