[KAFKA-6826] Avoid range scans when forwarding values in window store aggregations - ASF JIRA

Attach files

Attach Screenshot

Voters

Watch issue

Watchers

Create sub-task

Link

Clone

Update Comment Author

Replace String in Comment

Update Comment Visibility

Delete Comments

XML

Word

Printable

JSON

Details

Type: Bug
Status: Resolved
Priority: Critical
Resolution: Fixed
Affects Version/s: None
Fix Version/s: 2.0.0
Component/s: streams
Labels:
None

Description

This is a follow-up to ~~KAFKA-6560~~, where we missed at least one case that should be using single point queries instead of range-scans when forwarding values during aggregation.

Since a single range scan can sometimes account for 75% of aggregation cpu time, fixing this should provide some significant speedups (see attached flamegraph)