flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Yun Tang <myas...@live.com>
Subject Re: the savepoint problem of upgrading job from blink-1.5 to flink-1.10
Date Fri, 15 May 2020 10:01:24 GMT
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 <qcx978132955@gmail.com>
Sent: Friday, May 15, 2020 17:20
To: Roc Marshal <flinker@126.com>
Cc: user <user@flink.apache.org>
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 <flinker@126.com<mailto:flinker@126.com>> 于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





Mime
View raw message