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 <[email protected]> Authored: Mon Oct 6 17:21:30 2014 -0700 Committer: Jun Rao <[email protected]> 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()
