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

Pattern with group by query bug #43

Open pranjal0811 opened 5 years ago

pranjal0811 commented 5 years ago

I have the query like this - "from every e1=firewallStream[name == 'A']<3> -> e2=firewallStream [ name == 'B' ] within 40 seconds select 'AAAA' as ruleId group by e1[0].signatureId insert into outputstream"

when I execute it I got the error - e1 does not exist. The same query works well with the siddhi simulator.

here - https://github.com/siddhi-io/siddhi/blob/0c6b8b514e4f163c41fe8872f97040e923d0433f/modules/siddhi-query-api/src/test/java/io/siddhi/query/api/PatternQueryTestCase.java

haoch commented 4 years ago

Could you please share some error details?

GithubZhitao commented 2 years ago

bug ?