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 <master...@gmail.com> wrote: > 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 <parbhane....@gmail.com> > wrote: > >> 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$RocksDBMapEntry.getKey(RocksDBMapState.java:495)* >> >> *Caused by: java.io.EOFException* >> >> * at >> org.apache.flink.core.memory.DataInputDeserializer.readUnsignedByte(DataInputDeserializer.java:329)* >> >> * at >> org.apache.flink.types.StringValue.readString(StringValue.java:781)* >> >> * at >> org.apache.flink.api.common.typeutils.base.StringSerializer.deserialize(StringSerializer.java:73)* >> >> * at >> org.apache.flink.api.common.typeutils.base.StringSerializer.deserialize(StringSerializer.java:31)* >> >> * at >> org.apache.flink.contrib.streaming.state.RocksDBMapState.deserializeUserKey(RocksDBMapState.java:389)* >> >> * at >> org.apache.flink.contrib.streaming.state.RocksDBMapState.access$000(RocksDBMapState.java:65)* >> >> * at >> org.apache.flink.contrib.streaming.state.RocksDBMapState$RocksDBMapEntry.getKey(RocksDBMapState.java:492* >> " >> >> >> Any suggestions? >> >> Thanks, >> Prashant >> >> >> >> >> > > -- > Best, > Hangxiang. >
