[KAFKA-1574] unit tests can hang on socketserver shutdown

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.8.2.0
• Fix Version/s: 0.8.2.0
• Component/s: core
• Labels: newbie++
• Assignee: Jun Rao
• Reporter: Jun Rao
• Created: 06/Aug/14 16:36
• Updated: 11/Aug/14 14:46
• Resolved: 11/Aug/14 14:46

Description

Saw the following stacktrace.

"kafka-network-thread-59843-2" prio=5 tid=7fc7e5943800 nid=0x11eefa000 runnable [11eef9000]
java.lang.Thread.State: RUNNABLE
at sun.nio.ch.KQueueArrayWrapper.kevent0(Native Method)
at sun.nio.ch.KQueueArrayWrapper.poll(KQueueArrayWrapper.java:136)
at sun.nio.ch.KQueueSelectorImpl.doSelect(KQueueSelectorImpl.java:69)
at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:69)

• locked <7f4a80328> (a sun.nio.ch.Util$2)
• locked <7f4a80310> (a java.util.Collections$UnmodifiableSet)
• locked <7f4a71968> (a sun.nio.ch.KQueueSelectorImpl)
  at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:80)
  at kafka.network.Processor.run(SocketServer.scala:296)
  at java.lang.Thread.run(Thread.java:695)

"Test worker" prio=5 tid=7fc7e50d4800 nid=0x11534c000 waiting on condition [115349000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)

• parking to wait for <7f4a69d50> (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.network.AbstractServerThread.shutdown(SocketServer.scala:113)
  at kafka.network.SocketServer$$anonfun$shutdown$2.apply(SocketServer.scala:92)
  at kafka.network.SocketServer$$anonfun$shutdown$2.apply(SocketServer.scala:91)
  at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:34)
  at scala.collection.mutable.ArrayOps.foreach(ArrayOps.scala:34)
  at kafka.network.SocketServer.shutdown(SocketServer.scala:91)
  at kafka.server.KafkaServer$$anonfun$shutdown$3.apply$mcV$sp(KafkaServer.scala:246)
  at kafka.utils.Utils$.swallow(Utils.scala:172)
  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:246)
  at kafka.admin.AdminTest$$anonfun$testPartitionReassignmentNonOverlappingReplicas$3.apply(AdminTest.scala:232)
  at kafka.admin.AdminTest$$anonfun$testPartitionReassignmentNonOverlappingReplicas$3.apply(AdminTest.scala:232)