Myasuka commented on pull request #16835:
URL: https://github.com/apache/flink/pull/16835#issuecomment-900047864
The test failed due to fail to insert block cache, it seems RocksDB will
throw exception directly if no more spaces in block cache. I'll check what to
do to avoid this.
```
2021-08-16 07:18:45,145 WARN org.apache.flink.runtime.taskmanager.Task
[] - ValueStateMapper (2/2)#0 (f3c4c9f3b6ff23a52ac2d2c0fbf66b96)
switched from RUNNING to FAILED with failure cause:
org.apache.flink.util.FlinkRuntimeException: Error while retrieving data from
RocksDB.
at
org.apache.flink.contrib.streaming.state.RocksDBValueState.value(RocksDBValueState.java:91)
at
org.apache.flink.streaming.tests.RocksDBStateMemoryControlTestProgram$ValueStateMapper.map(RocksDBStateMemoryControlTestProgram.java:130)
at
org.apache.flink.streaming.tests.RocksDBStateMemoryControlTestProgram$ValueStateMapper.map(RocksDBStateMemoryControlTestProgram.java:103)
at
org.apache.flink.streaming.api.operators.StreamMap.processElement(StreamMap.java:38)
at
org.apache.flink.streaming.runtime.tasks.OneInputStreamTask$StreamTaskNetworkOutput.emitRecord(OneInputStreamTask.java:230)
at
org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.processElement(AbstractStreamTaskNetworkInput.java:134)
at
org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.emitNext(AbstractStreamTaskNetworkInput.java:105)
at
org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:487)
at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:203)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:817)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.executeInvoke(StreamTask.java:744)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.runWithCleanUpOnFail(StreamTask.java:783)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:726)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:786)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:572)
at java.lang.Thread.run(Thread.java:748)
Caused by: org.rocksdb.RocksDBException: Insert failed due to LRU cache
being full.
at org.rocksdb.RocksDB.get(Native Method)
at org.rocksdb.RocksDB.get(RocksDB.java:2084)
at
org.apache.flink.contrib.streaming.state.RocksDBValueState.value(RocksDBValueState.java:83)
... 16 more
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
