Hao Chen
Hao Chen
Yes, it supports state management. What's the error by your side? The recovering error is caused from flink side or siddhi internal?
@aagupta1 Could you please share the test code?
We use flink-siddhi at @eBay for monitoring/anomaly detection.
@eBay is building an Unified Streaming Platform based on `flink` + `flink-siddhi` to support both _DAG Pipeline SQL_ (Flink SQL) and _Dynamic Embed SQL_ (Siddhi CEP) being used in Payment...
@wujinhu keep our discussion here.
Have a try with `0.1.3`: https://clojars.org/com.github.haoch/flink-siddhi_2.11/versions/0.1.3-SNAPSHOT? For supporting Flink 1.7, it's because API in Flink changes a lot since previous version. Lots of use cases are using the latest Flink...
What's the purpose fo `QueryCallback`? As `Stream` concept is used to bind with Flink DataStream, how should we use QueryCallback in flink?
It makes sense then. The feature sounds good. We may expect a new method: `DataStream retainQuery(queryName)` on `SiddhiStream`
Thanks @aagupta1 👍
How about the progress @aagupta1 ?