Re: How to use or configure flink checkpointing with siddhi internal state

2021-06-01 Thread Dipanjan Mazumder
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 AbstractSiddhi

Re: How to use or configure flink checkpointing with siddhi internal state

2021-06-01 Thread Till Rohrmann
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] https://github.com/haoch/flink-sidd