[
https://issues.apache.org/jira/browse/KAFKA-1363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13967627#comment-13967627
]
Neha Narkhede commented on KAFKA-1363:
--------------------------------------
Checked into 0.8.1 as well
> testTopicConfigChangesDuringDeleteTopic hangs
> ---------------------------------------------
>
> Key: KAFKA-1363
> URL: https://issues.apache.org/jira/browse/KAFKA-1363
> Project: Kafka
> Issue Type: Bug
> Components: core
> Affects Versions: 0.8.1
> Reporter: Jun Rao
> Assignee: Timothy Chen
> Fix For: 0.8.1.1
>
> Attachments: KAFKA-1363.patch, KAFKA-1363.patch,
> KAFKA-1363_2014-04-08_17:52:17.patch, KAFKA-1363_2014-04-09_11:38:09.patch
>
>
> Saw the following deadlock during shutting down the delete topic manager.
> "delete-topics-thread" prio=10 tid=0x00007fd50c003800 nid=0x7d9 waiting on
> condition [0x00007fd53d160000]
> java.lang.Thread.State: WAITING (parking)
> at sun.misc.Unsafe.park(Native Method)
> - parking to wait for <0x00000006b41d6318> (a
> java.util.concurrent.locks.ReentrantLock$NonfairSync)
> 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.acquireQueued(AbstractQueuedSynchronizer.java:842)
> at
> java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:1178)
> at
> java.util.concurrent.locks.ReentrantLock$NonfairSync.lock(ReentrantLock.java:186)
> at
> java.util.concurrent.locks.ReentrantLock.lock(ReentrantLock.java:262)
> at kafka.utils.Utils$.inLock(Utils.scala:535)
> at
> kafka.controller.TopicDeletionManager$DeleteTopicsThread.doWork(TopicDeletionManager.scala:363)
> at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
> "Test worker" prio=10 tid=0x00007fd578928800 nid=0x763d waiting on condition
> [0x00007fd570a87000]
> java.lang.Thread.State: WAITING (parking)
> at sun.misc.Unsafe.park(Native Method)
> - parking to wait for <0x00000006b5b6f580> (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.utils.ShutdownableThread.shutdown(ShutdownableThread.scala:36)
> at
> kafka.controller.TopicDeletionManager.shutdown(TopicDeletionManager.scala:100)
> at
> kafka.controller.KafkaController$$anonfun$onControllerResignation$1.apply$mcV$sp(KafkaController.scala:345)
> at
> kafka.controller.KafkaController$$anonfun$onControllerResignation$1.apply(KafkaController.scala:341)
> at
> kafka.controller.KafkaController$$anonfun$onControllerResignation$1.apply(KafkaController.scala:341)
> at kafka.utils.Utils$.inLock(Utils.scala:537)
> at
> kafka.controller.KafkaController.onControllerResignation(KafkaController.scala:341)
> at
> kafka.controller.KafkaController$$anonfun$shutdown$1.apply$mcV$sp(KafkaController.scala:648)
> at
> kafka.controller.KafkaController$$anonfun$shutdown$1.apply(KafkaController.scala:646)
> at
> kafka.controller.KafkaController$$anonfun$shutdown$1.apply(KafkaController.scala:646)
> at kafka.utils.Utils$.inLock(Utils.scala:537)
> at
> kafka.controller.KafkaController.shutdown(KafkaController.scala:646)
> at
> kafka.server.KafkaServer$$anonfun$shutdown$9.apply$mcV$sp(KafkaServer.scala:242)
> at kafka.utils.Utils$.swallow(Utils.scala:166)
> at kafka.utils.Logging$class.swallowWarn(Logging.scala:92)
> at kafka.utils.Utils$.swallowWarn(Utils.scala:45)
> at kafka.utils.Logging$class.swallow(Logging.scala:94)
> at kafka.utils.Utils$.swallow(Utils.scala:45)
> at kafka.server.KafkaServer.shutdown(KafkaServer.scala:242)
> at
> kafka.admin.DeleteTopicTest$$anonfun$testTopicConfigChangesDuringDeleteTopic$1.apply(DeleteTopicTest.scala:362)
> at
> kafka.admin.DeleteTopicTest$$anonfun$testTopicConfigChangesDuringDeleteTopic$1.apply(DeleteTopicTest.scala:362)
> at
> scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61)
> at scala.collection.immutable.List.foreach(List.scala:45)
> at
> kafka.admin.DeleteTopicTest.testTopicConfigChangesDuringDeleteTopic(DeleteTopicTest.scala:362)
--
This message was sent by Atlassian JIRA
(v6.2#6252)
