Guozhang Wang created KAFKA-6179:
------------------------------------
Summary: RecordQueue.clear() does not clear MinTimestampTracker's
maintained list
Key: KAFKA-6179
URL: https://issues.apache.org/jira/browse/KAFKA-6179
Project: Kafka
Issue Type: Bug
Components: streams
Affects Versions: 1.0.0, 0.10.2.1, 0.11.0.1
Reporter: Guozhang Wang
Assignee: Guozhang Wang
When a stream task is being suspended, in {{RecordQueue.clear()}} we will clear
the {{ArrayDeque fifoQueue}}, but we do not clear the {{MinTimestampTracker}}'s
maintained list. As a result if the task gets resumed we will live with an
empty {{fifoQueue}} while a populated {{tracker}}. And hence we use reference
equality to check if the smallest timestamp record can be popped, we would
never be able to pop any more records and hence effectively leading to memory
leak.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
