Fix watermark processing for count measure

TU-Berlin-DIMA / scotty-window-processor

This repository provides Scotty, a framework for efficient window aggregations for out-of-order Stream Processing.

Apache License 2.0

75 stars 23 forks source link

Closed julianev closed 3 years ago

julianev commented 3 years ago

Two fixes in WindowManager to ensure the correct processing of watermarks for windows with count measure.

avoid requesting slices from the AggregationStore with index -1 in assignContextFreeWindows
correct update of lastCount