From c28b98ef57fb3e54915f7418cf67751869b13a8e Mon Sep 17 00:00:00 2001 From: "Xiao, Tao" Date: Wed, 25 Mar 2015 10:19:34 +0800 Subject: [PATCH] KAFKA-2048: Fixed IllegalMonitorStateException in catch block of method processFetchRequest --- core/src/main/scala/kafka/server/AbstractFetcherThread.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/kafka/server/AbstractFetcherThread.scala b/core/src/main/scala/kafka/server/AbstractFetcherThread.scala index e731df4..5d5cf58 100644 --- a/core/src/main/scala/kafka/server/AbstractFetcherThread.scala +++ b/core/src/main/scala/kafka/server/AbstractFetcherThread.scala @@ -100,7 +100,7 @@ abstract class AbstractFetcherThread(name: String, clientId: String, sourceBroke case t: Throwable => if (isRunning.get) { warn("Error in fetch %s. Possible cause: %s".format(fetchRequest, t.toString)) - partitionMapLock synchronized { + inLock(partitionMapLock) { partitionsWithError ++= partitionMap.keys // there is an error occurred while fetching partitions, sleep a while partitionMapCond.await(fetchBackOffMs, TimeUnit.MILLISECONDS) -- 1.7.11.1