Hi,
I had a few questions. How can I join the slack users group for siddhi?
I don't think the dialog box to get an invite on
https://siddhi.io/community/ is still working.
Also, I am trying to detect missing events from an event stream using siddhi. My query looks like:
from not inputStream[objid == '${objid1}']
for 20 sec
select '${objid1}' as objid, '${gapRuleId1}' as ruleId, 'Gap Detected' as alert, '20sec time gap' as timeGap
insert into GapCaseOutputStream;
from every f1 = inputStream[objid == '${objid1}'] -> not flattenedStream[f1.objid == objid] for 20 sec
select '${objid1}' as objid, '${gapRuleId1}' as ruleId,
'Gap Detected' as alert, '20sec time gap' as timeGap
insert into GapCaseOutputStream;
I am sending multiple of these rules each with a different objid. I have noticed that the output is not always consistent.
I have seen the following cases happen:
1. Get correct alerts for all the necessary objids.
2. Skips the alerts for few objids
3. Skips the alerts completely
4. Alerts for the same objid more than once and skips the others
Could you please help me understand how can this be solved? Is the shared state in Siddhi Context somehow triggering this behavior? I also noticed this behavior while debugging using Siddhi Editor.
Would appreciate your help on this.