kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject git commit: kafka-1468; (followup) add back inadventently removed commit; patched by Guozhang Wang; reviewed by Jun Rao
Date Tue, 07 Oct 2014 00:23:09 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 88595bfb5 -> 1a6c9207c


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/1a6c9207
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/1a6c9207
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/1a6c9207

Branch: refs/heads/trunk
Commit: 1a6c9207c7c19f04b91b455e86bbf4e779e7e7a2
Parents: 88595bf
Author: Guozhang Wang <guwang@linkedin.com>
Authored: Mon Oct 6 17:21:30 2014 -0700
Committer: Jun Rao <junrao@gmail.com>
Committed: Mon Oct 6 17:22:29 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/1a6c9207/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()


Mime
View raw message