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()
|