You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Alexander Smirnov <al...@gmail.com> on 2018/08/17 12:13:10 UTC

High CPU usage

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