Created
August 26, 2014 15:56
-
-
Save plaflamme/634411b162f56d8f48f6 to your computer and use it in GitHub Desktop.
Kafka Broker Thread Dump
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Full thread dump Java HotSpot(TM) 64-Bit Server VM (24.51-b03 mixed mode): | |
| "Attach Listener" daemon prio=10 tid=0x00007fe45c001000 nid=0x2822 waiting on condition [0x0000000000000000] | |
| java.lang.Thread.State: RUNNABLE | |
| "JMX server connection timeout 113128" daemon prio=10 tid=0x00007fd3e4006800 nid=0x7a94 in Object.wait() [0x00007fe461f6c000] | |
| java.lang.Thread.State: TIMED_WAITING (on object monitor) | |
| at java.lang.Object.wait(Native Method) | |
| - waiting on <0x0000000783885250> (a [I) | |
| at com.sun.jmx.remote.internal.ServerCommunicatorAdmin$Timeout.run(ServerCommunicatorAdmin.java:168) | |
| - locked <0x0000000783885250> (a [I) | |
| at java.lang.Thread.run(Thread.java:744) | |
| "RMI TCP Connection(idle)" daemon prio=10 tid=0x00007fe450001000 nid=0x76af waiting on condition [0x00007fe1b0c96000] | |
| java.lang.Thread.State: TIMED_WAITING (parking) | |
| at sun.misc.Unsafe.park(Native Method) | |
| - parking to wait for <0x000000076a84bdd8> (a java.util.concurrent.SynchronousQueue$TransferStack) | |
| at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226) | |
| at java.util.concurrent.SynchronousQueue$TransferStack.awaitFulfill(SynchronousQueue.java:460) | |
| at java.util.concurrent.SynchronousQueue$TransferStack.transfer(SynchronousQueue.java:359) | |
| at java.util.concurrent.SynchronousQueue.poll(SynchronousQueue.java:942) | |
| at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) | |
| at java.lang.Thread.run(Thread.java:744) | |
| "Controller-1-to-broker-3-send-thread" prio=10 tid=0x00007fe44002c000 nid=0x681 waiting on condition [0x00007fd2f3ffb000] | |
| java.lang.Thread.State: WAITING (parking) | |
| at sun.misc.Unsafe.park(Native Method) | |
| - parking to wait for <0x000000076c3af050> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043) | |
| at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:121) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) | |
| "Controller-1-to-broker-2-send-thread" prio=10 tid=0x00007fe44000f000 nid=0x655 waiting on condition [0x00007fe46206d000] | |
| java.lang.Thread.State: WAITING (parking) | |
| at sun.misc.Unsafe.park(Native Method) | |
| - parking to wait for <0x000000076af5e6c8> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043) | |
| at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:121) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) | |
| "Controller-1-to-broker-1-send-thread" prio=10 tid=0x00007fe44000c000 nid=0x654 waiting on condition [0x00007fe19ebea000] | |
| java.lang.Thread.State: WAITING (parking) | |
| at sun.misc.Unsafe.park(Native Method) | |
| - parking to wait for <0x000000076af5e710> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043) | |
| at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:121) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) | |
| "main-EventThread" daemon prio=10 tid=0x00007fe43801b800 nid=0x512 waiting on condition [0x00007fe19e9e8000] | |
| java.lang.Thread.State: WAITING (parking) | |
| at sun.misc.Unsafe.park(Native Method) | |
| - parking to wait for <0x000000076a294680> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043) | |
| at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) | |
| at org.apache.zookeeper.ClientCnxn$EventThread.run(ClientCnxn.java:503) | |
| "main-SendThread(zk-zoo1.lab.mtl:2181)" daemon prio=10 tid=0x00007fe43801a000 nid=0x511 runnable [0x00007fe19eae9000] | |
| java.lang.Thread.State: RUNNABLE | |
| at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method) | |
| at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269) | |
| at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:79) | |
| at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:87) | |
| - locked <0x000000076a2d13c0> (a sun.nio.ch.Util$2) | |
| - locked <0x000000076a2d13a8> (a java.util.Collections$UnmodifiableSet) | |
| - locked <0x000000076a533a20> (a sun.nio.ch.EPollSelectorImpl) | |
| at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:98) | |
| at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1134) | |
| "kafka-scheduler-3" daemon prio=10 tid=0x00007fe4b05df800 nid=0x501 waiting on condition [0x00007fe19eceb000] | |
| java.lang.Thread.State: WAITING (parking) | |
| at sun.misc.Unsafe.park(Native Method) | |
| - parking to wait for <0x000000076a226c48> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1085) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:807) | |
| at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) | |
| at java.lang.Thread.run(Thread.java:744) | |
| "kafka-request-handler-7" daemon prio=10 tid=0x00007fe4b05dd000 nid=0x500 waiting on condition [0x00007fe19edec000] | |
| java.lang.Thread.State: WAITING (parking) | |
| at sun.misc.Unsafe.park(Native Method) | |
| - parking to wait for <0x000000076a22c690> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043) | |
| at java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:374) | |
| at kafka.network.RequestChannel.receiveRequest(RequestChannel.scala:164) | |
| at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:34) | |
| at java.lang.Thread.run(Thread.java:744) | |
| "kafka-request-handler-6" daemon prio=10 tid=0x00007fe4b05db800 nid=0x4ff waiting on condition [0x00007fe19eeed000] | |
| java.lang.Thread.State: WAITING (parking) | |
| at sun.misc.Unsafe.park(Native Method) | |
| - parking to wait for <0x000000076a22c690> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043) | |
| at java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:374) | |
| at kafka.network.RequestChannel.receiveRequest(RequestChannel.scala:164) | |
| at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:34) | |
| at java.lang.Thread.run(Thread.java:744) | |
| "kafka-request-handler-5" daemon prio=10 tid=0x00007fe4b05fd000 nid=0x4fe waiting on condition [0x00007fe19efee000] | |
| java.lang.Thread.State: WAITING (parking) | |
| at sun.misc.Unsafe.park(Native Method) | |
| - parking to wait for <0x000000076a22c690> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043) | |
| at java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:374) | |
| at kafka.network.RequestChannel.receiveRequest(RequestChannel.scala:164) | |
| at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:34) | |
| at java.lang.Thread.run(Thread.java:744) | |
| "kafka-request-handler-4" daemon prio=10 tid=0x00007fe4b05fb800 nid=0x4fd waiting on condition [0x00007fe19f0ef000] | |
| java.lang.Thread.State: WAITING (parking) | |
| at sun.misc.Unsafe.park(Native Method) | |
| - parking to wait for <0x000000076a22c690> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043) | |
| at java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:374) | |
| at kafka.network.RequestChannel.receiveRequest(RequestChannel.scala:164) | |
| at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:34) | |
| at java.lang.Thread.run(Thread.java:744) | |
| "kafka-request-handler-3" daemon prio=10 tid=0x00007fe4b0596000 nid=0x4fc waiting on condition [0x00007fe19f1f0000] | |
| java.lang.Thread.State: WAITING (parking) | |
| at sun.misc.Unsafe.park(Native Method) | |
| - parking to wait for <0x000000076a22c690> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043) | |
| at java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:374) | |
| at kafka.network.RequestChannel.receiveRequest(RequestChannel.scala:164) | |
| at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:34) | |
| at java.lang.Thread.run(Thread.java:744) | |
| "kafka-request-handler-2" daemon prio=10 tid=0x00007fe4b0595000 nid=0x4fb waiting on condition [0x00007fe19f2f1000] | |
| java.lang.Thread.State: WAITING (parking) | |
| at sun.misc.Unsafe.park(Native Method) | |
| - parking to wait for <0x000000076a22c690> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043) | |
| at java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:374) | |
| at kafka.network.RequestChannel.receiveRequest(RequestChannel.scala:164) | |
| at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:34) | |
| at java.lang.Thread.run(Thread.java:744) | |
| "kafka-request-handler-1" daemon prio=10 tid=0x00007fe4b059a800 nid=0x4fa waiting on condition [0x00007fe19f3f2000] | |
| java.lang.Thread.State: WAITING (parking) | |
| at sun.misc.Unsafe.park(Native Method) | |
| - parking to wait for <0x000000076a22c690> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043) | |
| at java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:374) | |
| at kafka.network.RequestChannel.receiveRequest(RequestChannel.scala:164) | |
| at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:34) | |
| at java.lang.Thread.run(Thread.java:744) | |
| "kafka-request-handler-0" daemon prio=10 tid=0x00007fe4b05a1000 nid=0x4f9 waiting on condition [0x00007fe19f4f3000] | |
| java.lang.Thread.State: WAITING (parking) | |
| at sun.misc.Unsafe.park(Native Method) | |
| - parking to wait for <0x000000076a22c690> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043) | |
| at java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:374) | |
| at kafka.network.RequestChannel.receiveRequest(RequestChannel.scala:164) | |
| at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:34) | |
| at java.lang.Thread.run(Thread.java:744) | |
| "request-expiration-task" prio=10 tid=0x00007fe4b0586800 nid=0x4f8 runnable [0x00007fe19f5f4000] | |
| java.lang.Thread.State: TIMED_WAITING (parking) | |
| at sun.misc.Unsafe.park(Native Method) | |
| - parking to wait for <0x000000076a22c6c0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) | |
| at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2082) | |
| at java.util.concurrent.DelayQueue.poll(DelayQueue.java:269) | |
| at kafka.server.RequestPurgatory$ExpiredRequestReaper.pollExpired(RequestPurgatory.scala:256) | |
| at kafka.server.RequestPurgatory$ExpiredRequestReaper.run(RequestPurgatory.scala:213) | |
| at java.lang.Thread.run(Thread.java:744) | |
| "request-expiration-task" prio=10 tid=0x00007fe4b05f6800 nid=0x4f7 waiting on condition [0x00007fe19f6f5000] | |
| java.lang.Thread.State: TIMED_WAITING (parking) | |
| at sun.misc.Unsafe.park(Native Method) | |
| - parking to wait for <0x000000076a22db10> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) | |
| at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2082) | |
| at java.util.concurrent.DelayQueue.poll(DelayQueue.java:256) | |
| at kafka.server.RequestPurgatory$ExpiredRequestReaper.pollExpired(RequestPurgatory.scala:256) | |
| at kafka.server.RequestPurgatory$ExpiredRequestReaper.run(RequestPurgatory.scala:213) | |
| at java.lang.Thread.run(Thread.java:744) | |
| "metrics-meter-tick-thread-2" daemon prio=10 tid=0x00007fe4b02cc800 nid=0x4f6 waiting on condition [0x00007fe19f7f6000] | |
| java.lang.Thread.State: WAITING (parking) | |
| at sun.misc.Unsafe.park(Native Method) | |
| - parking to wait for <0x000000076a22db58> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1085) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:807) | |
| at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) | |
| at java.lang.Thread.run(Thread.java:744) | |
| "kafka-acceptor" prio=10 tid=0x00007fe4b056a800 nid=0x4f5 runnable [0x00007fe19f8f7000] | |
| java.lang.Thread.State: RUNNABLE | |
| at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method) | |
| at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269) | |
| at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:79) | |
| at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:87) | |
| - locked <0x000000076a22db88> (a sun.nio.ch.Util$2) | |
| - locked <0x000000076a22dba0> (a java.util.Collections$UnmodifiableSet) | |
| - locked <0x000000076a22e2a0> (a sun.nio.ch.EPollSelectorImpl) | |
| at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:98) | |
| at kafka.network.Acceptor.run(SocketServer.scala:144) | |
| at java.lang.Thread.run(Thread.java:744) | |
| "kafka-processor-9092-2" prio=10 tid=0x00007fe4b0576000 nid=0x4f4 runnable [0x00007fe19f9f8000] | |
| java.lang.Thread.State: RUNNABLE | |
| at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method) | |
| at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269) | |
| at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:79) | |
| at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:87) | |
| - locked <0x000000076a22dbb8> (a sun.nio.ch.Util$2) | |
| - locked <0x000000076a22dbd0> (a java.util.Collections$UnmodifiableSet) | |
| - locked <0x000000076a22e378> (a sun.nio.ch.EPollSelectorImpl) | |
| at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:98) | |
| at kafka.network.Processor.run(SocketServer.scala:234) | |
| at java.lang.Thread.run(Thread.java:744) | |
| "kafka-processor-9092-1" prio=10 tid=0x00007fe4b0575000 nid=0x4f3 runnable [0x00007fe19faf9000] | |
| java.lang.Thread.State: RUNNABLE | |
| at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method) | |
| at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269) | |
| at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:79) | |
| at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:87) | |
| - locked <0x000000076a22dbe8> (a sun.nio.ch.Util$2) | |
| - locked <0x000000076a22dc00> (a java.util.Collections$UnmodifiableSet) | |
| - locked <0x000000076a22e450> (a sun.nio.ch.EPollSelectorImpl) | |
| at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:98) | |
| at kafka.network.Processor.run(SocketServer.scala:234) | |
| at java.lang.Thread.run(Thread.java:744) | |
| "kafka-processor-9092-0" prio=10 tid=0x00007fe4b0578000 nid=0x4f2 runnable [0x00007fe19fbfa000] | |
| java.lang.Thread.State: RUNNABLE | |
| at sun.nio.ch.FileDispatcherImpl.write0(Native Method) | |
| at sun.nio.ch.SocketDispatcher.write(SocketDispatcher.java:47) | |
| at sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:93) | |
| at sun.nio.ch.IOUtil.write(IOUtil.java:65) | |
| at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:487) | |
| - locked <0x000000078a02cc70> (a java.lang.Object) | |
| at kafka.api.FetchResponseSend.writeTo(FetchResponse.scala:217) | |
| at kafka.network.Processor.write(SocketServer.scala:375) | |
| at kafka.network.Processor.run(SocketServer.scala:247) | |
| at java.lang.Thread.run(Thread.java:744) | |
| "kafka-log-cleaner-thread-0" prio=10 tid=0x00007fe4b0552800 nid=0x4f1 waiting on condition [0x00007fe19fcfb000] | |
| java.lang.Thread.State: TIMED_WAITING (sleeping) | |
| at java.lang.Thread.sleep(Native Method) | |
| at kafka.utils.SystemTime$.sleep(Time.scala:59) | |
| at kafka.log.LogCleaner$CleanerThread.cleanOrSleep(LogCleaner.scala:197) | |
| at kafka.log.LogCleaner$CleanerThread.doWork(LogCleaner.scala:187) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) | |
| "kafka-scheduler-2" daemon prio=10 tid=0x00007fe4b025f000 nid=0x4f0 waiting on condition [0x00007fe19fdfc000] | |
| java.lang.Thread.State: WAITING (parking) | |
| at sun.misc.Unsafe.park(Native Method) | |
| - parking to wait for <0x000000076a226c48> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1085) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:807) | |
| at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) | |
| at java.lang.Thread.run(Thread.java:744) | |
| "kafka-scheduler-1" daemon prio=10 tid=0x00007fe4b025e800 nid=0x4ef waiting on condition [0x00007fe19fefd000] | |
| java.lang.Thread.State: WAITING (parking) | |
| at sun.misc.Unsafe.park(Native Method) | |
| - parking to wait for <0x000000076a226c48> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1085) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:807) | |
| at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) | |
| at java.lang.Thread.run(Thread.java:744) | |
| "kafka-scheduler-0" daemon prio=10 tid=0x00007fe4b0261800 nid=0x4ee waiting on condition [0x00007fe19fffe000] | |
| java.lang.Thread.State: TIMED_WAITING (parking) | |
| at sun.misc.Unsafe.park(Native Method) | |
| - parking to wait for <0x000000076a226c48> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) | |
| at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2082) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1090) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:807) | |
| at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) | |
| at java.lang.Thread.run(Thread.java:744) | |
| "metrics-meter-tick-thread-1" daemon prio=10 tid=0x00007fe4b0646000 nid=0x4ed waiting on condition [0x00007fe1ab85a000] | |
| java.lang.Thread.State: TIMED_WAITING (parking) | |
| at sun.misc.Unsafe.park(Native Method) | |
| - parking to wait for <0x000000076a22db58> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) | |
| at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2082) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1090) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:807) | |
| at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) | |
| at java.lang.Thread.run(Thread.java:744) | |
| "RMI Scheduler(0)" daemon prio=10 tid=0x00007fe1ac003800 nid=0x4e6 waiting on condition [0x00007fe1b0867000] | |
| java.lang.Thread.State: TIMED_WAITING (parking) | |
| at sun.misc.Unsafe.park(Native Method) | |
| - parking to wait for <0x000000076a226c60> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) | |
| at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2082) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1090) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:807) | |
| at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) | |
| at java.lang.Thread.run(Thread.java:744) | |
| "ZkClient-EventThread-14-zk-zoo1.lab.mtl:2181/kafka08" daemon prio=10 tid=0x00007fe4b0530000 nid=0x49d waiting on condition [0x00007fe46216e000] | |
| java.lang.Thread.State: WAITING (parking) | |
| at sun.misc.Unsafe.park(Native Method) | |
| - parking to wait for <0x000000076a226cd8> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043) | |
| at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) | |
| at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:67) | |
| "RMI TCP Accept-0" daemon prio=10 tid=0x00007fe4b036c800 nid=0x49b runnable [0x00007fe484209000] | |
| java.lang.Thread.State: RUNNABLE | |
| at java.net.PlainSocketImpl.socketAccept(Native Method) | |
| at java.net.AbstractPlainSocketImpl.accept(AbstractPlainSocketImpl.java:398) | |
| at java.net.ServerSocket.implAccept(ServerSocket.java:530) | |
| at java.net.ServerSocket.accept(ServerSocket.java:498) | |
| at sun.management.jmxremote.LocalRMIServerSocketFactory$1.accept(LocalRMIServerSocketFactory.java:52) | |
| at sun.rmi.transport.tcp.TCPTransport$AcceptLoop.executeAcceptLoop(TCPTransport.java:388) | |
| at sun.rmi.transport.tcp.TCPTransport$AcceptLoop.run(TCPTransport.java:360) | |
| at java.lang.Thread.run(Thread.java:744) | |
| "RMI TCP Accept-10301" daemon prio=10 tid=0x00007fe4b0366000 nid=0x49a runnable [0x00007fe48430a000] | |
| java.lang.Thread.State: RUNNABLE | |
| at java.net.PlainSocketImpl.socketAccept(Native Method) | |
| at java.net.AbstractPlainSocketImpl.accept(AbstractPlainSocketImpl.java:398) | |
| at java.net.ServerSocket.implAccept(ServerSocket.java:530) | |
| at java.net.ServerSocket.accept(ServerSocket.java:498) | |
| at sun.rmi.transport.tcp.TCPTransport$AcceptLoop.executeAcceptLoop(TCPTransport.java:388) | |
| at sun.rmi.transport.tcp.TCPTransport$AcceptLoop.run(TCPTransport.java:360) | |
| at java.lang.Thread.run(Thread.java:744) | |
| "RMI TCP Accept-0" daemon prio=10 tid=0x00007fe4b0357000 nid=0x499 runnable [0x00007fe48440b000] | |
| java.lang.Thread.State: RUNNABLE | |
| at java.net.PlainSocketImpl.socketAccept(Native Method) | |
| at java.net.AbstractPlainSocketImpl.accept(AbstractPlainSocketImpl.java:398) | |
| at java.net.ServerSocket.implAccept(ServerSocket.java:530) | |
| at java.net.ServerSocket.accept(ServerSocket.java:498) | |
| at sun.rmi.transport.tcp.TCPTransport$AcceptLoop.executeAcceptLoop(TCPTransport.java:388) | |
| at sun.rmi.transport.tcp.TCPTransport$AcceptLoop.run(TCPTransport.java:360) | |
| at java.lang.Thread.run(Thread.java:744) | |
| "Service Thread" daemon prio=10 tid=0x00007fe4b025c800 nid=0x498 runnable [0x0000000000000000] | |
| java.lang.Thread.State: RUNNABLE | |
| "C2 CompilerThread1" daemon prio=10 tid=0x00007fe4b025a000 nid=0x497 waiting on condition [0x0000000000000000] | |
| java.lang.Thread.State: RUNNABLE | |
| "C2 CompilerThread0" daemon prio=10 tid=0x00007fe4b0257800 nid=0x496 waiting on condition [0x0000000000000000] | |
| java.lang.Thread.State: RUNNABLE | |
| "Signal Dispatcher" daemon prio=10 tid=0x00007fe4b0255800 nid=0x495 runnable [0x0000000000000000] | |
| java.lang.Thread.State: RUNNABLE | |
| "Surrogate Locker Thread (Concurrent GC)" daemon prio=10 tid=0x00007fe4b024b000 nid=0x494 waiting on condition [0x0000000000000000] | |
| java.lang.Thread.State: RUNNABLE | |
| "Finalizer" daemon prio=10 tid=0x00007fe4b0234000 nid=0x493 in Object.wait() [0x00007fe4853c0000] | |
| java.lang.Thread.State: WAITING (on object monitor) | |
| at java.lang.Object.wait(Native Method) | |
| - waiting on <0x000000076a226d68> (a java.lang.ref.ReferenceQueue$Lock) | |
| at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:135) | |
| - locked <0x000000076a226d68> (a java.lang.ref.ReferenceQueue$Lock) | |
| at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:151) | |
| at java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:189) | |
| "Reference Handler" daemon prio=10 tid=0x00007fe4b0230000 nid=0x492 in Object.wait() [0x00007fe4854c1000] | |
| java.lang.Thread.State: WAITING (on object monitor) | |
| at java.lang.Object.wait(Native Method) | |
| - waiting on <0x000000076a2236e0> (a java.lang.ref.Reference$Lock) | |
| at java.lang.Object.wait(Object.java:503) | |
| at java.lang.ref.Reference$ReferenceHandler.run(Reference.java:133) | |
| - locked <0x000000076a2236e0> (a java.lang.ref.Reference$Lock) | |
| "main" prio=10 tid=0x00007fe4b0009800 nid=0x485 waiting on condition [0x00007fe4b510c000] | |
| java.lang.Thread.State: WAITING (parking) | |
| at sun.misc.Unsafe.park(Native Method) | |
| - parking to wait for <0x000000076a22c890> (a java.util.concurrent.CountDownLatch$Sync) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:834) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedInterruptibly(AbstractQueuedSynchronizer.java:994) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1303) | |
| at java.util.concurrent.CountDownLatch.await(CountDownLatch.java:236) | |
| at kafka.server.KafkaServer.awaitShutdown(KafkaServer.scala:246) | |
| at kafka.server.KafkaServerStartable.awaitShutdown(KafkaServerStartable.scala:56) | |
| at kafka.Kafka$.main(Kafka.scala:47) | |
| at kafka.Kafka.main(Kafka.scala) | |
| "VM Thread" prio=10 tid=0x00007fe4b022d800 nid=0x491 runnable | |
| "Gang worker#0 (Parallel GC Threads)" prio=10 tid=0x00007fe4b001a800 nid=0x486 runnable | |
| "Gang worker#1 (Parallel GC Threads)" prio=10 tid=0x00007fe4b001c800 nid=0x487 runnable | |
| "Gang worker#2 (Parallel GC Threads)" prio=10 tid=0x00007fe4b001e800 nid=0x488 runnable | |
| "Gang worker#3 (Parallel GC Threads)" prio=10 tid=0x00007fe4b0020800 nid=0x489 runnable | |
| "Gang worker#4 (Parallel GC Threads)" prio=10 tid=0x00007fe4b0022000 nid=0x48a runnable | |
| "Gang worker#5 (Parallel GC Threads)" prio=10 tid=0x00007fe4b0024000 nid=0x48b runnable | |
| "Gang worker#6 (Parallel GC Threads)" prio=10 tid=0x00007fe4b0026000 nid=0x48c runnable | |
| "Gang worker#7 (Parallel GC Threads)" prio=10 tid=0x00007fe4b0027800 nid=0x48d runnable | |
| "Concurrent Mark-Sweep GC Thread" prio=10 tid=0x00007fe4b0101000 nid=0x490 runnable | |
| "Gang worker#0 (Parallel CMS Threads)" prio=10 tid=0x00007fe4b00fc800 nid=0x48e runnable | |
| "Gang worker#1 (Parallel CMS Threads)" prio=10 tid=0x00007fe4b00fe800 nid=0x48f runnable | |
| "VM Periodic Task Thread" prio=10 tid=0x00007fe4b036f000 nid=0x49c waiting on condition | |
| JNI global references: 271 |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment