This email wants to correct my previous mail, Yun's answer is correct. I mistook "blink-1.5" for "flink-1.5" when replying to the previous email. and the savepoint V3 is not in flink-1.10(will be in 1.11)
Best, Congxian Yun Tang <[email protected]> 于2020年5月15日周五 下午6:01写道： > Hi Roc > > Blink-1.5 should never make the promise that it could be compatible with > Flink-1.10. > Moreover, the SavepointV3Serializer in Blink is totally no the same thing > as Flink, and the reason why we introduce SavepointV3Serializer is because > we use different state handle when we open source blink. As you can see, we > use "org.apache.flink.runtime.state.KeyGroupsStateSnapshot" instead of " > org.apache.flink.runtime.state.KeyGroupsStateHandle", and thus the > savepoint generated by Blink cannot be easily consumed by Flink. > > Best > Yun Tang > > ------------------------------ > *From:* Congxian Qiu <[email protected]> > *Sent:* Friday, May 15, 2020 17:20 > *To:* Roc Marshal <[email protected]> > *Cc:* user <[email protected]> > *Subject:* Re: the savepoint problem of upgrading job from blink-1.5 to > flink-1.10 > > Hi, > Could you please share the stack or the log message? > If I understand correctly, savepoint V3 is not contained in 1.10, > > Best, > Congxian > > > Roc Marshal <[email protected]> 于2020年5月15日周五 下午4:33写道： > > Hi, all. > > When using savepoint to upgrade a Flink job from blink-1.5 to flink-1.10, > the system prompts that blink savepointV3 is incompatible with the version > in Flink. Is there any solution? > > Thank you so much. > > > > > > > > > Sincerely, > Roc Marshal > > > > >
