'Improve performance of flink siddhi for pattern queries
I have siddhi query like:
from every e1=tempStream[ ( (e1.id == 'id1') AND (e1.data == 'data') ) ]<1> -> e2=tempStream[ ( (e2.id == 'id1') AND (e2.data == 'data') ) ]<4>\nwithin 5 minutes\nselect 'id1' as Id insert into outputStream;
where tempStream is stream having nearly 350 fields. I am facing performance issues when i send millions of records [i.e event consumption speed is near to 5k events per second]. Does siddhi query with 'every' works slowly? Or is it because i have 350 fields in tempStream? How can i increase event consumption rate?
Sources
This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.
Source: Stack Overflow
| Solution | Source |
|---|