kafka-commits mailing list archives

Repository: kafka
Updated Branches:
  refs/heads/0.8.2 f43358197 -> 5fcc3747f


kafka-1468; (followup) add back inadventently removed commit; patched by Guozhang Wang; reviewed
by Jun Rao


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/5fcc3747
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/5fcc3747
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/5fcc3747

Branch: refs/heads/0.8.2
Commit: 5fcc3747faae69353f045ad7e3a88e13737145d3
Parents: f433581
Author: Guozhang Wang <guwang@linkedin.com>
Authored: Mon Oct 6 17:24:21 2014 -0700
Committer: Jun Rao <junrao@gmail.com>
Committed: Mon Oct 6 17:24:21 2014 -0700

----------------------------------------------------------------------
 core/src/main/scala/kafka/server/RequestPurgatory.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/5fcc3747/core/src/main/scala/kafka/server/RequestPurgatory.scala
----------------------------------------------------------------------
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()