You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/11/07 01:28:01 UTC
[jira] [Created] (KAFKA-6179) RecordQueue.clear() does not clear
MinTimestampTracker's maintained list
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)