Hi Mahesh,
You are right that it based on the Pattern you write there might be a big
amount of intermittent states created. Flink CEP library keeps all its State in
State Backend. So if you use e.g. RocksDBStateBackend it will be backed by
disc. Nevertheless it is vital to allow clearing the s
Hello,
Can anyone shed some light on the intermittent state store mechanism used
by Flink CEP ?
Based on the kind of pattern, the state-store may be overwhelmed with
intermittent states. How does Flink CEP manage this ? Does it use a
persistent store, or just an in-memory store with a cap on the n
