Created
April 25, 2018 04:56
-
-
Save holgerbrandl/095c8eb7a486626676882c94269bc741 to your computer and use it in GitHub Desktop.
Thread dump of deadlock in org.deeplearning4j.streaming.kafka.NDArrayPublisherTests#testPublish
This file contains 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 | |
| "main@1" prio=5 tid=0x1 nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) | |
| at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) | |
| at org.apache.camel.component.seda.SedaPollingConsumer.receive(SedaPollingConsumer.java:41) | |
| at org.apache.camel.impl.ConsumerCache.receive(ConsumerCache.java:202) | |
| at org.apache.camel.impl.DefaultConsumerTemplate.receive(DefaultConsumerTemplate.java:90) | |
| at org.apache.camel.impl.DefaultConsumerTemplate.receiveBody(DefaultConsumerTemplate.java:163) | |
| at org.deeplearning4j.streaming.kafka.NDArrayConsumer.getINDArray(NDArrayConsumer.java:84) | |
| at org.deeplearning4j.streaming.kafka.NDArrayPublisherTests.testPublish(NDArrayPublisherTests.java:47) | |
| at sun.reflect.NativeMethodAccessorImpl.invoke0(NativeMethodAccessorImpl.java:-1) | |
| at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) | |
| at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) | |
| at java.lang.reflect.Method.invoke(Method.java:498) | |
| at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50) | |
| at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) | |
| at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47) | |
| at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17) | |
| at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325) | |
| at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78) | |
| at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57) | |
| at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290) | |
| at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71) | |
| at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288) | |
| at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58) | |
| at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268) | |
| at org.junit.runners.ParentRunner.run(ParentRunner.java:363) | |
| at org.junit.runner.JUnitCore.run(JUnitCore.java:137) | |
| at com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:68) | |
| at com.intellij.rt.execution.junit.IdeaTestRunner$Repeater.startRunnerWithArgs(IdeaTestRunner.java:47) | |
| at com.intellij.rt.execution.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:242) | |
| at com.intellij.rt.execution.junit.JUnitStarter.main(JUnitStarter.java:70) | |
| "Camel (camel-1) thread #2 - KafkaConsumer[testkafka]@5237" daemon prio=5 tid=0x47 nid=NA runnable | |
| java.lang.Thread.State: RUNNABLE | |
| blocks kafka-coordinator-heartbeat-thread | dl4jgroup@5238 | |
| at sun.nio.ch.KQueueArrayWrapper.kevent0(KQueueArrayWrapper.java:-1) | |
| at sun.nio.ch.KQueueArrayWrapper.poll(KQueueArrayWrapper.java:198) | |
| at sun.nio.ch.KQueueSelectorImpl.doSelect(KQueueSelectorImpl.java:117) | |
| at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86) | |
| - locked <0x148f> (a sun.nio.ch.KQueueSelectorImpl) | |
| - locked <0x1490> (a java.util.Collections$UnmodifiableSet) | |
| - locked <0x1491> (a sun.nio.ch.Util$3) | |
| at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97) | |
| at org.apache.kafka.common.network.Selector.select(Selector.java:470) | |
| at org.apache.kafka.common.network.Selector.poll(Selector.java:286) | |
| at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:260) | |
| at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:232) | |
| - locked <0x148e> (a org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient) | |
| at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1031) | |
| at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:979) | |
| at org.apache.camel.component.kafka.KafkaConsumer$KafkaFetchRecords.run(KafkaConsumer.java:142) | |
| at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) | |
| at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266) | |
| at java.util.concurrent.FutureTask.run(FutureTask.java:-1) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) | |
| at java.lang.Thread.run(Thread.java:748) | |
| "kafka-scheduler-0@2839" daemon prio=5 tid=0x29 nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:836) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued(AbstractQueuedSynchronizer.java:870) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:1199) | |
| at java.util.concurrent.locks.ReentrantLock$NonfairSync.lock(ReentrantLock.java:209) | |
| at java.util.concurrent.locks.ReentrantLock.lock(ReentrantLock.java:285) | |
| at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:232) | |
| at kafka.controller.KafkaController$$anonfun$kafka$controller$KafkaController$$checkAndTriggerPartitionRebalance$4.apply(KafkaController.scala:1194) | |
| at kafka.controller.KafkaController$$anonfun$kafka$controller$KafkaController$$checkAndTriggerPartitionRebalance$4.apply(KafkaController.scala:1190) | |
| at scala.collection.immutable.Map$Map1.foreach(Map.scala:116) | |
| at kafka.controller.KafkaController.kafka$controller$KafkaController$$checkAndTriggerPartitionRebalance(KafkaController.scala:1190) | |
| at kafka.controller.KafkaController$$anonfun$onControllerFailover$1.apply$mcV$sp(KafkaController.scala:347) | |
| at kafka.utils.KafkaScheduler$$anonfun$1.apply$mcV$sp(KafkaScheduler.scala:110) | |
| at kafka.utils.CoreUtils$$anon$1.run(CoreUtils.scala:58) | |
| at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) | |
| at java.util.concurrent.FutureTask.runAndReset$$$capture(FutureTask.java:308) | |
| at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:-1) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) | |
| at java.lang.Thread.run(Thread.java:748) | |
| "Camel (camel-1) thread #0 - KafkaConsumer[testkafka]@4634" daemon prio=5 tid=0x41 nid=NA runnable | |
| java.lang.Thread.State: RUNNABLE | |
| at sun.nio.ch.KQueueArrayWrapper.kevent0(KQueueArrayWrapper.java:-1) | |
| at sun.nio.ch.KQueueArrayWrapper.poll(KQueueArrayWrapper.java:198) | |
| at sun.nio.ch.KQueueSelectorImpl.doSelect(KQueueSelectorImpl.java:117) | |
| at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86) | |
| - locked <0x1496> (a sun.nio.ch.KQueueSelectorImpl) | |
| - locked <0x1497> (a java.util.Collections$UnmodifiableSet) | |
| - locked <0x1498> (a sun.nio.ch.Util$3) | |
| at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97) | |
| at org.apache.kafka.common.network.Selector.select(Selector.java:470) | |
| at org.apache.kafka.common.network.Selector.poll(Selector.java:286) | |
| at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:260) | |
| at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:232) | |
| - locked <0x1499> (a org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient) | |
| at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1031) | |
| at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:979) | |
| at org.apache.camel.component.kafka.KafkaConsumer$KafkaFetchRecords.run(KafkaConsumer.java:142) | |
| at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) | |
| at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266) | |
| at java.util.concurrent.FutureTask.run(FutureTask.java:-1) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) | |
| at java.lang.Thread.run(Thread.java:748) | |
| "kafka-producer-network-thread | producer-1@4544" daemon prio=5 tid=0x3d nid=NA runnable | |
| java.lang.Thread.State: RUNNABLE | |
| at sun.nio.ch.KQueueArrayWrapper.kevent0(KQueueArrayWrapper.java:-1) | |
| at sun.nio.ch.KQueueArrayWrapper.poll(KQueueArrayWrapper.java:198) | |
| at sun.nio.ch.KQueueSelectorImpl.doSelect(KQueueSelectorImpl.java:117) | |
| at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86) | |
| - locked <0x149a> (a sun.nio.ch.KQueueSelectorImpl) | |
| - locked <0x149b> (a java.util.Collections$UnmodifiableSet) | |
| - locked <0x149c> (a sun.nio.ch.Util$3) | |
| at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97) | |
| at org.apache.kafka.common.network.Selector.select(Selector.java:470) | |
| at org.apache.kafka.common.network.Selector.poll(Selector.java:286) | |
| at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:260) | |
| at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:236) | |
| at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:135) | |
| at java.lang.Thread.run(Thread.java:748) | |
| "kafka-network-thread-1-PLAINTEXT-2@2651" prio=5 tid=0x20 nid=NA runnable | |
| java.lang.Thread.State: RUNNABLE | |
| at sun.nio.ch.KQueueArrayWrapper.kevent0(KQueueArrayWrapper.java:-1) | |
| at sun.nio.ch.KQueueArrayWrapper.poll(KQueueArrayWrapper.java:198) | |
| at sun.nio.ch.KQueueSelectorImpl.doSelect(KQueueSelectorImpl.java:117) | |
| at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86) | |
| - locked <0x14a2> (a sun.nio.ch.KQueueSelectorImpl) | |
| - locked <0x14a3> (a java.util.Collections$UnmodifiableSet) | |
| - locked <0x14a4> (a sun.nio.ch.Util$3) | |
| at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97) | |
| at org.apache.kafka.common.network.Selector.select(Selector.java:470) | |
| at org.apache.kafka.common.network.Selector.poll(Selector.java:286) | |
| at kafka.network.Processor.poll(SocketServer.scala:476) | |
| at kafka.network.Processor.run(SocketServer.scala:416) | |
| at java.lang.Thread.run(Thread.java:748) | |
| "kafka-network-thread-1-PLAINTEXT-1@2650" prio=5 tid=0x1f nid=NA runnable | |
| java.lang.Thread.State: RUNNABLE | |
| at sun.nio.ch.KQueueArrayWrapper.kevent0(KQueueArrayWrapper.java:-1) | |
| at sun.nio.ch.KQueueArrayWrapper.poll(KQueueArrayWrapper.java:198) | |
| at sun.nio.ch.KQueueSelectorImpl.doSelect(KQueueSelectorImpl.java:117) | |
| at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86) | |
| - locked <0x14a5> (a sun.nio.ch.KQueueSelectorImpl) | |
| - locked <0x14a6> (a java.util.Collections$UnmodifiableSet) | |
| - locked <0x14a7> (a sun.nio.ch.Util$3) | |
| at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97) | |
| at org.apache.kafka.common.network.Selector.select(Selector.java:470) | |
| at org.apache.kafka.common.network.Selector.poll(Selector.java:286) | |
| at kafka.network.Processor.poll(SocketServer.scala:476) | |
| at kafka.network.Processor.run(SocketServer.scala:416) | |
| at java.lang.Thread.run(Thread.java:748) | |
| "kafka-network-thread-1-PLAINTEXT-0@2649" prio=5 tid=0x1e nid=NA runnable | |
| java.lang.Thread.State: RUNNABLE | |
| at sun.nio.ch.KQueueArrayWrapper.kevent0(KQueueArrayWrapper.java:-1) | |
| at sun.nio.ch.KQueueArrayWrapper.poll(KQueueArrayWrapper.java:198) | |
| at sun.nio.ch.KQueueSelectorImpl.doSelect(KQueueSelectorImpl.java:117) | |
| at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86) | |
| - locked <0x14a8> (a sun.nio.ch.KQueueSelectorImpl) | |
| - locked <0x14a9> (a java.util.Collections$UnmodifiableSet) | |
| - locked <0x14aa> (a sun.nio.ch.Util$3) | |
| at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97) | |
| at org.apache.kafka.common.network.Selector.select(Selector.java:470) | |
| at org.apache.kafka.common.network.Selector.poll(Selector.java:286) | |
| at kafka.network.Processor.poll(SocketServer.scala:476) | |
| at kafka.network.Processor.run(SocketServer.scala:416) | |
| at java.lang.Thread.run(Thread.java:748) | |
| "ZkClient-EventThread-22-localhost:53975@2076" daemon prio=5 tid=0x16 nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) | |
| at java.util.concurrent.ThreadPoolExecutor.awaitTermination(ThreadPoolExecutor.java:1475) | |
| at kafka.utils.KafkaScheduler.shutdown(KafkaScheduler.scala:98) | |
| at kafka.controller.KafkaController.onControllerResignation(KafkaController.scala:373) | |
| at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply$mcZ$sp(KafkaController.scala:1167) | |
| at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply(KafkaController.scala:1166) | |
| at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply(KafkaController.scala:1166) | |
| at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:234) | |
| at kafka.controller.KafkaController$SessionExpirationListener.handleNewSession(KafkaController.scala:1166) | |
| at org.I0Itec.zkclient.ZkClient$6.run(ZkClient.java:735) | |
| at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71) | |
| "main-SendThread(localhost:53975)@4869" daemon prio=5 tid=0x43 nid=NA runnable | |
| java.lang.Thread.State: RUNNABLE | |
| at sun.nio.ch.KQueueArrayWrapper.kevent0(KQueueArrayWrapper.java:-1) | |
| at sun.nio.ch.KQueueArrayWrapper.poll(KQueueArrayWrapper.java:198) | |
| at sun.nio.ch.KQueueSelectorImpl.doSelect(KQueueSelectorImpl.java:117) | |
| at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86) | |
| - locked <0x1493> (a sun.nio.ch.KQueueSelectorImpl) | |
| - locked <0x1494> (a java.util.Collections$UnmodifiableSet) | |
| - locked <0x1495> (a sun.nio.ch.Util$3) | |
| at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97) | |
| at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:349) | |
| at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1081) | |
| "kafka-socket-acceptor-PLAINTEXT-53977@2653" prio=5 tid=0x21 nid=NA runnable | |
| java.lang.Thread.State: RUNNABLE | |
| at sun.nio.ch.KQueueArrayWrapper.kevent0(KQueueArrayWrapper.java:-1) | |
| at sun.nio.ch.KQueueArrayWrapper.poll(KQueueArrayWrapper.java:198) | |
| at sun.nio.ch.KQueueSelectorImpl.doSelect(KQueueSelectorImpl.java:117) | |
| at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86) | |
| - locked <0x149f> (a sun.nio.ch.KQueueSelectorImpl) | |
| - locked <0x14a0> (a java.util.Collections$UnmodifiableSet) | |
| - locked <0x14a1> (a sun.nio.ch.Util$3) | |
| at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97) | |
| at kafka.network.Acceptor.run(SocketServer.scala:260) | |
| at java.lang.Thread.run(Thread.java:748) | |
| "NIOServerCxn.Factory:localhost/127.0.0.1:53975@1103" daemon prio=5 tid=0xd nid=NA runnable | |
| java.lang.Thread.State: RUNNABLE | |
| at sun.nio.ch.KQueueArrayWrapper.kevent0(KQueueArrayWrapper.java:-1) | |
| at sun.nio.ch.KQueueArrayWrapper.poll(KQueueArrayWrapper.java:198) | |
| at sun.nio.ch.KQueueSelectorImpl.doSelect(KQueueSelectorImpl.java:117) | |
| at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86) | |
| - locked <0x14ab> (a sun.nio.ch.KQueueSelectorImpl) | |
| - locked <0x14ac> (a java.util.Collections$UnmodifiableSet) | |
| - locked <0x14ad> (a sun.nio.ch.Util$3) | |
| at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97) | |
| at org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:178) | |
| at java.lang.Thread.run(Thread.java:748) | |
| "kafka-scheduler-9@4125" daemon prio=5 tid=0x3b nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) | |
| at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) | |
| at java.lang.Thread.run(Thread.java:748) | |
| "kafka-scheduler-8@3709" daemon prio=5 tid=0x38 nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) | |
| at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) | |
| at java.lang.Thread.run(Thread.java:748) | |
| "kafka-scheduler-7@3685" daemon prio=5 tid=0x37 nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) | |
| at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) | |
| at java.lang.Thread.run(Thread.java:748) | |
| "group-metadata-manager-0@2895" daemon prio=5 tid=0x2d nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) | |
| at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) | |
| at java.lang.Thread.run(Thread.java:748) | |
| "kafka-scheduler-6@2697" daemon prio=5 tid=0x28 nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) | |
| at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) | |
| at java.lang.Thread.run(Thread.java:748) | |
| "kafka-scheduler-5@2695" daemon prio=5 tid=0x27 nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) | |
| at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) | |
| at java.lang.Thread.run(Thread.java:748) | |
| "kafka-scheduler-4@2691" daemon prio=5 tid=0x26 nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) | |
| at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) | |
| at java.lang.Thread.run(Thread.java:748) | |
| "kafka-scheduler-3@2686" daemon prio=5 tid=0x25 nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) | |
| at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) | |
| at java.lang.Thread.run(Thread.java:748) | |
| "metrics-meter-tick-thread-2@2684" daemon prio=5 tid=0x24 nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) | |
| at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) | |
| at java.lang.Thread.run(Thread.java:748) | |
| "kafka-scheduler-2@2566" daemon prio=5 tid=0x1d nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) | |
| at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) | |
| at java.lang.Thread.run(Thread.java:748) | |
| "kafka-scheduler-1@2564" daemon prio=5 tid=0x1c nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) | |
| at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) | |
| at java.lang.Thread.run(Thread.java:748) | |
| "kafka-scheduler-0@2561" daemon prio=5 tid=0x1b nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) | |
| at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) | |
| at java.lang.Thread.run(Thread.java:748) | |
| "metrics-meter-tick-thread-1@2535" daemon prio=5 tid=0x19 nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) | |
| at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) | |
| at java.lang.Thread.run(Thread.java:748) | |
| "SensorExpiryThread@2027" daemon prio=5 tid=0x13 nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093) | |
| at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) | |
| at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) | |
| at java.lang.Thread.run(Thread.java:748) | |
| "executor-Fetch@5151" prio=5 tid=0x46 nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) | |
| at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) | |
| at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) | |
| at java.lang.Thread.run(Thread.java:748) | |
| "Camel (camel-1) thread #1 - KafkaProducer[testkafka]@4825" daemon prio=5 tid=0x42 nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) | |
| at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) | |
| at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) | |
| at java.lang.Thread.run(Thread.java:748) | |
| "ExpirationReaper-1@2858" prio=5 tid=0x2c nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) | |
| at java.util.concurrent.DelayQueue.poll(DelayQueue.java:268) | |
| at kafka.utils.timer.SystemTimer.advanceClock(Timer.scala:106) | |
| at kafka.server.DelayedOperationPurgatory.advanceClock(DelayedOperation.scala:355) | |
| at kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper.doWork(DelayedOperation.scala:379) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| "ExpirationReaper-1@2855" prio=5 tid=0x2b nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) | |
| at java.util.concurrent.DelayQueue.poll(DelayQueue.java:268) | |
| at kafka.utils.timer.SystemTimer.advanceClock(Timer.scala:106) | |
| at kafka.server.DelayedOperationPurgatory.advanceClock(DelayedOperation.scala:355) | |
| at kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper.doWork(DelayedOperation.scala:379) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| "ExpirationReaper-1@2847" prio=5 tid=0x2a nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) | |
| at java.util.concurrent.DelayQueue.poll(DelayQueue.java:259) | |
| at kafka.utils.timer.SystemTimer.advanceClock(Timer.scala:106) | |
| at kafka.server.DelayedOperationPurgatory.advanceClock(DelayedOperation.scala:355) | |
| at kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper.doWork(DelayedOperation.scala:379) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| "ExpirationReaper-1@2680" prio=5 tid=0x23 nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) | |
| at java.util.concurrent.DelayQueue.poll(DelayQueue.java:268) | |
| at kafka.utils.timer.SystemTimer.advanceClock(Timer.scala:106) | |
| at kafka.server.DelayedOperationPurgatory.advanceClock(DelayedOperation.scala:355) | |
| at kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper.doWork(DelayedOperation.scala:379) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| "ExpirationReaper-1@2679" prio=5 tid=0x22 nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) | |
| at java.util.concurrent.DelayQueue.poll(DelayQueue.java:259) | |
| at kafka.utils.timer.SystemTimer.advanceClock(Timer.scala:106) | |
| at kafka.server.DelayedOperationPurgatory.advanceClock(DelayedOperation.scala:355) | |
| at kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper.doWork(DelayedOperation.scala:379) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| "kafka-log-cleaner-thread-0@2570" prio=5 tid=0x1a nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328) | |
| at java.util.concurrent.CountDownLatch.await(CountDownLatch.java:277) | |
| at kafka.log.LogCleaner$CleanerThread.cleanOrSleep(LogCleaner.scala:258) | |
| at kafka.log.LogCleaner$CleanerThread.doWork(LogCleaner.scala:218) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| "kafka-request-handler-7@2950" daemon prio=5 tid=0x35 nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) | |
| at java.util.concurrent.ArrayBlockingQueue.poll(ArrayBlockingQueue.java:418) | |
| at kafka.network.RequestChannel.receiveRequest(RequestChannel.scala:238) | |
| at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:48) | |
| at java.lang.Thread.run(Thread.java:748) | |
| "kafka-request-handler-6@2948" daemon prio=5 tid=0x34 nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) | |
| at java.util.concurrent.ArrayBlockingQueue.poll(ArrayBlockingQueue.java:418) | |
| at kafka.network.RequestChannel.receiveRequest(RequestChannel.scala:238) | |
| at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:48) | |
| at java.lang.Thread.run(Thread.java:748) | |
| "kafka-request-handler-5@2947" daemon prio=5 tid=0x33 nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) | |
| at java.util.concurrent.ArrayBlockingQueue.poll(ArrayBlockingQueue.java:418) | |
| at kafka.network.RequestChannel.receiveRequest(RequestChannel.scala:238) | |
| at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:48) | |
| at java.lang.Thread.run(Thread.java:748) | |
| "kafka-request-handler-4@2946" daemon prio=5 tid=0x32 nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) | |
| at java.util.concurrent.ArrayBlockingQueue.poll(ArrayBlockingQueue.java:418) | |
| at kafka.network.RequestChannel.receiveRequest(RequestChannel.scala:238) | |
| at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:48) | |
| at java.lang.Thread.run(Thread.java:748) | |
| "kafka-request-handler-3@2945" daemon prio=5 tid=0x31 nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) | |
| at java.util.concurrent.ArrayBlockingQueue.poll(ArrayBlockingQueue.java:418) | |
| at kafka.network.RequestChannel.receiveRequest(RequestChannel.scala:238) | |
| at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:48) | |
| at java.lang.Thread.run(Thread.java:748) | |
| "kafka-request-handler-2@2944" daemon prio=5 tid=0x30 nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) | |
| at java.util.concurrent.ArrayBlockingQueue.poll(ArrayBlockingQueue.java:418) | |
| at kafka.network.RequestChannel.receiveRequest(RequestChannel.scala:238) | |
| at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:48) | |
| at java.lang.Thread.run(Thread.java:748) | |
| "kafka-request-handler-1@2943" daemon prio=5 tid=0x2f nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) | |
| at java.util.concurrent.ArrayBlockingQueue.poll(ArrayBlockingQueue.java:418) | |
| at kafka.network.RequestChannel.receiveRequest(RequestChannel.scala:238) | |
| at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:48) | |
| at java.lang.Thread.run(Thread.java:748) | |
| "kafka-request-handler-0@2942" daemon prio=5 tid=0x2e nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) | |
| at java.util.concurrent.ArrayBlockingQueue.poll(ArrayBlockingQueue.java:418) | |
| at kafka.network.RequestChannel.receiveRequest(RequestChannel.scala:238) | |
| at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:48) | |
| at java.lang.Thread.run(Thread.java:748) | |
| "Controller-1-to-broker-1-send-thread@3226" prio=5 tid=0x36 nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) | |
| at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:172) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| "ThrottledRequestReaper-Produce@2054" prio=5 tid=0x15 nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) | |
| at java.util.concurrent.DelayQueue.poll(DelayQueue.java:259) | |
| at kafka.server.ClientQuotaManager$ThrottledRequestReaper.doWork(ClientQuotaManager.scala:158) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| "ThrottledRequestReaper-Fetch@2047" prio=5 tid=0x14 nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) | |
| at java.util.concurrent.DelayQueue.poll(DelayQueue.java:259) | |
| at kafka.server.ClientQuotaManager$ThrottledRequestReaper.doWork(ClientQuotaManager.scala:158) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| "kafka-coordinator-heartbeat-thread | dl4jgroup@5238" daemon prio=5 tid=0x48 nid=NA waiting for monitor entry | |
| java.lang.Thread.State: BLOCKED | |
| waiting for Camel (camel-1) thread #2 - KafkaConsumer[testkafka]@5237 to release lock on <0x148e> (a org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient) | |
| at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.disableWakeups(ConsumerNetworkClient.java:410) | |
| at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.pollNoWakeup(ConsumerNetworkClient.java:264) | |
| at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:865) | |
| - locked <0x148d> (a org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) | |
| "main-EventThread@4870" daemon prio=5 tid=0x44 nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) | |
| at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) | |
| at org.apache.zookeeper.ClientCnxn$EventThread.run(ClientCnxn.java:494) | |
| "ProcessThread(sid:0 cport:-1):@1132" prio=5 tid=0x10 nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) | |
| at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) | |
| at org.apache.zookeeper.server.PrepRequestProcessor.run(PrepRequestProcessor.java:120) | |
| "SyncThread:0@1129" prio=5 tid=0xf nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) | |
| at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) | |
| at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) | |
| at org.apache.zookeeper.server.SyncRequestProcessor.run(SyncRequestProcessor.java:127) | |
| "ForkJoinPool.commonPool-worker-2@4567" daemon prio=5 tid=0x3e nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.ForkJoinPool.awaitWork(ForkJoinPool.java:1824) | |
| at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1693) | |
| at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:157) | |
| "ForkJoinPool.commonPool-worker-1@4223" daemon prio=5 tid=0x3c nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at sun.misc.Unsafe.park(Unsafe.java:-1) | |
| at java.util.concurrent.ForkJoinPool.awaitWork(ForkJoinPool.java:1824) | |
| at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1693) | |
| at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:157) | |
| "JavaCPP Deallocator@4100" daemon prio=10 tid=0x3a nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at java.lang.Object.wait(Object.java:-1) | |
| at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:143) | |
| at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:164) | |
| at org.bytedeco.javacpp.Pointer$DeallocatorThread.run(Pointer.java:299) | |
| "Workspace deallocator thread@4083" daemon prio=5 tid=0x39 nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at java.lang.Object.wait(Object.java:-1) | |
| at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:143) | |
| at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:164) | |
| at org.nd4j.linalg.memory.provider.BasicWorkspaceManager$WorkspaceDeallocatorThread.run(BasicWorkspaceManager.java:254) | |
| "kafka-coordinator-heartbeat-thread | dl4jgroup@4914" daemon prio=5 tid=0x45 nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at java.lang.Object.wait(Object.java:-1) | |
| at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:884) | |
| "SessionTracker@1118" prio=5 tid=0xe nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at java.lang.Object.wait(Object.java:-1) | |
| at org.apache.zookeeper.server.SessionTrackerImpl.run(SessionTrackerImpl.java:146) | |
| "Finalizer@5259" daemon prio=8 tid=0x3 nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at java.lang.Object.wait(Object.java:-1) | |
| at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:143) | |
| at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:164) | |
| at java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:209) | |
| "Reference Handler@5260" daemon prio=10 tid=0x2 nid=NA waiting | |
| java.lang.Thread.State: WAITING | |
| at java.lang.Object.wait(Object.java:-1) | |
| at java.lang.Object.wait(Object.java:502) | |
| at java.lang.ref.Reference.tryHandlePending(Reference.java:191) | |
| at java.lang.ref.Reference$ReferenceHandler.run(Reference.java:153) | |
| "Signal Dispatcher@5258" daemon prio=9 tid=0x4 nid=NA runnable | |
| java.lang.Thread.State: RUNNABLE | |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment