Hi I think you have missed the "caused by" exception [1] , which could tell us the truth. Could you please check the full stack trace?
[1] https://github.com/apache/flink/blob/6846522ed67343c665f7e1dd02b7c06c05c1eb1d/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBListState.java#L151 Best Yun Tang ________________________________ From: anaray <anum...@gmail.com> Sent: Friday, April 10, 2020 1:25 To: user@flink.apache.org <user@flink.apache.org> Subject: FlinkRuntimeException: Unexpected list element deserialization failure Hi flink team, I see below exception . What could be the reason of the failure ? Please share your thoughts? Caused by: org.apache.flink.util.FlinkRuntimeException: Unexpected list element deserialization failure at org.apache.flink.contrib.streaming.state.RocksDBListState.deserializeNextElement(RocksDBListState.java:153) at org.apache.flink.contrib.streaming.state.RocksDBListState.deserializeList(RocksDBListState.java:137) at org.apache.flink.contrib.streaming.state.RocksDBListState.getInternal(RocksDBListState.java:121) at org.apache.flink.contrib.streaming.state.RocksDBListState.get(RocksDBListState.java:112) at org.apache.flink.contrib.streaming.state.RocksDBListState.get(RocksDBListState.java:61) at org.apache.flink.streaming.runtime.operators.windowing.WindowOperator.onEventTime(WindowOperator.java:452) at org.apache.flink.streaming.api.operators.InternalTimerServiceImpl.advanceWatermark(InternalTimerServiceImpl.java:251) at org.apache.flink.streaming.api.operators.InternalTimeServiceManager.advanceWatermark(InternalTimeServiceManager.java:128) at org.apache.flink.streaming.api.operators.AbstractStreamOperator.processWatermark(AbstractStreamOperator.java:775) at org.apache.flink.streaming.runtime.io.StreamInputProcessor$ForwardingValveOutputHandler.handleWatermark(StreamInputProcessor.java:262) ... 7 more Thanks -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
