Hi Till,
Thanks so that means it should work will try and see ..
RegardsDipanjan
On Tuesday, June 1, 2021, 01:48:19 PM GMT+5:30, Till Rohrmann
wrote:
Hi Dipanjan,
I am assuming that you are using the flink-siddhi library [1]. I am not an
expert but it looks as if the
Hi Dipanjan,
I am assuming that you are using the flink-siddhi library [1]. I am not an
expert but it looks as if the AbstractSiddhiOperator overrides the
snapshotState [2] method to store the Siddhi state in Flink.
[1] https://github.com/haoch/flink-siddhi
[2]
Hi ,
I was trying to do checkpointing while using siddhi as the CEP engine
running on flink. While using siddhi windowing , it uses an internal state to
aggregated or perform operation on a bucket of events pertaining to a specific
time window. But what i am not sure is how can that state be
