Hi Andrey,
Thank you for the explanation. I think you are right. It is either
kStaleFile or kNoSpace. We found the cause of the issue, even though we
still don't know how to explain it.
We set the java.io.tmpdir to an EBS-backed drive instead of the
default and the exception started happening. Th
Hi Ning,
The problem here first of all is that RocksDB java JNI client diverged from
RocksDB cpp code in status.h,
as mentioned in the Flink issue you refer to.
Flink 1.6 uses RocksDB 5.7.5 java client.
The JNI code there misses these status subcodes:
kNoSpace = 4,
kDeadlock = 5,
kStaleFile = 6
Hi,
We are doing some performance testing on a 12 node cluster with 8 task
slots per TM. Every 15 minutes or so, the job would run into the
following exception.
java.lang.IllegalArgumentException: Illegal value provided for SubCode.
at org.rocksdb.Status$SubCode.getSubCode(Status.java:109