FlinkRuntimeException: Unexpected list element deserialization failure

[anaray]

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/

[Yun Tang]

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 <[hidden email]>
Sent: Friday, April 10, 2020 1:25
To: [hidden email] <[hidden email]>
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/

[Congxian Qiu]

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.

Yun Tang <[hidden email]> 于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 <[hidden email]>
Sent: Friday, April 10, 2020 1:25
To: [hidden email] <[hidden email]>
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/