flink-siddhi icon indicating copy to clipboard operation
flink-siddhi copied to clipboard

Published 20 hours ago • verified publisher icon haoch

Adding logic for restoring the rules states after job failure

Open pranjal0811 opened this issue 4 years ago • 0 comments

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.

pranjal0811 avatar Apr 29 '20 10:04 pranjal0811