Flowmix is a flexible event processing engine for Apache Storm. It supports complex correlations of events via sliding/tumbling windows. It allows parallel streams to be processed that can be grouped together in different ways.
Apache License 2.0
55
stars
20
forks
source link
Aggregator window's window eviction fires unexpectedly because the window is only ever written to the cache once. #22
Fix is to add the window to the cache after every event encountered.