Hello everyone,
I am using Flink 1.13.1 CEP Library and doing some pressure test.
My message rate is about 16000 records per second.
I find that it cant process more than 16000 records per second because the CPU 
cost is up to 100%(say 800% because I allocated 8 vcores to a taskmanager).
I tried switch to filesystem mode, it gtt faster and cpu cost goes low.
I understand this may because of serialization/deserialization cost in rocksdb, 
but in some reason we must use rocksdb as state backend.
Any suggestion to optimize this issue?




Reply via email to