Description
When flushing the CachingSessionStore we need to search for the previous value for a session. This involves searching each open RocksDB segment. The code ends up doing a call Segments.segments(0, Long.MAX_VALUE) this results in approximately 3 million gets on a ConcurrentHashMap of which all but 3 of them will be hits.
Change this code to restrict the segmentIds to search just to the available set.
Attachments
Issue Links
- duplicates
-
KAFKA-4876 WindowStore.fetch(key, 0, Long.MaxValue) is very slow
-
- Resolved
-
- links to
