Github user dianfu commented on the issue:
https://github.com/apache/flink/pull/5063
{{AbstractKeyedCEPPatternOperator}} has similar logic as
{{RowTimeUnboundedOver}}. As described in FLINK-8106, we find that the
performance is very bad under the current logic for
{{AbstractKeyedCEPPatternOperator}}. The throughput can increase from 10+ tps
to about 3500 tps for one operator in the case of RocksDBStateBackend after
optimizing the timer logic. I think the optimization should also apply to
{{RowTimeUnboundedOver}}.
BTW: the watermark we use in the CEP use case is
{{AssignerWithPunctuatedWatermarks}}. It will generate one watermark for every
input element.
---
