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.
