Hi As Yun said, could you please share the whole stack trace(normally, you can copy more lines below the given stack trace), can not tell why this happened from the given stack trace.
Best, Congxian Yun Tang <[email protected]> 于2020年4月10日周五 上午1:48写道： > 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 <[email protected]> > *Sent:* Friday, April 10, 2020 1:25 > *To:* [email protected] <[email protected]> > *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/ >
