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
