KAFKA-702 Deadlock between request handler/processor threads; reviewed by Neha Narkhede, Jun Rao
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/da7f1467 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/da7f1467 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/da7f1467 Branch: refs/heads/trunk Commit: da7f14676e677bb6b4fc1ea75fe9792709954591 Parents: 777f662 Author: Edward Jay Kreps <jkr...@apache.org> Authored: Wed Jan 16 10:00:22 2013 -0800 Committer: Neha Narkhede <neha.narkh...@gmail.com> Committed: Wed Jan 16 10:00:31 2013 -0800 ---------------------------------------------------------------------- .../main/scala/kafka/network/RequestChannel.scala | 2 +- 1 files changed, 1 insertions(+), 1 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/da7f1467/core/src/main/scala/kafka/network/RequestChannel.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/kafka/network/RequestChannel.scala b/core/src/main/scala/kafka/network/RequestChannel.scala index 0e5b7cb..848c877 100644 --- a/core/src/main/scala/kafka/network/RequestChannel.scala +++ b/core/src/main/scala/kafka/network/RequestChannel.scala @@ -98,7 +98,7 @@ class RequestChannel(val numProcessors: Int, val queueSize: Int) extends KafkaMe private val requestQueue = new ArrayBlockingQueue[RequestChannel.Request](queueSize) private val responseQueues = new Array[BlockingQueue[RequestChannel.Response]](numProcessors) for(i <- 0 until numProcessors) - responseQueues(i) = new ArrayBlockingQueue[RequestChannel.Response](queueSize) + responseQueues(i) = new LinkedBlockingQueue[RequestChannel.Response]() newGauge( "RequestQueueSize",
