Hello,
I noticed CPU utilization went high and took a thread dump on the task manager node. Why would RocksDBMapState.entries() / seek0 call consumes CPU?
It is Flink 1.4.2
"Co-Flat Map (3/4)" #16129 prio=5 os_prio=0 tid=0x00007fefac029000 nid=0x338f runnable [0x00007feed2002000]
java.lang.Thread.State: RUNNABLE
at org.rocksdb.RocksIterator.seek0(Native Method)
at org.rocksdb.AbstractRocksIterator.seek(AbstractRocksIterator.java:58)
at org.apache.flink.contrib.streaming.state.RocksDBMapState$RocksDBMapIterator.loadCache(RocksDBMapState.java:489)
at org.apache.flink.contrib.streaming.state.RocksDBMapState$RocksDBMapIterator.hasNext(RocksDBMapState.java:433)
at org.apache.flink.contrib.streaming.state.RocksDBMapState.entries(RocksDBMapState.java:147)
at org.apache.flink.runtime.state.UserFacingMapState.entries(UserFacingMapState.java:77)
Thank you,
Alex