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