Trivial Description
-When adding elements MinTimestampTracker removes all existing elements greater than the added element.-
-Perhaps I've missed something and this is intended behaviour but I can't find any evidence for that in comments or tests.-
MinTimestampTracker maintains a list of elements ascending by timestamp, but calls the list var descendingSubsequence – it also get the largest element at the end and stores it in a var called minElem.
Attachments
Issue Links
- relates to
-
KAFKA-3514 Stream timestamp computation needs some further thoughts
-
- Resolved
-
- links to
