fix(functions-aggregate): drain CORR state vectors for streaming aggregation#19669

Open

geoffreyclaude wants to merge 3 commits intoapache:mainfrom

geoffreyclaude:fix/corr

Commits on Jan 6, 2026

test: demonstrate failure in CORR streaming aggregation
geoffreyclaude
committed
fix: drain CORR state vectors on EmitTo::First in streaming aggregation
geoffreyclaude
committed

Commits on Jan 7, 2026

test: add comprehensive aggregate tests for streaming aggregation
geoffreyclaude
committed