Created
December 16, 2014 00:26
-
-
Save aspyker/a940c9ec0948cbf20a20 to your computer and use it in GitHub Desktop.
Kafka Snappy Javacore Threaddumps
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
| "kafka-request-handler-7" daemon prio=10 tid=0x00007faeaa591000 nid=0x32a0 runnable [0x00007fad90356000] | |
| java.lang.Thread.State: RUNNABLE | |
| at org.xerial.snappy.SnappyOutputStream.<init>(SnappyOutputStream.java:78) | |
| at org.xerial.snappy.SnappyOutputStream.<init>(SnappyOutputStream.java:66) | |
| at kafka.message.CompressionFactory$.apply(CompressionFactory.scala:33) | |
| at kafka.message.ByteBufferMessageSet$.kafka$message$ByteBufferMessageSet$$create(ByteBufferMessageSet.scala:41) | |
| at kafka.message.ByteBufferMessageSet.<init>(ByteBufferMessageSet.scala:106) | |
| at kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) | |
| at kafka.log.Log.liftedTree1$1(Log.scala:252) | |
| at kafka.log.Log.append(Log.scala:251) | |
| - locked <0x000000070465da60> (a java.lang.Object) | |
| at kafka.cluster.Partition.appendMessagesToLeader(Partition.scala:354) | |
| - locked <0x0000000703231528> (a java.lang.Object) | |
| at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:376) | |
| at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:366) | |
| at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) | |
| at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) | |
| at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) | |
| at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) | |
| at scala.collection.Iterator$class.foreach(Iterator.scala:772) | |
| at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) | |
| at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) | |
| at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) | |
| at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) | |
| at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) | |
| at scala.collection.mutable.HashMap.map(HashMap.scala:45) | |
| at kafka.server.KafkaApis.appendToLocalLog(KafkaApis.scala:366) | |
| at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:292) | |
| at kafka.server.KafkaApis.handle(KafkaApis.scala:185) | |
| at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) | |
| at java.lang.Thread.run(Thread.java:745) | |
| "kafka-request-handler-6" daemon prio=10 tid=0x00007faeaa58f000 nid=0x329f waiting for monitor entry [0x00007fad90457000] | |
| java.lang.Thread.State: BLOCKED (on object monitor) | |
| at kafka.cluster.Partition.appendMessagesToLeader(Partition.scala:349) | |
| - waiting to lock <0x0000000703231528> (a java.lang.Object) | |
| at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:376) | |
| at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:366) | |
| at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) | |
| at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) | |
| at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) | |
| at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) | |
| at scala.collection.Iterator$class.foreach(Iterator.scala:772) | |
| at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) | |
| at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) | |
| at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) | |
| at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) | |
| at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) | |
| at scala.collection.mutable.HashMap.map(HashMap.scala:45) | |
| at kafka.server.KafkaApis.appendToLocalLog(KafkaApis.scala:366) | |
| at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:292) | |
| at kafka.server.KafkaApis.handle(KafkaApis.scala:185) | |
| at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) | |
| at java.lang.Thread.run(Thread.java:745) | |
| "kafka-request-handler-5" daemon prio=10 tid=0x00007faeaa5bd000 nid=0x329e runnable [0x00007fad90558000] | |
| java.lang.Thread.State: RUNNABLE | |
| at scala.collection.mutable.ResizableArray$class.$init$(ResizableArray.scala:33) | |
| at scala.collection.mutable.ArrayBuffer.<init>(ArrayBuffer.scala:47) | |
| at scala.collection.mutable.ArrayBuffer.<init>(ArrayBuffer.scala:61) | |
| at scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) | |
| at scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) | |
| at kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) | |
| at kafka.log.Log.liftedTree1$1(Log.scala:252) | |
| at kafka.log.Log.append(Log.scala:251) | |
| - locked <0x000000070465f868> (a java.lang.Object) | |
| at kafka.cluster.Partition.appendMessagesToLeader(Partition.scala:354) | |
| - locked <0x0000000703231a58> (a java.lang.Object) | |
| at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:376) | |
| at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:366) | |
| at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) | |
| at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) | |
| at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) | |
| at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) | |
| at scala.collection.Iterator$class.foreach(Iterator.scala:772) | |
| at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) | |
| at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) | |
| at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) | |
| at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) | |
| at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) | |
| at scala.collection.mutable.HashMap.map(HashMap.scala:45) | |
| at kafka.server.KafkaApis.appendToLocalLog(KafkaApis.scala:366) | |
| at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:292) | |
| at kafka.server.KafkaApis.handle(KafkaApis.scala:185) | |
| at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) | |
| at java.lang.Thread.run(Thread.java:745) | |
| "kafka-request-handler-4" daemon prio=10 tid=0x00007faeaa5bb000 nid=0x329d runnable [0x00007fad90659000] | |
| java.lang.Thread.State: RUNNABLE | |
| at kafka.cluster.Partition.leaderReplicaIfLocal(Partition.scala:115) | |
| - locked <0x0000000703230ff8> (a java.lang.Object) | |
| at kafka.cluster.Partition.appendMessagesToLeader(Partition.scala:350) | |
| - locked <0x0000000703230ff8> (a java.lang.Object) | |
| at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:376) | |
| at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:366) | |
| at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) | |
| at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) | |
| at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) | |
| at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) | |
| at scala.collection.Iterator$class.foreach(Iterator.scala:772) | |
| at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) | |
| at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) | |
| at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) | |
| at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) | |
| at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) | |
| at scala.collection.mutable.HashMap.map(HashMap.scala:45) | |
| at kafka.server.KafkaApis.appendToLocalLog(KafkaApis.scala:366) | |
| at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:292) | |
| at kafka.server.KafkaApis.handle(KafkaApis.scala:185) | |
| at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) | |
| at java.lang.Thread.run(Thread.java:745) | |
| "kafka-request-handler-3" daemon prio=10 tid=0x00007faeaa5a0000 nid=0x329c waiting for monitor entry [0x00007fad9075a000] | |
| java.lang.Thread.State: BLOCKED (on object monitor) | |
| at kafka.cluster.Partition.appendMessagesToLeader(Partition.scala:349) | |
| - locked <0x0000000703231528> (a java.lang.Object) | |
| at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:376) | |
| at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:366) | |
| at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) | |
| at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) | |
| at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) | |
| at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) | |
| at scala.collection.Iterator$class.foreach(Iterator.scala:772) | |
| at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) | |
| at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) | |
| at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) | |
| at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) | |
| at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) | |
| at scala.collection.mutable.HashMap.map(HashMap.scala:45) | |
| at kafka.server.KafkaApis.appendToLocalLog(KafkaApis.scala:366) | |
| at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:292) | |
| at kafka.server.KafkaApis.handle(KafkaApis.scala:185) | |
| at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) | |
| at java.lang.Thread.run(Thread.java:745) | |
| "kafka-request-handler-2" daemon prio=10 tid=0x00007faeaa59e800 nid=0x329b waiting for monitor entry [0x00007fad9085b000] | |
| java.lang.Thread.State: BLOCKED (on object monitor) | |
| at kafka.cluster.Partition.appendMessagesToLeader(Partition.scala:349) | |
| - waiting to lock <0x0000000703231528> (a java.lang.Object) | |
| at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:376) | |
| at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:366) | |
| at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) | |
| at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) | |
| at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) | |
| at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) | |
| at scala.collection.Iterator$class.foreach(Iterator.scala:772) | |
| at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) | |
| at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) | |
| at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) | |
| at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) | |
| at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) | |
| at scala.collection.mutable.HashMap.map(HashMap.scala:45) | |
| at kafka.server.KafkaApis.appendToLocalLog(KafkaApis.scala:366) | |
| at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:292) | |
| at kafka.server.KafkaApis.handle(KafkaApis.scala:185) | |
| at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) | |
| at java.lang.Thread.run(Thread.java:745) | |
| "kafka-request-handler-1" daemon prio=10 tid=0x00007faeaa5c1000 nid=0x329a waiting for monitor entry [0x00007fad9095c000] | |
| java.lang.Thread.State: BLOCKED (on object monitor) | |
| at kafka.cluster.Partition.appendMessagesToLeader(Partition.scala:349) | |
| - waiting to lock <0x0000000703231528> (a java.lang.Object) | |
| at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:376) | |
| at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:366) | |
| at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) | |
| at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) | |
| at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) | |
| at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) | |
| at scala.collection.Iterator$class.foreach(Iterator.scala:772) | |
| at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) | |
| at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) | |
| at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) | |
| at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) | |
| at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) | |
| at scala.collection.mutable.HashMap.map(HashMap.scala:45) | |
| at kafka.server.KafkaApis.appendToLocalLog(KafkaApis.scala:366) | |
| at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:292) | |
| at kafka.server.KafkaApis.handle(KafkaApis.scala:185) | |
| at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) | |
| at java.lang.Thread.run(Thread.java:745) | |
| "kafka-request-handler-0" daemon prio=10 tid=0x00007faeaa5b1000 nid=0x3299 waiting for monitor entry [0x00007fad90a5d000] | |
| java.lang.Thread.State: BLOCKED (on object monitor) | |
| at kafka.cluster.Partition.appendMessagesToLeader(Partition.scala:349) | |
| - locked <0x0000000703230a78> (a java.lang.Object) | |
| at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:376) | |
| at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:366) | |
| at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) | |
| at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) | |
| at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) | |
| at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) | |
| at scala.collection.Iterator$class.foreach(Iterator.scala:772) | |
| at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) | |
| at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) | |
| at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) | |
| at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) | |
| at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) | |
| at scala.collection.mutable.HashMap.map(HashMap.scala:45) | |
| at kafka.server.KafkaApis.appendToLocalLog(KafkaApis.scala:366) | |
| at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:292) | |
| at kafka.server.KafkaApis.handle(KafkaApis.scala:185) | |
| at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) | |
| at java.lang.Thread.run(Thread.java:745) |
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
| "kafka-request-handler-7" daemon prio=10 tid=0x00007f59ee607800 nid=0x1969 waiting for monitor entry [0x00007f58d90a3000] | |
| java.lang.Thread.State: BLOCKED (on object monitor) | |
| at kafka.cluster.Partition.appendMessagesToLeader(Partition.scala:349) | |
| - waiting to lock <0x0000000716b37f50> (a java.lang.Object) | |
| at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:376) | |
| at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:366) | |
| at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) | |
| at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) | |
| at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) | |
| at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) | |
| at scala.collection.Iterator$class.foreach(Iterator.scala:772) | |
| at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) | |
| at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) | |
| at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) | |
| at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) | |
| at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) | |
| at scala.collection.mutable.HashMap.map(HashMap.scala:45) | |
| at kafka.server.KafkaApis.appendToLocalLog(KafkaApis.scala:366) | |
| at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:292) | |
| at kafka.server.KafkaApis.handle(KafkaApis.scala:185) | |
| at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) | |
| at java.lang.Thread.run(Thread.java:745) | |
| "kafka-request-handler-6" daemon prio=10 tid=0x00007f59ee605800 nid=0x1968 waiting for monitor entry [0x00007f58d91a4000] | |
| java.lang.Thread.State: BLOCKED (on object monitor) | |
| at kafka.cluster.Partition.appendMessagesToLeader(Partition.scala:349) | |
| - waiting to lock <0x0000000716b37f50> (a java.lang.Object) | |
| at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:376) | |
| at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:366) | |
| at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) | |
| at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) | |
| at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) | |
| at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) | |
| at scala.collection.Iterator$class.foreach(Iterator.scala:772) | |
| at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) | |
| at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) | |
| at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) | |
| at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) | |
| at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) | |
| at scala.collection.mutable.HashMap.map(HashMap.scala:45) | |
| at kafka.server.KafkaApis.appendToLocalLog(KafkaApis.scala:366) | |
| at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:292) | |
| at kafka.server.KafkaApis.handle(KafkaApis.scala:185) | |
| at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) | |
| at java.lang.Thread.run(Thread.java:745) | |
| "kafka-request-handler-5" daemon prio=10 tid=0x00007f59ee603800 nid=0x1967 waiting for monitor entry [0x00007f58d92a5000] | |
| java.lang.Thread.State: BLOCKED (on object monitor) | |
| at kafka.cluster.Partition.appendMessagesToLeader(Partition.scala:349) | |
| - waiting to lock <0x0000000716b37f50> (a java.lang.Object) | |
| at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:376) | |
| at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:366) | |
| at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) | |
| at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) | |
| at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) | |
| at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) | |
| at scala.collection.Iterator$class.foreach(Iterator.scala:772) | |
| at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) | |
| at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) | |
| at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) | |
| at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) | |
| at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) | |
| at scala.collection.mutable.HashMap.map(HashMap.scala:45) | |
| at kafka.server.KafkaApis.appendToLocalLog(KafkaApis.scala:366) | |
| at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:292) | |
| at kafka.server.KafkaApis.handle(KafkaApis.scala:185) | |
| at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) | |
| at java.lang.Thread.run(Thread.java:745) | |
| "kafka-request-handler-4" daemon prio=10 tid=0x00007f59ee618000 nid=0x1966 waiting for monitor entry [0x00007f58d93a6000] | |
| java.lang.Thread.State: BLOCKED (on object monitor) | |
| at kafka.cluster.Partition.appendMessagesToLeader(Partition.scala:349) | |
| - waiting to lock <0x0000000716b37f50> (a java.lang.Object) | |
| at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:376) | |
| at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:366) | |
| at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) | |
| at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) | |
| at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) | |
| at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) | |
| at scala.collection.Iterator$class.foreach(Iterator.scala:772) | |
| at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) | |
| at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) | |
| at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) | |
| at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) | |
| at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) | |
| at scala.collection.mutable.HashMap.map(HashMap.scala:45) | |
| at kafka.server.KafkaApis.appendToLocalLog(KafkaApis.scala:366) | |
| at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:292) | |
| at kafka.server.KafkaApis.handle(KafkaApis.scala:185) | |
| at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) | |
| at java.lang.Thread.run(Thread.java:745) | |
| "kafka-request-handler-3" daemon prio=10 tid=0x00007f59ee616800 nid=0x1965 waiting for monitor entry [0x00007f58d94a7000] | |
| java.lang.Thread.State: BLOCKED (on object monitor) | |
| at kafka.cluster.Partition.appendMessagesToLeader(Partition.scala:349) | |
| - waiting to lock <0x0000000716b37f50> (a java.lang.Object) | |
| at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:376) | |
| at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:366) | |
| at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) | |
| at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) | |
| at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) | |
| at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) | |
| at scala.collection.Iterator$class.foreach(Iterator.scala:772) | |
| at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) | |
| at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) | |
| at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) | |
| at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) | |
| at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) | |
| at scala.collection.mutable.HashMap.map(HashMap.scala:45) | |
| at kafka.server.KafkaApis.appendToLocalLog(KafkaApis.scala:366) | |
| at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:292) | |
| at kafka.server.KafkaApis.handle(KafkaApis.scala:185) | |
| at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) | |
| at java.lang.Thread.run(Thread.java:745) | |
| "kafka-request-handler-2" daemon prio=10 tid=0x00007f59ee614800 nid=0x1964 runnable [0x00007f58d95a8000] | |
| java.lang.Thread.State: RUNNABLE | |
| at org.xerial.snappy.SnappyNative.arrayCopy(Native Method) | |
| at org.xerial.snappy.Snappy.arrayCopy(Snappy.java:77) | |
| at org.xerial.snappy.SnappyInputStream.rawRead(SnappyInputStream.java:166) | |
| at org.xerial.snappy.SnappyInputStream.read(SnappyInputStream.java:142) | |
| at java.io.InputStream.read(InputStream.java:101) | |
| at kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply$mcI$sp(ByteBufferMessageSet.scala:68) | |
| at kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply(ByteBufferMessageSet.scala:68) | |
| at kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply(ByteBufferMessageSet.scala:68) | |
| at scala.collection.immutable.Stream$.continually(Stream.scala:1104) | |
| at scala.collection.immutable.Stream$$anonfun$continually$1.apply(Stream.scala:1104) | |
| at scala.collection.immutable.Stream$$anonfun$continually$1.apply(Stream.scala:1104) | |
| at scala.collection.immutable.Stream$Cons.tail(Stream.scala:1060) | |
| - locked <0x000000071b47df68> (a scala.collection.immutable.Stream$Cons) | |
| at scala.collection.immutable.Stream$Cons.tail(Stream.scala:1052) | |
| at scala.collection.immutable.Stream$$anonfun$takeWhile$1.apply(Stream.scala:782) | |
| at scala.collection.immutable.Stream$$anonfun$takeWhile$1.apply(Stream.scala:782) | |
| at scala.collection.immutable.Stream$Cons.tail(Stream.scala:1060) | |
| - locked <0x000000071b47dfa8> (a scala.collection.immutable.Stream$Cons) | |
| at scala.collection.immutable.Stream$Cons.tail(Stream.scala:1052) | |
| at scala.collection.immutable.Stream.foreach(Stream.scala:527) | |
| at kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:68) | |
| at kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:178) | |
| at kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) | |
| at kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) | |
| at kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) | |
| at kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) | |
| at scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) | |
| at scala.collection.Iterator$class.foreach(Iterator.scala:772) | |
| at scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) | |
| at scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) | |
| at scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) | |
| at scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) | |
| at scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) | |
| at kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) | |
| at kafka.log.Log.liftedTree1$1(Log.scala:252) | |
| at kafka.log.Log.append(Log.scala:251) | |
| - locked <0x0000000716b35da0> (a java.lang.Object) | |
| at kafka.cluster.Partition.appendMessagesToLeader(Partition.scala:354) | |
| - locked <0x0000000716b37f50> (a java.lang.Object) | |
| at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:376) | |
| at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:366) | |
| at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) | |
| at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) | |
| at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) | |
| at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) | |
| at scala.collection.Iterator$class.foreach(Iterator.scala:772) | |
| at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) | |
| at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) | |
| at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) | |
| at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) | |
| at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) | |
| at scala.collection.mutable.HashMap.map(HashMap.scala:45) | |
| at kafka.server.KafkaApis.appendToLocalLog(KafkaApis.scala:366) | |
| at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:292) | |
| at kafka.server.KafkaApis.handle(KafkaApis.scala:185) | |
| at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) | |
| at java.lang.Thread.run(Thread.java:745) | |
| "kafka-request-handler-1" daemon prio=10 tid=0x00007f59ee61d000 nid=0x1963 waiting for monitor entry [0x00007f58d96a9000] | |
| java.lang.Thread.State: BLOCKED (on object monitor) | |
| at kafka.cluster.Partition.appendMessagesToLeader(Partition.scala:349) | |
| - waiting to lock <0x0000000716b38420> (a java.lang.Object) | |
| at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:376) | |
| at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:366) | |
| at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) | |
| at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) | |
| at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) | |
| at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) | |
| at scala.collection.Iterator$class.foreach(Iterator.scala:772) | |
| at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) | |
| at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) | |
| at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) | |
| at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) | |
| at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) | |
| at scala.collection.mutable.HashMap.map(HashMap.scala:45) | |
| at kafka.server.KafkaApis.appendToLocalLog(KafkaApis.scala:366) | |
| at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:292) | |
| at kafka.server.KafkaApis.handle(KafkaApis.scala:185) | |
| at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) | |
| at java.lang.Thread.run(Thread.java:745) | |
| "kafka-request-handler-0" daemon prio=10 tid=0x00007f59ee602000 nid=0x1962 runnable [0x00007f58d97aa000] | |
| java.lang.Thread.State: RUNNABLE | |
| at org.xerial.snappy.SnappyNative.arrayCopy(Native Method) | |
| at org.xerial.snappy.Snappy.arrayCopy(Snappy.java:77) | |
| at org.xerial.snappy.SnappyInputStream.rawRead(SnappyInputStream.java:166) | |
| at org.xerial.snappy.SnappyInputStream.read(SnappyInputStream.java:142) | |
| at java.io.InputStream.read(InputStream.java:101) | |
| at kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply$mcI$sp(ByteBufferMessageSet.scala:68) | |
| at kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply(ByteBufferMessageSet.scala:68) | |
| at kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply(ByteBufferMessageSet.scala:68) | |
| at scala.collection.immutable.Stream$.continually(Stream.scala:1104) | |
| at kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:68) | |
| at kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:178) | |
| at kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) | |
| at kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) | |
| at kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) | |
| at kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) | |
| at scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) | |
| at scala.collection.Iterator$class.foreach(Iterator.scala:772) | |
| at scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) | |
| at scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) | |
| at scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) | |
| at scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) | |
| at scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) | |
| at kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) | |
| at kafka.log.Log.liftedTree1$1(Log.scala:252) | |
| at kafka.log.Log.append(Log.scala:251) | |
| - locked <0x0000000716b36498> (a java.lang.Object) | |
| at kafka.cluster.Partition.appendMessagesToLeader(Partition.scala:354) | |
| - locked <0x0000000716b38420> (a java.lang.Object) | |
| at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:376) | |
| at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:366) | |
| at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) | |
| at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) | |
| at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) | |
| at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) | |
| at scala.collection.Iterator$class.foreach(Iterator.scala:772) | |
| at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) | |
| at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) | |
| at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) | |
| at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) | |
| at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) | |
| at scala.collection.mutable.HashMap.map(HashMap.scala:45) | |
| at kafka.server.KafkaApis.appendToLocalLog(KafkaApis.scala:366) | |
| at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:292) | |
| at kafka.server.KafkaApis.handle(KafkaApis.scala:185) | |
| at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) | |
| at java.lang.Thread.run(Thread.java:745) |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment