Flink job unable to restore from savepoint

2024-03-26 Thread prashant parbhane
Hello, We have been facing this weird issue of not being able to restore from savepoint, when we have a significant load on flink jobs. " *org.apache.flink.util.FlinkRuntimeException: Error while deserializing the user key.* *at org.apache.flink.contrib.streaming.state.RocksDBMapState$RocksD

Re: Flink job unable to restore from savepoint

2024-03-27 Thread Hangxiang Yu
Hi, Prashant. Which Flink version did you use? And Did you modify your job logic or configurations ? If yes, Could you share changed things ? On Wed, Mar 27, 2024 at 3:37 PM prashant parbhane wrote: > Hello, > > We have been facing this weird issue of not being able to restore from > savepoint,

Re: Flink job unable to restore from savepoint

2024-03-27 Thread Yanfei Lei
Hi Prashant, Compared to the job that generated savepoint, are there any changes in the new job? For example, data fields were added or deleted, or the type serializer was changed? More detailed job manager logs may help. prashant parbhane 于2024年3月27日周三 14:20写道: > > Hello, > > We have been facin

Re: Flink job unable to restore from savepoint

2024-03-27 Thread prashant parbhane
flink version 1.17 Didn't change any job configuration. We are facing this below issue. https://issues.apache.org/jira/browse/FLINK-23886 On Wed, Mar 27, 2024 at 1:39 AM Hangxiang Yu wrote: > Hi, Prashant. > Which Flink version did you use? > And Did you modify your job logic or configurations