From 1be37ec9537f65b00c068c7ea7df6c6e9d81277f Mon Sep 17 00:00:00 2001 From: Guozhang Wang Date: Mon, 6 Oct 2014 16:30:44 -0700 Subject: [PATCH] follow-up KAFKA-1468 --- core/src/main/scala/kafka/server/RequestPurgatory.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/kafka/server/RequestPurgatory.scala b/core/src/main/scala/kafka/server/RequestPurgatory.scala index cf3ed4c..9d76234 100644 --- a/core/src/main/scala/kafka/server/RequestPurgatory.scala +++ b/core/src/main/scala/kafka/server/RequestPurgatory.scala @@ -166,7 +166,7 @@ abstract class RequestPurgatory[T <: DelayedRequest](brokerId: Int = 0, purgeInt * bookkeeping logic. */ private class Watchers { - private val requests = new util.ArrayList[T] + private val requests = new util.LinkedList[T] // return the size of the watch list def watched() = requests.size() -- 1.7.12.4