Re:Backpressure causing operators to stop ingestion completely

Hi,  you can use flame_graphs to debug https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/ops/debugging/flame_graphs/ -- Original -- From:

keyby mapState use question

Hi all: KeyBy process function EventKeyedBroadcastProcessFunction {         private transient mapstate = null;      public void open(Configuration parameters) throws Exception {          // initial map state     }     public void processElement() {          // can't get onTimer() function s