[
https://issues.apache.org/jira/browse/KAFKA-1385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede resolved KAFKA-1385.
----------------------------------
Resolution: Fixed
Fixed by patch for KAFKA-1650
> mirrormaker hangs during shutdown if no topic is consumed
> ---------------------------------------------------------
>
> Key: KAFKA-1385
> URL: https://issues.apache.org/jira/browse/KAFKA-1385
> Project: Kafka
> Issue Type: Bug
> Components: core
> Affects Versions: 0.8.2
> Reporter: Jun Rao
>
> Couldn't do clean shutdown when running the following command.
> bin/kafka-run-class.sh kafka.tools.MirrorMaker --producer.config
> config/producer.properties --consumer.config config/consumer.properties
> --blacklist=".*"
> Saw the following stacktrace.
> "Thread-6" prio=5 tid=7f94120af800 nid=0x113e16000 waiting on condition
> [113e15000]
> java.lang.Thread.State: WAITING (parking)
> at sun.misc.Unsafe.park(Native Method)
> - parking to wait for <7ec0eb870> (a
> java.util.concurrent.CountDownLatch$Sync)
> at java.util.concurrent.locks.LockSupport.park(LockSupport.java:156)
> at
> java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:811)
> at
> java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedInterruptibly(AbstractQueuedSynchronizer.java:969)
> at
> java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1281)
> at java.util.concurrent.CountDownLatch.await(CountDownLatch.java:207)
> at
> kafka.tools.MirrorMaker$MirrorMakerThread.awaitShutdown(MirrorMaker.scala:216)
> at
> kafka.tools.MirrorMaker$$anonfun$cleanShutdown$2.apply(MirrorMaker.scala:167)
> at
> kafka.tools.MirrorMaker$$anonfun$cleanShutdown$2.apply(MirrorMaker.scala:167)
> at
> scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61)
> at scala.collection.immutable.List.foreach(List.scala:45)
> at kafka.tools.MirrorMaker$.cleanShutdown(MirrorMaker.scala:167)
> at kafka.tools.MirrorMaker$$anon$2.run(MirrorMaker.scala:144)
> "mirrormaker-0" prio=5 tid=7f9414a90800 nid=0x113804000 waiting on condition
> [113803000]
> java.lang.Thread.State: WAITING (parking)
> at sun.misc.Unsafe.park(Native Method)
> - parking to wait for <7ec0b0298> (a
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> at java.util.concurrent.locks.LockSupport.park(LockSupport.java:156)
> at
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:1987)
> at
> java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:399)
> at kafka.consumer.ConsumerIterator.makeNext(ConsumerIterator.scala:63)
> at kafka.consumer.ConsumerIterator.makeNext(ConsumerIterator.scala:33)
> at
> kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66)
> at kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58)
> at scala.collection.Iterator$class.foreach(Iterator.scala:631)
> at kafka.utils.IteratorTemplate.foreach(IteratorTemplate.scala:32)
> at scala.collection.IterableLike$class.foreach(IterableLike.scala:79)
> at kafka.consumer.KafkaStream.foreach(KafkaStream.scala:25)
> at
> kafka.tools.MirrorMaker$MirrorMakerThread.run(MirrorMaker.scala:190)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
