State cleaning in general streaming over window executor #13907
Labels
A-watermark
A-window-func
Area: Window function, OverWindow.
no-issue-activity
type/perf
Type: Performance.
Currently watermark messages are not handled by general version of streaming OverWindowExecutor. It's reported that the state of OverWindow eventually becoming too large. We may need to add state cleaning by watermark for it. Unlike interval join that knows every rows to cleanup, OverWindow only caches a range of rows in cache, so it may only be able to clean state in the same way HashAgg does, which means it can only clean state with watermarks on
PARTITION BY
columns.OTOH for EOWC version, state cleaning is implemented by design.
The text was updated successfully, but these errors were encountered: