Thanks for the tip Stefan, you are probably right that this might be
related to a custom change.
We have a change that deletes every state that hasn't been registered in
the open method and maybe it accidentally delates the timer service as
well, need to check.
Thanks!
Gyula
On Tue, Jan 15, 2019
Hi,
I have never seen this before. I would assume to see this exception because the
write batch is flushed and contained a write against a column family that does
not exist (anymore). However, we initialize everything relevant in
RocksDBCachingPriorityQueueSet as final (CF handle) and never dro
Hi!
Lately I seem to be hitting a bug in the rocksdb timer service. This
happens mostly at checkpoints but sometimes even at watermark:
java.lang.RuntimeException: Exception occurred while processing valve
output watermark:
at
org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor
