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 <parbhane....@gmail.com> 于2024年3月27日周三 14:20写道： > > 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, Yanfei
