search

haoch / flink-siddhi

A CEP library to run Siddhi within Apache Flink™ Streaming Application (Not maintained)
Apache License 2.0
243 stars 96 forks source link

Adding logic for restoring the rules states after job failure #65

Open pranjal0811 opened 4 years ago

pranjal0811 commented 4 years ago

https://github.com/haoch/flink-siddhi/blob/cf4b2b6935bc69be1b465e49431bb8485e4d670b/core/src/main/java/org/apache/flink/streaming/siddhi/operator/AbstractSiddhiOperator.java#L341

https://github.com/haoch/flink-siddhi/blob/cf4b2b6935bc69be1b465e49431bb8485e4d670b/core/src/main/java/org/apache/flink/streaming/siddhi/router/AddRouteOperator.java#L68

Moving AddRouteOperator members in flink state for restoring after failure.