Hello, I have this Exception in my datastream app and I can't find the root cause. I consume data from Kafka and it fails when I try to get a value from my MapState in RocksDB. It was working in previous release of my app but I can't find the cause of this error.
java.lang.ArrayIndexOutOfBoundsException: 512 at org.apache.flink.api.common.typeutils.base.EnumSerializer.deserialize(EnumSerializer.java:130) at org.apache.flink.api.common.typeutils.base.EnumSerializer.deserialize(EnumSerializer.java:50) at org.apache.flink.api.java.typeutils.runtime.TupleSerializer.deserialize(TupleSerializer.java:143) at org.apache.flink.api.java.typeutils.runtime.TupleSerializer.deserialize(TupleSerializer.java:37) at org.apache.flink.contrib.streaming.state.RocksDBMapState.deserializeUserValue(RocksDBMapState.java:344) at org.apache.flink.contrib.streaming.state.RocksDBMapState.get(RocksDBMapState.java:123) at org.apache.flink.runtime.state.UserFacingMapState.get(UserFacingMapState.java:47) .. Flink version: 1.9.2