kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject svn commit: r1244765 - /incubator/kafka/trunk/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala
Date Wed, 15 Feb 2012 22:22:11 GMT
Author: junrao
Date: Wed Feb 15 22:22:11 2012
New Revision: 1244765

URL: http://svn.apache.org/viewvc?rev=1244765&view=rev
Log:
fix condition to use await instead of wait; patched by Jun Rao; reviewed by Neha Narkhede;
KAFKA-265

Modified:
    incubator/kafka/trunk/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala

Modified: incubator/kafka/trunk/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala?rev=1244765&r1=1244764&r2=1244765&view=diff
==============================================================================
--- incubator/kafka/trunk/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala
(original)
+++ incubator/kafka/trunk/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala
Wed Feb 15 22:22:11 2012
@@ -384,7 +384,7 @@ private[kafka] class ZookeeperConsumerCo
             lock.lock()
             try {
               if (!isWatcherTriggered)
-                cond.wait()
+                cond.await()
             } finally {
               isWatcherTriggered = false
               lock.unlock()



Mime
View raw message