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