JAVA PROFILE 1.0.1, created Fri Aug 2 21:40:09 2013 Header for -agentlib:hprof (or -Xrunhprof) ASCII Output (JDK 5.0 JVMTI based) %W% %E% Copyright (c) 2006 Sun Microsystems, Inc. All Rights Reserved. WARNING! This file format is under development, and is subject to change without notice. This file contains the following types of records: THREAD START THREAD END mark the lifetime of Java threads TRACE represents a Java stack trace. Each trace consists of a series of stack frames. Other records refer to TRACEs to identify (1) where object allocations have taken place, (2) the frames in which GC roots were found, and (3) frequently executed methods. HEAP DUMP is a complete snapshot of all live objects in the Java heap. Following distinctions are made: ROOT root set as determined by GC CLS classes OBJ instances ARR arrays SITES is a sorted list of allocation sites. This identifies the most heavily allocated object types, and the TRACE at which those allocations occurred. CPU SAMPLES is a statistical profile of program execution. The VM periodically samples all running threads, and assigns a quantum to active TRACEs in those threads. Entries in this record are TRACEs ranked by the percentage of total quanta they consumed; top-ranked TRACEs are typically hot spots in the program. CPU TIME is a profile of program execution obtained by measuring the time spent in individual methods (excluding the time spent in callees), as well as by counting the number of times each method is called. Entries in this record are TRACEs ranked by the percentage of total CPU time. The "count" field indicates the number of times each TRACE is invoked. MONITOR TIME is a profile of monitor contention obtained by measuring the time spent by a thread waiting to enter a monitor. Entries in this record are TRACEs ranked by the percentage of total monitor contention time and a brief description of the monitor. The "count" field indicates the number of times the monitor was contended at that TRACE. MONITOR DUMP is a complete snapshot of all the monitors and threads in the System. HEAP DUMP, SITES, CPU SAMPLES|TIME and MONITOR DUMP|TIME records are generated at program exit. They can also be obtained during program execution by typing Ctrl-\ (on Solaris) or by typing Ctrl-Break (on Win32). -------- THREAD START (obj=50000150, id = 200001, name="main", group="main") THREAD START (obj=50000494, id = 200004, name="Thread-2", group="main") THREAD START (obj=50000497, id = 200005, name="AWT-Shutdown", group="main") THREAD START (obj=5000077e, id = 200007, name="Thread-4", group="system") THREAD END (id = 200005) THREAD END (id = 200007) THREAD START (obj=50000497, id = 200008, name="AWT-Shutdown", group="main") THREAD END (id = 200008) THREAD START (obj=5000077e, id = 200009, name="Thread-5", group="system") THREAD END (id = 200009) THREAD START (obj=5000079f, id = 200010, name="Thread-6", group="main") THREAD END (id = 200010) THREAD START (obj=5000077e, id = 200011, name="AWT-Shutdown", group="main") THREAD END (id = 200011) THREAD START (obj=500007a8, id = 200012, name="Thread-7", group="system") THREAD END (id = 200012) THREAD START (obj=5000077e, id = 200013, name="kafka-scheduler-0", group="main") THREAD START (obj=500007a8, id = 200014, name="metrics-meter-tick-thread-1", group="main") THREAD START (obj=500007e7, id = 200015, name="AWT-Shutdown", group="main") THREAD END (id = 200015) THREAD START (obj=500007e8, id = 200016, name="Thread-8", group="system") THREAD END (id = 200016) THREAD START (obj=500007e7, id = 200017, name="AWT-Shutdown", group="main") THREAD END (id = 200017) THREAD START (obj=500007e8, id = 200018, name="Thread-9", group="system") THREAD END (id = 200018) THREAD START (obj=500007e7, id = 200019, name="AWT-Shutdown", group="main") THREAD END (id = 200019) THREAD START (obj=500007e8, id = 200020, name="Thread-10", group="system") THREAD END (id = 200020) THREAD END (id = 200013) THREAD END (id = 200001) THREAD START (obj=500007ea, id = 200021, name="DestroyJavaVM", group="main") THREAD START (obj=500007e7, id = 200022, name="Thread-3", group="main") THREAD START (obj=500007ed, id = 200023, name="Thread-1", group="main") THREAD END (id = 200023) THREAD END (id = 200022) THREAD END (id = 200021) TRACE 301044: org.xerial.snappy.SnappyNative.arrayCopy(SnappyNative.java:Unknown line) org.xerial.snappy.Snappy.arrayCopy(Snappy.java:73) org.xerial.snappy.SnappyInputStream.rawRead(SnappyInputStream.java:165) org.xerial.snappy.SnappyInputStream.read(SnappyInputStream.java:142) java.io.InputStream.read(InputStream.java:82) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply$mcI$sp(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply(ByteBufferMessageSet.scala:68) scala.collection.immutable.Stream$.continually(Stream.scala:1104) scala.collection.immutable.Stream$$anonfun$continually$1.apply(Stream.scala:1104) scala.collection.immutable.Stream$$anonfun$continually$1.apply(Stream.scala:1104) scala.collection.immutable.Stream$Cons.tail(Stream.scala:1060) scala.collection.immutable.Stream$Cons.tail(Stream.scala:1052) scala.collection.immutable.Stream$$anonfun$takeWhile$1.apply(Stream.scala:782) scala.collection.immutable.Stream$$anonfun$takeWhile$1.apply(Stream.scala:782) scala.collection.immutable.Stream$Cons.tail(Stream.scala:1060) scala.collection.immutable.Stream$Cons.tail(Stream.scala:1052) scala.collection.immutable.Stream.foreach(Stream.scala:527) kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:178) TRACE 301073: java.util.Arrays.copyOf(Arrays.java:2786) java.io.ByteArrayOutputStream.write(ByteArrayOutputStream.java:94) kafka.message.ByteBufferMessageSet$$anonfun$decompress$3.apply$mcVI$sp(ByteBufferMessageSet.scala:69) kafka.message.ByteBufferMessageSet$$anonfun$decompress$3.apply(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anonfun$decompress$3.apply(ByteBufferMessageSet.scala:68) scala.collection.immutable.Stream.foreach(Stream.scala:526) kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:178) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) TRACE 301053: org.xerial.snappy.SnappyNative.rawCompress(SnappyNative.java:Unknown line) org.xerial.snappy.Snappy.rawCompress(Snappy.java:358) org.xerial.snappy.Snappy.compress(Snappy.java:106) org.xerial.snappy.SnappyOutputStream.dump(SnappyOutputStream.java:295) org.xerial.snappy.SnappyOutputStream.rawWrite(SnappyOutputStream.java:244) org.xerial.snappy.SnappyOutputStream.write(SnappyOutputStream.java:99) java.io.DataOutputStream.write(DataOutputStream.java:90) kafka.message.ByteBufferMessageSet$$anonfun$kafka$message$ByteBufferMessageSet$$create$2.apply(ByteBufferMessageSet.scala:48) kafka.message.ByteBufferMessageSet$$anonfun$kafka$message$ByteBufferMessageSet$$create$2.apply(ByteBufferMessageSet.scala:44) scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:60) scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47) kafka.message.ByteBufferMessageSet$.kafka$message$ByteBufferMessageSet$$create(ByteBufferMessageSet.scala:44) kafka.message.ByteBufferMessageSet.(ByteBufferMessageSet.scala:106) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301084: org.xerial.snappy.SnappyNative.rawUncompress(SnappyNative.java:Unknown line) org.xerial.snappy.Snappy.rawUncompress(Snappy.java:391) org.xerial.snappy.Snappy.uncompress(Snappy.java:427) org.xerial.snappy.SnappyInputStream.hasNextChunk(SnappyInputStream.java:354) org.xerial.snappy.SnappyInputStream.rawRead(SnappyInputStream.java:158) org.xerial.snappy.SnappyInputStream.read(SnappyInputStream.java:142) java.io.InputStream.read(InputStream.java:82) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply$mcI$sp(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply(ByteBufferMessageSet.scala:68) scala.collection.immutable.Stream$.continually(Stream.scala:1104) scala.collection.immutable.Stream$$anonfun$continually$1.apply(Stream.scala:1104) scala.collection.immutable.Stream$$anonfun$continually$1.apply(Stream.scala:1104) scala.collection.immutable.Stream$Cons.tail(Stream.scala:1060) scala.collection.immutable.Stream$Cons.tail(Stream.scala:1052) scala.collection.immutable.Stream$$anonfun$takeWhile$1.apply(Stream.scala:782) scala.collection.immutable.Stream$$anonfun$takeWhile$1.apply(Stream.scala:782) scala.collection.immutable.Stream$Cons.tail(Stream.scala:1060) scala.collection.immutable.Stream$Cons.tail(Stream.scala:1052) scala.collection.immutable.Stream.foreach(Stream.scala:527) TRACE 301063: java.io.ByteArrayOutputStream.(ByteArrayOutputStream.java:60) kafka.message.ByteBufferMessageSet$.kafka$message$ByteBufferMessageSet$$create(ByteBufferMessageSet.scala:40) kafka.message.ByteBufferMessageSet.(ByteBufferMessageSet.scala:106) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301090: sun.nio.ch.FileDispatcher.write0(FileDispatcher.java:Unknown line) sun.nio.ch.FileDispatcher.write(FileDispatcher.java:39) sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:69) sun.nio.ch.IOUtil.write(IOUtil.java:40) sun.nio.ch.FileChannelImpl.write(FileChannelImpl.java:198) kafka.message.ByteBufferMessageSet.writeTo(ByteBufferMessageSet.scala:132) kafka.log.FileMessageSet.append(FileMessageSet.scala:203) kafka.log.LogSegment.append(LogSegment.scala:80) kafka.log.Log.append(Log.scala:271) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301074: java.nio.HeapByteBuffer.(HeapByteBuffer.java:39) java.nio.ByteBuffer.allocate(ByteBuffer.java:312) kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:74) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:178) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) TRACE 301049: java.util.Arrays.copyOf(Arrays.java:2786) java.io.ByteArrayOutputStream.toByteArray(ByteArrayOutputStream.java:133) kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:75) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:178) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) TRACE 301070: org.xerial.snappy.SnappyNative.arrayCopy(SnappyNative.java:Unknown line) org.xerial.snappy.Snappy.arrayCopy(Snappy.java:73) org.xerial.snappy.SnappyOutputStream.rawWrite(SnappyOutputStream.java:239) org.xerial.snappy.SnappyOutputStream.write(SnappyOutputStream.java:99) java.io.DataOutputStream.write(DataOutputStream.java:90) kafka.message.ByteBufferMessageSet$$anonfun$kafka$message$ByteBufferMessageSet$$create$2.apply(ByteBufferMessageSet.scala:48) kafka.message.ByteBufferMessageSet$$anonfun$kafka$message$ByteBufferMessageSet$$create$2.apply(ByteBufferMessageSet.scala:44) scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:60) scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47) kafka.message.ByteBufferMessageSet$.kafka$message$ByteBufferMessageSet$$create(ByteBufferMessageSet.scala:44) kafka.message.ByteBufferMessageSet.(ByteBufferMessageSet.scala:106) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301068: org.xerial.snappy.SnappyNative.rawUncompress(SnappyNative.java:Unknown line) org.xerial.snappy.Snappy.rawUncompress(Snappy.java:391) org.xerial.snappy.Snappy.uncompress(Snappy.java:427) org.xerial.snappy.SnappyInputStream.hasNextChunk(SnappyInputStream.java:354) org.xerial.snappy.SnappyInputStream.rawRead(SnappyInputStream.java:158) org.xerial.snappy.SnappyInputStream.read(SnappyInputStream.java:142) java.io.InputStream.read(InputStream.java:82) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply$mcI$sp(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply(ByteBufferMessageSet.scala:68) scala.collection.immutable.Stream$.continually(Stream.scala:1104) kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:178) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) TRACE 301065: org.xerial.snappy.SnappyNative.arrayCopy(SnappyNative.java:Unknown line) org.xerial.snappy.Snappy.arrayCopy(Snappy.java:73) org.xerial.snappy.SnappyOutputStream.rawWrite(SnappyOutputStream.java:239) org.xerial.snappy.SnappyOutputStream.write(SnappyOutputStream.java:99) java.io.DataOutputStream.writeLong(DataOutputStream.java:207) kafka.message.ByteBufferMessageSet$$anonfun$kafka$message$ByteBufferMessageSet$$create$2.apply(ByteBufferMessageSet.scala:46) kafka.message.ByteBufferMessageSet$$anonfun$kafka$message$ByteBufferMessageSet$$create$2.apply(ByteBufferMessageSet.scala:44) scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:60) scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47) kafka.message.ByteBufferMessageSet$.kafka$message$ByteBufferMessageSet$$create(ByteBufferMessageSet.scala:44) kafka.message.ByteBufferMessageSet.(ByteBufferMessageSet.scala:106) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301089: java.nio.HeapByteBuffer.(HeapByteBuffer.java:39) java.nio.ByteBuffer.allocate(ByteBuffer.java:312) kafka.message.ByteBufferMessageSet$.kafka$message$ByteBufferMessageSet$$create(ByteBufferMessageSet.scala:55) kafka.message.ByteBufferMessageSet.(ByteBufferMessageSet.scala:106) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301103: kafka.message.ByteBufferMessageSet$$anon$1.innerIter(ByteBufferMessageSet.scala:147) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:193) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301100: org.xerial.snappy.SnappyNative.rawCompress(SnappyNative.java:Unknown line) org.xerial.snappy.Snappy.rawCompress(Snappy.java:358) org.xerial.snappy.Snappy.compress(Snappy.java:106) org.xerial.snappy.SnappyOutputStream.dump(SnappyOutputStream.java:295) org.xerial.snappy.SnappyOutputStream.flush(SnappyOutputStream.java:271) java.io.DataOutputStream.flush(DataOutputStream.java:106) java.io.FilterOutputStream.close(FilterOutputStream.java:140) kafka.message.ByteBufferMessageSet$.kafka$message$ByteBufferMessageSet$$create(ByteBufferMessageSet.scala:51) kafka.message.ByteBufferMessageSet.(ByteBufferMessageSet.scala:106) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301137: kafka.message.ByteBufferMessageSet$$anonfun$decompress$3.apply$mcVI$sp(ByteBufferMessageSet.scala:69) kafka.message.ByteBufferMessageSet$$anonfun$decompress$3.apply(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anonfun$decompress$3.apply(ByteBufferMessageSet.scala:68) scala.collection.immutable.Stream.foreach(Stream.scala:526) kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:178) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) TRACE 301152: kafka.message.ByteBufferMessageSet$$anon$1.innerIter(ByteBufferMessageSet.scala:147) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:193) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301086: org.xerial.snappy.SnappyOutputStream.(SnappyOutputStream.java:78) org.xerial.snappy.SnappyOutputStream.(SnappyOutputStream.java:66) kafka.message.CompressionFactory$.apply(CompressionFactory.scala:33) kafka.message.ByteBufferMessageSet$.kafka$message$ByteBufferMessageSet$$create(ByteBufferMessageSet.scala:41) kafka.message.ByteBufferMessageSet.(ByteBufferMessageSet.scala:106) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301139: org.xerial.snappy.SnappyInputStream.hasNextChunk(SnappyInputStream.java:352) org.xerial.snappy.SnappyInputStream.rawRead(SnappyInputStream.java:158) org.xerial.snappy.SnappyInputStream.read(SnappyInputStream.java:142) java.io.InputStream.read(InputStream.java:82) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply$mcI$sp(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply(ByteBufferMessageSet.scala:68) scala.collection.immutable.Stream$.continually(Stream.scala:1104) kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:178) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) TRACE 301138: org.xerial.snappy.SnappyInputStream.hasNextChunk(SnappyInputStream.java:337) org.xerial.snappy.SnappyInputStream.rawRead(SnappyInputStream.java:158) org.xerial.snappy.SnappyInputStream.read(SnappyInputStream.java:142) java.io.InputStream.read(InputStream.java:82) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply$mcI$sp(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply(ByteBufferMessageSet.scala:68) scala.collection.immutable.Stream$.continually(Stream.scala:1104) kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:178) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) TRACE 301149: org.xerial.snappy.SnappyOutputStream.(SnappyOutputStream.java:79) org.xerial.snappy.SnappyOutputStream.(SnappyOutputStream.java:66) kafka.message.CompressionFactory$.apply(CompressionFactory.scala:33) kafka.message.ByteBufferMessageSet$.kafka$message$ByteBufferMessageSet$$create(ByteBufferMessageSet.scala:41) kafka.message.ByteBufferMessageSet.(ByteBufferMessageSet.scala:106) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301174: java.nio.ByteBuffer.put(ByteBuffer.java:813) kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:75) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:178) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301104: java.lang.Thread.isInterrupted(Thread.java:Unknown line) java.lang.Thread.isInterrupted(Thread.java:951) java.nio.channels.spi.AbstractInterruptibleChannel.begin(AbstractInterruptibleChannel.java:153) sun.nio.ch.FileChannelImpl.write(FileChannelImpl.java:191) kafka.message.ByteBufferMessageSet.writeTo(ByteBufferMessageSet.scala:132) kafka.log.FileMessageSet.append(FileMessageSet.scala:203) kafka.log.LogSegment.append(LogSegment.scala:80) kafka.log.Log.append(Log.scala:271) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301085: org.xerial.snappy.SnappyNative.uncompressedLength(SnappyNative.java:Unknown line) org.xerial.snappy.Snappy.uncompressedLength(Snappy.java:541) org.xerial.snappy.SnappyInputStream.hasNextChunk(SnappyInputStream.java:350) org.xerial.snappy.SnappyInputStream.rawRead(SnappyInputStream.java:158) org.xerial.snappy.SnappyInputStream.read(SnappyInputStream.java:142) java.io.InputStream.read(InputStream.java:82) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply$mcI$sp(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply(ByteBufferMessageSet.scala:68) scala.collection.immutable.Stream$.continually(Stream.scala:1104) kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:178) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) TRACE 301064: kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:65) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:178) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301133: java.nio.HeapByteBuffer.(HeapByteBuffer.java:39) java.nio.ByteBuffer.allocate(ByteBuffer.java:312) kafka.message.Message.(Message.scala:99) kafka.message.Message.(Message.scala:134) kafka.message.Message.(Message.scala:137) kafka.message.ByteBufferMessageSet$.kafka$message$ByteBufferMessageSet$$create(ByteBufferMessageSet.scala:54) kafka.message.ByteBufferMessageSet.(ByteBufferMessageSet.scala:106) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301226: sun.nio.ch.FileChannelImpl.force0(FileChannelImpl.java:Unknown line) sun.nio.ch.FileChannelImpl.force(FileChannelImpl.java:348) kafka.log.FileMessageSet.flush(FileMessageSet.scala:211) kafka.log.LogSegment$$anonfun$flush$1.apply$mcV$sp(LogSegment.scala:238) kafka.log.LogSegment$$anonfun$flush$1.apply(LogSegment.scala:237) kafka.log.LogSegment$$anonfun$flush$1.apply(LogSegment.scala:237) kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33) kafka.log.LogSegment.flush(LogSegment.scala:237) kafka.log.Log$$anonfun$flush$2.apply(Log.scala:511) kafka.log.Log$$anonfun$flush$2.apply(Log.scala:510) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.JavaConversions$JIteratorWrapper.foreach(JavaConversions.scala:573) scala.collection.IterableLike$class.foreach(IterableLike.scala:73) scala.collection.JavaConversions$JCollectionWrapper.foreach(JavaConversions.scala:592) kafka.log.Log.flush(Log.scala:510) kafka.log.Log$$anonfun$roll$1.apply$mcV$sp(Log.scala:483) kafka.utils.KafkaScheduler$$anon$1.run(KafkaScheduler.scala:100) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439) java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303) java.util.concurrent.FutureTask.run(FutureTask.java:138) TRACE 300491: java.lang.ClassLoader$NativeLibrary.load(ClassLoader.java:Unknown line) java.lang.ClassLoader.loadLibrary0(ClassLoader.java:1827) java.lang.ClassLoader.loadLibrary(ClassLoader.java:1724) java.lang.Runtime.loadLibrary0(Runtime.java:823) java.lang.System.loadLibrary(System.java:1045) sun.security.action.LoadLibraryAction.run(LoadLibraryAction.java:50) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.awt.Toolkit.loadLibraries(Toolkit.java:1605) java.awt.Toolkit.(Toolkit.java:1627) sun.awt.AppContext$2.run(AppContext.java:237) sun.awt.AppContext$2.run(AppContext.java:226) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) sun.awt.AppContext.initMainAppContext(AppContext.java:226) sun.awt.AppContext.access$200(AppContext.java:112) sun.awt.AppContext$3.run(AppContext.java:299) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) sun.awt.AppContext.getAppContext(AppContext.java:280) com.sun.jmx.trace.Trace.out(Trace.java:180) com.sun.jmx.trace.Trace.isSelected(Trace.java:88) com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.isTraceOn(DefaultMBeanServerInterceptor.java:1830) TRACE 301175: org.xerial.snappy.SnappyNative.uncompressedLength(SnappyNative.java:Unknown line) org.xerial.snappy.Snappy.uncompressedLength(Snappy.java:541) org.xerial.snappy.SnappyInputStream.hasNextChunk(SnappyInputStream.java:350) org.xerial.snappy.SnappyInputStream.rawRead(SnappyInputStream.java:158) org.xerial.snappy.SnappyInputStream.read(SnappyInputStream.java:142) java.io.InputStream.read(InputStream.java:82) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply$mcI$sp(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply(ByteBufferMessageSet.scala:68) scala.collection.immutable.Stream$.continually(Stream.scala:1104) scala.collection.immutable.Stream$$anonfun$continually$1.apply(Stream.scala:1104) scala.collection.immutable.Stream$$anonfun$continually$1.apply(Stream.scala:1104) scala.collection.immutable.Stream$Cons.tail(Stream.scala:1060) scala.collection.immutable.Stream$Cons.tail(Stream.scala:1052) scala.collection.immutable.Stream$$anonfun$takeWhile$1.apply(Stream.scala:782) scala.collection.immutable.Stream$$anonfun$takeWhile$1.apply(Stream.scala:782) scala.collection.immutable.Stream$Cons.tail(Stream.scala:1060) scala.collection.immutable.Stream$Cons.tail(Stream.scala:1052) scala.collection.immutable.Stream.foreach(Stream.scala:527) kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:68) TRACE 300024: java.util.zip.ZipFile.open(ZipFile.java:Unknown line) java.util.zip.ZipFile.(ZipFile.java:128) java.util.jar.JarFile.(JarFile.java:136) java.util.jar.JarFile.(JarFile.java:73) sun.misc.URLClassPath$JarLoader.getJarFile(URLClassPath.java:661) sun.misc.URLClassPath$JarLoader.access$600(URLClassPath.java:544) sun.misc.URLClassPath$JarLoader$1.run(URLClassPath.java:613) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) sun.misc.URLClassPath$JarLoader.ensureOpen(URLClassPath.java:605) sun.misc.URLClassPath$JarLoader.(URLClassPath.java:589) sun.misc.URLClassPath$3.run(URLClassPath.java:337) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) sun.misc.URLClassPath.getLoader(URLClassPath.java:326) sun.misc.URLClassPath.getLoader(URLClassPath.java:303) sun.misc.URLClassPath.getResource(URLClassPath.java:172) java.net.URLClassLoader$1.run(URLClassLoader.java:194) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findClass(URLClassLoader.java:190) sun.misc.Launcher$ExtClassLoader.findClass(Launcher.java:229) java.lang.ClassLoader.loadClass(ClassLoader.java:306) TRACE 301155: java.lang.Integer.valueOf(Integer.java:625) scala.runtime.BoxesRunTime.boxToInteger(:Unknown line) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply(ByteBufferMessageSet.scala:68) scala.collection.immutable.Stream$.continually(Stream.scala:1104) scala.collection.immutable.Stream$$anonfun$continually$1.apply(Stream.scala:1104) scala.collection.immutable.Stream$$anonfun$continually$1.apply(Stream.scala:1104) scala.collection.immutable.Stream$Cons.tail(Stream.scala:1060) scala.collection.immutable.Stream$Cons.tail(Stream.scala:1052) scala.collection.immutable.Stream$$anonfun$takeWhile$1.apply(Stream.scala:782) scala.collection.immutable.Stream$$anonfun$takeWhile$1.apply(Stream.scala:782) scala.collection.immutable.Stream$Cons.tail(Stream.scala:1060) scala.collection.immutable.Stream$Cons.tail(Stream.scala:1052) scala.collection.immutable.Stream.foreach(Stream.scala:527) kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:178) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) TRACE 301081: java.lang.Thread.currentThread(Thread.java:Unknown line) java.nio.channels.spi.AbstractInterruptibleChannel.begin(AbstractInterruptibleChannel.java:153) sun.nio.ch.FileChannelImpl.write(FileChannelImpl.java:191) kafka.message.ByteBufferMessageSet.writeTo(ByteBufferMessageSet.scala:132) kafka.log.FileMessageSet.append(FileMessageSet.scala:203) kafka.log.LogSegment.append(LogSegment.scala:80) kafka.log.Log.append(Log.scala:271) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301076: org.xerial.snappy.SnappyInputStream.(SnappyInputStream.java:48) kafka.message.CompressionFactory$.apply(CompressionFactory.scala:45) kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:66) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:178) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) TRACE 301173: java.util.Arrays.copyOf(Arrays.java:2786) java.io.ByteArrayOutputStream.toByteArray(ByteArrayOutputStream.java:133) kafka.message.ByteBufferMessageSet$.kafka$message$ByteBufferMessageSet$$create(ByteBufferMessageSet.scala:53) kafka.message.ByteBufferMessageSet.(ByteBufferMessageSet.scala:106) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301061: java.lang.System.arraycopy(System.java:Unknown line) java.nio.HeapByteBuffer.put(HeapByteBuffer.java:166) java.nio.ByteBuffer.put(ByteBuffer.java:813) kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:75) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:178) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) TRACE 301227: org.xerial.snappy.SnappyInputStream.readHeader(SnappyInputStream.java:92) org.xerial.snappy.SnappyInputStream.(SnappyInputStream.java:58) kafka.message.CompressionFactory$.apply(CompressionFactory.scala:45) kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:66) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:178) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) TRACE 301136: java.lang.System.nanoTime(System.java:Unknown line) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:139) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 300935: java.io.UnixFileSystem.delete0(UnixFileSystem.java:Unknown line) java.io.UnixFileSystem.delete(UnixFileSystem.java:251) java.io.File.delete(File.java:904) kafka.utils.Utils$.rm(Utils.scala:236) kafka.utils.Utils$$anonfun$rm$2.apply(Utils.scala:232) kafka.utils.Utils$$anonfun$rm$2.apply(Utils.scala:231) scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:34) scala.collection.mutable.ArrayOps.foreach(ArrayOps.scala:38) kafka.utils.Utils$.rm(Utils.scala:231) kafka.TestLinearWriteSpeed$LogWritable.(TestLinearWriteSpeed.scala:202) kafka.TestLinearWriteSpeed$$anonfun$main$1.apply$mcVI$sp(TestLinearWriteSpeed.scala:119) scala.collection.immutable.Range.foreach$mVc$sp(Range.scala:81) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:112) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301147: org.xerial.snappy.SnappyNative.arrayCopy(SnappyNative.java:Unknown line) org.xerial.snappy.Snappy.arrayCopy(Snappy.java:73) org.xerial.snappy.SnappyInputStream.rawRead(SnappyInputStream.java:165) org.xerial.snappy.SnappyInputStream.read(SnappyInputStream.java:142) java.io.InputStream.read(InputStream.java:82) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply$mcI$sp(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply(ByteBufferMessageSet.scala:68) scala.collection.immutable.Stream$.continually(Stream.scala:1104) kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:178) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) TRACE 301243: kafka.log.Log.analyzeAndValidateMessageSet(Log.scala:337) kafka.log.Log.append(Log.scala:230) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301075: java.io.DataInputStream.(DataInputStream.java:41) org.xerial.snappy.SnappyCodec.readHeader(SnappyCodec.java:92) org.xerial.snappy.SnappyInputStream.readHeader(SnappyInputStream.java:92) org.xerial.snappy.SnappyInputStream.(SnappyInputStream.java:58) kafka.message.CompressionFactory$.apply(CompressionFactory.scala:45) kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:66) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:178) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) TRACE 301141: scala.collection.mutable.ResizableArray$class.$init$(ResizableArray.scala:33) scala.collection.mutable.ArrayBuffer.(ArrayBuffer.scala:47) scala.collection.mutable.ArrayBuffer.(ArrayBuffer.scala:61) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301079: java.lang.Thread.currentThread(Thread.java:Unknown line) java.nio.channels.spi.AbstractInterruptibleChannel.blockedOn(AbstractInterruptibleChannel.java:191) java.nio.channels.spi.AbstractInterruptibleChannel.begin(AbstractInterruptibleChannel.java:152) sun.nio.ch.FileChannelImpl.write(FileChannelImpl.java:191) kafka.message.ByteBufferMessageSet.writeTo(ByteBufferMessageSet.scala:132) kafka.log.FileMessageSet.append(FileMessageSet.scala:203) kafka.log.LogSegment.append(LogSegment.scala:80) kafka.log.Log.append(Log.scala:271) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301099: scala.collection.IndexedSeqOptimized$class.foldLeft(IndexedSeqOptimized.scala:61) scala.collection.mutable.ArrayBuffer.foldLeft(ArrayBuffer.scala:47) kafka.message.MessageSet$.messageSetSize(MessageSet.scala:37) kafka.message.ByteBufferMessageSet$.kafka$message$ByteBufferMessageSet$$create(ByteBufferMessageSet.scala:40) kafka.message.ByteBufferMessageSet.(ByteBufferMessageSet.scala:106) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301101: java.lang.System.currentTimeMillis(System.java:Unknown line) kafka.utils.SystemTime$.milliseconds(Time.scala:55) kafka.log.Log.maybeRoll(Log.scala:438) kafka.log.Log.append(Log.scala:245) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301182: kafka.message.CompressionFactory$.apply(CompressionFactory.scala:45) kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:66) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:178) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301237: kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:190) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301178: org.xerial.snappy.SnappyNative.maxCompressedLength(SnappyNative.java:Unknown line) org.xerial.snappy.Snappy.maxCompressedLength(Snappy.java:316) org.xerial.snappy.SnappyOutputStream.(SnappyOutputStream.java:79) org.xerial.snappy.SnappyOutputStream.(SnappyOutputStream.java:66) kafka.message.CompressionFactory$.apply(CompressionFactory.scala:33) kafka.message.ByteBufferMessageSet$.kafka$message$ByteBufferMessageSet$$create(ByteBufferMessageSet.scala:41) kafka.message.ByteBufferMessageSet.(ByteBufferMessageSet.scala:106) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301083: java.lang.System.nanoTime(System.java:Unknown line) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:137) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301162: kafka.utils.Utils$.crc32(Utils.scala:333) kafka.message.Message.computeChecksum(Message.scala:149) kafka.message.Message.isValid(Message.scala:159) kafka.message.Message.ensureValid(Message.scala:165) kafka.log.Log$$anonfun$analyzeAndValidateMessageSet$1.apply(Log.scala:330) kafka.log.Log$$anonfun$analyzeAndValidateMessageSet$1.apply(Log.scala:318) scala.collection.Iterator$class.foreach(Iterator.scala:772) kafka.utils.IteratorTemplate.foreach(IteratorTemplate.scala:32) kafka.log.Log.analyzeAndValidateMessageSet(Log.scala:318) kafka.log.Log.append(Log.scala:230) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301239: kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:179) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) TRACE 301240: kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301179: kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:190) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) kafka.message.ByteBufferMessageSet$$anon$1.innerDone(ByteBufferMessageSet.scala:149) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:190) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) TRACE 301132: java.lang.System.arraycopy(System.java:Unknown line) java.nio.HeapByteBuffer.put(HeapByteBuffer.java:183) kafka.message.ByteBufferMessageSet$.writeMessage(ByteBufferMessageSet.scala:83) kafka.message.ByteBufferMessageSet$.kafka$message$ByteBufferMessageSet$$create(ByteBufferMessageSet.scala:56) kafka.message.ByteBufferMessageSet.(ByteBufferMessageSet.scala:106) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301102: java.lang.System.arraycopy(System.java:Unknown line) java.nio.HeapByteBuffer.put(HeapByteBuffer.java:166) kafka.message.Message.(Message.scala:126) kafka.message.Message.(Message.scala:134) kafka.message.Message.(Message.scala:137) kafka.message.ByteBufferMessageSet$.kafka$message$ByteBufferMessageSet$$create(ByteBufferMessageSet.scala:54) kafka.message.ByteBufferMessageSet.(ByteBufferMessageSet.scala:106) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301235: kafka.log.Log.maybeRoll(Log.scala:439) kafka.log.Log.append(Log.scala:245) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 300229: java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:631) java.lang.ClassLoader.defineClass(ClassLoader.java:615) java.security.SecureClassLoader.defineClass(SecureClassLoader.java:141) java.net.URLClassLoader.defineClass(URLClassLoader.java:283) java.net.URLClassLoader.access$000(URLClassLoader.java:58) java.net.URLClassLoader$1.run(URLClassLoader.java:197) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findClass(URLClassLoader.java:190) java.lang.ClassLoader.loadClass(ClassLoader.java:306) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:247) java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:631) java.lang.ClassLoader.defineClass(ClassLoader.java:615) java.security.SecureClassLoader.defineClass(SecureClassLoader.java:141) java.net.URLClassLoader.defineClass(URLClassLoader.java:283) java.net.URLClassLoader.access$000(URLClassLoader.java:58) java.net.URLClassLoader$1.run(URLClassLoader.java:197) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) TRACE 301233: kafka.log.Log.append(Log.scala:230) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301251: scala.collection.immutable.Stream.takeWhile(Stream.scala:782) scala.collection.immutable.Stream$$anonfun$takeWhile$1.apply(Stream.scala:782) scala.collection.immutable.Stream$$anonfun$takeWhile$1.apply(Stream.scala:782) scala.collection.immutable.Stream$Cons.tail(Stream.scala:1060) scala.collection.immutable.Stream$Cons.tail(Stream.scala:1052) scala.collection.immutable.Stream.foreach(Stream.scala:527) kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:178) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) TRACE 301134: java.util.concurrent.ConcurrentSkipListMap$Node.isBaseHeader(ConcurrentSkipListMap.java:440) java.util.concurrent.ConcurrentSkipListMap.findLast(ConcurrentSkipListMap.java:1231) java.util.concurrent.ConcurrentSkipListMap.lastEntry(ConcurrentSkipListMap.java:2172) kafka.log.Log.activeSegment(Log.scala:581) kafka.log.Log.maybeRoll(Log.scala:436) kafka.log.Log.append(Log.scala:245) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301135: sun.misc.Unsafe.putInt(Unsafe.java:Unknown line) java.nio.DirectByteBuffer.putInt(DirectByteBuffer.java:678) java.nio.DirectByteBuffer.putInt(DirectByteBuffer.java:690) kafka.log.OffsetIndex.append(OffsetIndex.scala:196) kafka.log.LogSegment.append(LogSegment.scala:76) kafka.log.Log.append(Log.scala:271) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301051: scala.collection.mutable.ArrayBuffer.size0(ArrayBuffer.scala:47) scala.collection.mutable.ArrayBuffer.$plus$eq(ArrayBuffer.scala:84) scala.collection.mutable.ArrayBuffer.$plus$eq(ArrayBuffer.scala:47) scala.collection.generic.Growable$$anonfun$$plus$plus$eq$1.apply(Growable.scala:48) scala.collection.generic.Growable$$anonfun$$plus$plus$eq$1.apply(Growable.scala:48) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301050: java.lang.System.arraycopy(System.java:Unknown line) java.io.ByteArrayOutputStream.write(ByteArrayOutputStream.java:96) kafka.message.ByteBufferMessageSet$$anonfun$decompress$3.apply$mcVI$sp(ByteBufferMessageSet.scala:69) kafka.message.ByteBufferMessageSet$$anonfun$decompress$3.apply(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anonfun$decompress$3.apply(ByteBufferMessageSet.scala:68) scala.collection.immutable.Stream.foreach(Stream.scala:526) kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:178) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) TRACE 301048: scala.collection.mutable.ArrayBuffer.size0(ArrayBuffer.scala:47) scala.collection.mutable.ArrayBuffer.$plus$eq(ArrayBuffer.scala:82) scala.collection.mutable.ArrayBuffer.$plus$eq(ArrayBuffer.scala:47) scala.collection.generic.Growable$$anonfun$$plus$plus$eq$1.apply(Growable.scala:48) scala.collection.generic.Growable$$anonfun$$plus$plus$eq$1.apply(Growable.scala:48) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301157: kafka.log.Log.maybeRoll(Log.scala:437) kafka.log.Log.append(Log.scala:245) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301156: kafka.log.OffsetIndex.append(OffsetIndex.scala:197) kafka.log.LogSegment.append(LogSegment.scala:76) kafka.log.Log.append(Log.scala:271) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301153: scala.collection.mutable.ArrayBuffer.initialSize(ArrayBuffer.scala:47) scala.collection.mutable.ResizableArray$class.$init$(ResizableArray.scala:33) scala.collection.mutable.ArrayBuffer.(ArrayBuffer.scala:47) scala.collection.mutable.ArrayBuffer.(ArrayBuffer.scala:61) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301181: scala.runtime.BoxesRunTime.equals2(:Unknown line) scala.runtime.BoxesRunTime.equals(:Unknown line) kafka.message.CompressionCodec$.getCompressionCodec(CompressionCodec.scala:22) kafka.message.Message.compressionCodec(Message.scala:213) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:173) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) TRACE 300269: scala.sys.SystemProperties$.propertyHelp(SystemProperties.scala:57) scala.sys.SystemProperties$.addHelp(SystemProperties.scala:59) scala.sys.SystemProperties$.bool(SystemProperties.scala:63) scala.sys.SystemProperties$.noTraceSupression(SystemProperties.scala:75) scala.util.control.NoStackTrace$.(NoStackTrace.scala:26) scala.util.control.NoStackTrace$.(NoStackTrace.scala:Unknown line) scala.util.control.NoStackTrace$class.fillInStackTrace(NoStackTrace.scala:21) scala.util.control.BreakControl.fillInStackTrace(Breaks.scala:95) java.lang.Throwable.(Throwable.java:181) scala.util.control.BreakControl.(Breaks.scala:95) scala.util.control.Breaks.(Breaks.scala:30) scala.collection.Traversable$.(Traversable.scala:103) scala.collection.Traversable$.(Traversable.scala:Unknown line) scala.package$.(package.scala:37) scala.package$.(package.scala:Unknown line) scala.Predef$.(Predef.scala:89) scala.Predef$.(Predef.scala:Unknown line) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:54) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301172: scala.runtime.BoxesRunTime.equals2(:Unknown line) scala.runtime.BoxesRunTime.equals(:Unknown line) kafka.message.CompressionCodec$.getCompressionCodec(CompressionCodec.scala:22) kafka.message.Message.compressionCodec(Message.scala:213) kafka.log.Log$$anonfun$analyzeAndValidateMessageSet$1.apply(Log.scala:333) kafka.log.Log$$anonfun$analyzeAndValidateMessageSet$1.apply(Log.scala:318) scala.collection.Iterator$class.foreach(Iterator.scala:772) kafka.utils.IteratorTemplate.foreach(IteratorTemplate.scala:32) kafka.log.Log.analyzeAndValidateMessageSet(Log.scala:318) kafka.log.Log.append(Log.scala:230) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301176: scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301177: org.xerial.snappy.SnappyInputStream.hasNextChunk(SnappyInputStream.java:337) org.xerial.snappy.SnappyInputStream.rawRead(SnappyInputStream.java:158) org.xerial.snappy.SnappyInputStream.read(SnappyInputStream.java:142) java.io.InputStream.read(InputStream.java:82) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply$mcI$sp(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply(ByteBufferMessageSet.scala:68) scala.collection.immutable.Stream$.continually(Stream.scala:1104) scala.collection.immutable.Stream$$anonfun$continually$1.apply(Stream.scala:1104) scala.collection.immutable.Stream$$anonfun$continually$1.apply(Stream.scala:1104) scala.collection.immutable.Stream$Cons.tail(Stream.scala:1060) scala.collection.immutable.Stream$Cons.tail(Stream.scala:1052) scala.collection.immutable.Stream$$anonfun$takeWhile$1.apply(Stream.scala:782) scala.collection.immutable.Stream$$anonfun$takeWhile$1.apply(Stream.scala:782) scala.collection.immutable.Stream$Cons.tail(Stream.scala:1060) scala.collection.immutable.Stream$Cons.tail(Stream.scala:1052) scala.collection.immutable.Stream.foreach(Stream.scala:527) kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:178) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) TRACE 301180: kafka.log.Log$$anonfun$analyzeAndValidateMessageSet$1.apply(Log.scala:333) kafka.log.Log$$anonfun$analyzeAndValidateMessageSet$1.apply(Log.scala:318) scala.collection.Iterator$class.foreach(Iterator.scala:772) kafka.utils.IteratorTemplate.foreach(IteratorTemplate.scala:32) kafka.log.Log.analyzeAndValidateMessageSet(Log.scala:318) kafka.log.Log.append(Log.scala:230) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 300543: java.util.concurrent.CopyOnWriteArrayList.iterator(CopyOnWriteArrayList.java:925) javax.management.NotificationBroadcasterSupport.sendNotification(NotificationBroadcasterSupport.java:216) javax.management.MBeanServerDelegate.sendNotification(MBeanServerDelegate.java:193) com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.sendNotification(DefaultMBeanServerInterceptor.java:1522) com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.internal_addObject(DefaultMBeanServerInterceptor.java:1499) com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:962) com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:916) com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:312) com.sun.jmx.mbeanserver.JmxMBeanServer$2.run(JmxMBeanServer.java:1195) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) com.sun.jmx.mbeanserver.JmxMBeanServer.initialize(JmxMBeanServer.java:1193) com.sun.jmx.mbeanserver.JmxMBeanServer.(JmxMBeanServer.java:225) com.sun.jmx.mbeanserver.JmxMBeanServer.(JmxMBeanServer.java:170) com.sun.jmx.mbeanserver.JmxMBeanServer.newMBeanServer(JmxMBeanServer.java:1401) javax.management.MBeanServerBuilder.newMBeanServer(MBeanServerBuilder.java:93) javax.management.MBeanServerFactory.newMBeanServer(MBeanServerFactory.java:311) javax.management.MBeanServerFactory.createMBeanServer(MBeanServerFactory.java:214) javax.management.MBeanServerFactory.createMBeanServer(MBeanServerFactory.java:175) sun.management.ManagementFactory.createPlatformMBeanServer(ManagementFactory.java:302) java.lang.management.ManagementFactory.getPlatformMBeanServer(ManagementFactory.java:504) TRACE 300693: kafka.utils.Crc32.update(Crc32.java:60) kafka.utils.Utils$.crc32(Utils.scala:333) kafka.message.Message.computeChecksum(Message.scala:149) kafka.message.Message.(Message.scala:130) kafka.message.Message.(Message.scala:134) kafka.message.Message.(Message.scala:143) kafka.TestLinearWriteSpeed$$anonfun$1.apply(TestLinearWriteSpeed.scala:107) kafka.TestLinearWriteSpeed$$anonfun$1.apply(TestLinearWriteSpeed.scala:107) scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) scala.collection.immutable.Range.foreach(Range.scala:78) scala.collection.TraversableLike$class.map(TraversableLike.scala:233) scala.collection.immutable.Range.map(Range.scala:46) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:107) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 300412: sun.misc.Unsafe.compareAndSwapLong(Unsafe.java:Unknown line) java.util.concurrent.atomic.AtomicLong.compareAndSet(AtomicLong.java:121) java.util.Random.next(Random.java:139) java.util.Random.nextInt(Random.java:189) java.util.Random.nextBytes(Random.java:164) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:105) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 300952: java.lang.AbstractStringBuilder.(AbstractStringBuilder.java:45) java.lang.StringBuilder.(StringBuilder.java:68) java.io.UnixFileSystem.resolve(UnixFileSystem.java:93) java.io.File.(File.java:312) sun.misc.URLClassPath$FileLoader.getResource(URLClassPath.java:1012) sun.misc.URLClassPath.getResource(URLClassPath.java:173) java.net.URLClassLoader$1.run(URLClassLoader.java:194) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findClass(URLClassLoader.java:190) java.lang.ClassLoader.loadClass(ClassLoader.java:306) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:247) scala.collection.JavaConversions$.collectionAsScalaIterable(JavaConversions.scala:421) scala.collection.JavaConversions$.asIterable(JavaConversions.scala:428) kafka.log.Log.logSegments(Log.scala:586) kafka.log.Log.loadSegments(Log.scala:145) kafka.log.Log.(Log.scala:65) kafka.TestLinearWriteSpeed$LogWritable.(TestLinearWriteSpeed.scala:203) kafka.TestLinearWriteSpeed$$anonfun$main$1.apply$mcVI$sp(TestLinearWriteSpeed.scala:119) scala.collection.immutable.Range.foreach$mVc$sp(Range.scala:81) TRACE 300786: java.security.MessageDigest.update(MessageDigest.java:262) java.security.DigestInputStream.read(DigestInputStream.java:109) org.xerial.snappy.SnappyLoader.md5sum(SnappyLoader.java:334) org.xerial.snappy.SnappyLoader.extractLibraryFile(SnappyLoader.java:366) org.xerial.snappy.SnappyLoader.findNativeLibrary(SnappyLoader.java:446) org.xerial.snappy.SnappyLoader.loadNativeLibrary(SnappyLoader.java:308) org.xerial.snappy.SnappyLoader.load(SnappyLoader.java:219) org.xerial.snappy.Snappy.(Snappy.java:44) org.xerial.snappy.SnappyOutputStream.(SnappyOutputStream.java:79) org.xerial.snappy.SnappyOutputStream.(SnappyOutputStream.java:66) kafka.message.CompressionFactory$.apply(CompressionFactory.scala:33) kafka.message.ByteBufferMessageSet$.kafka$message$ByteBufferMessageSet$$create(ByteBufferMessageSet.scala:41) kafka.message.ByteBufferMessageSet.(ByteBufferMessageSet.scala:102) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:107) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 300787: java.security.DigestInputStream.read(DigestInputStream.java:107) org.xerial.snappy.SnappyLoader.md5sum(SnappyLoader.java:334) org.xerial.snappy.SnappyLoader.extractLibraryFile(SnappyLoader.java:366) org.xerial.snappy.SnappyLoader.findNativeLibrary(SnappyLoader.java:446) org.xerial.snappy.SnappyLoader.loadNativeLibrary(SnappyLoader.java:308) org.xerial.snappy.SnappyLoader.load(SnappyLoader.java:219) org.xerial.snappy.Snappy.(Snappy.java:44) org.xerial.snappy.SnappyOutputStream.(SnappyOutputStream.java:79) org.xerial.snappy.SnappyOutputStream.(SnappyOutputStream.java:66) kafka.message.CompressionFactory$.apply(CompressionFactory.scala:33) kafka.message.ByteBufferMessageSet$.kafka$message$ByteBufferMessageSet$$create(ByteBufferMessageSet.scala:41) kafka.message.ByteBufferMessageSet.(ByteBufferMessageSet.scala:102) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:107) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 300788: sun.misc.Unsafe.getInt(Unsafe.java:Unknown line) sun.security.provider.ByteArrayAccess.b2iLittle64(ByteArrayAccess.java:118) sun.security.provider.MD5.implCompress(MD5.java:129) sun.security.provider.DigestBase.engineUpdate(DigestBase.java:116) sun.security.provider.DigestBase.engineUpdate(DigestBase.java:92) java.security.MessageDigest$Delegate.engineUpdate(MessageDigest.java:534) java.security.MessageDigest.update(MessageDigest.java:261) java.security.DigestInputStream.read(DigestInputStream.java:109) org.xerial.snappy.SnappyLoader.md5sum(SnappyLoader.java:334) org.xerial.snappy.SnappyLoader.extractLibraryFile(SnappyLoader.java:367) org.xerial.snappy.SnappyLoader.findNativeLibrary(SnappyLoader.java:446) org.xerial.snappy.SnappyLoader.loadNativeLibrary(SnappyLoader.java:308) org.xerial.snappy.SnappyLoader.load(SnappyLoader.java:219) org.xerial.snappy.Snappy.(Snappy.java:44) org.xerial.snappy.SnappyOutputStream.(SnappyOutputStream.java:79) org.xerial.snappy.SnappyOutputStream.(SnappyOutputStream.java:66) kafka.message.CompressionFactory$.apply(CompressionFactory.scala:33) kafka.message.ByteBufferMessageSet$.kafka$message$ByteBufferMessageSet$$create(ByteBufferMessageSet.scala:41) kafka.message.ByteBufferMessageSet.(ByteBufferMessageSet.scala:102) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:107) TRACE 300311: java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:631) java.lang.ClassLoader.defineClass(ClassLoader.java:615) java.security.SecureClassLoader.defineClass(SecureClassLoader.java:141) java.net.URLClassLoader.defineClass(URLClassLoader.java:283) java.net.URLClassLoader.access$000(URLClassLoader.java:58) java.net.URLClassLoader$1.run(URLClassLoader.java:197) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findClass(URLClassLoader.java:190) java.lang.ClassLoader.loadClass(ClassLoader.java:306) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:247) scala.collection.mutable.HashMap.(HashMap.scala:45) scala.collection.mutable.HashMap.(HashMap.scala:60) scala.collection.mutable.Map$.empty(Map.scala:72) scala.collection.mutable.Map$.empty(Map.scala:68) scala.collection.generic.MutableMapFactory.newBuilder(MutableMapFactory.scala:28) scala.collection.generic.GenMapFactory.apply(GenMapFactory.scala:48) scala.sys.SystemProperties$.propertyHelp(SystemProperties.scala:57) scala.sys.SystemProperties$.addHelp(SystemProperties.scala:59) TRACE 301023: java.io.FileInputStream.open(FileInputStream.java:Unknown line) java.io.FileInputStream.(FileInputStream.java:120) sun.misc.URLClassPath$FileLoader$1.getInputStream(URLClassPath.java:1021) sun.misc.Resource.cachedInputStream(Resource.java:61) sun.misc.Resource.getByteBuffer(Resource.java:144) java.net.URLClassLoader.defineClass(URLClassLoader.java:256) java.net.URLClassLoader.access$000(URLClassLoader.java:58) java.net.URLClassLoader$1.run(URLClassLoader.java:197) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findClass(URLClassLoader.java:190) java.lang.ClassLoader.loadClass(ClassLoader.java:306) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:247) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:218) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 300168: sun.text.normalizer.NormalizerBase.(NormalizerBase.java:393) java.text.Normalizer.normalize(Normalizer.java:146) sun.security.x509.AVA.toRFC2253CanonicalString(AVA.java:986) sun.security.x509.RDN.toRFC2253StringInternal(RDN.java:430) sun.security.x509.RDN.toRFC2253String(RDN.java:409) sun.security.x509.X500Name.getRFC2253CanonicalName(X500Name.java:714) sun.security.x509.X500Name.equals(X500Name.java:400) sun.security.pkcs.PKCS7.getCertificate(PKCS7.java:609) sun.security.pkcs.SignerInfo.getCertificate(SignerInfo.java:202) sun.security.pkcs.SignerInfo.verify(SignerInfo.java:328) sun.security.pkcs.PKCS7.verify(PKCS7.java:494) sun.security.pkcs.PKCS7.verify(PKCS7.java:511) sun.security.util.SignatureFileVerifier.processImpl(SignatureFileVerifier.java:197) sun.security.util.SignatureFileVerifier.process(SignatureFileVerifier.java:174) java.util.jar.JarVerifier.processEntry(JarVerifier.java:288) java.util.jar.JarVerifier.update(JarVerifier.java:199) java.util.jar.JarFile.initializeVerifier(JarFile.java:327) java.util.jar.JarFile.getInputStream(JarFile.java:395) sun.misc.JarIndex.getJarIndex(JarIndex.java:120) sun.misc.URLClassPath$JarLoader$1.run(URLClassPath.java:614) TRACE 300697: java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:631) java.lang.ClassLoader.defineClass(ClassLoader.java:615) java.security.SecureClassLoader.defineClass(SecureClassLoader.java:141) java.net.URLClassLoader.defineClass(URLClassLoader.java:283) java.net.URLClassLoader.access$000(URLClassLoader.java:58) java.net.URLClassLoader$1.run(URLClassLoader.java:197) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findClass(URLClassLoader.java:190) java.lang.ClassLoader.loadClass(ClassLoader.java:306) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:247) scala.collection.TraversableOnce$class.foldLeft(TraversableOnce.scala:142) scala.collection.immutable.Vector.foldLeft(Vector.scala:63) kafka.message.MessageSet$.messageSetSize(MessageSet.scala:37) kafka.message.ByteBufferMessageSet$.kafka$message$ByteBufferMessageSet$$create(ByteBufferMessageSet.scala:40) kafka.message.ByteBufferMessageSet.(ByteBufferMessageSet.scala:102) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:107) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 300618: java.lang.reflect.Method.hashCode(Method.java:370) java.util.HashMap.getEntry(HashMap.java:344) java.util.HashMap.containsKey(HashMap.java:335) java.util.HashSet.contains(HashSet.java:184) java.util.AbstractCollection.removeAll(AbstractCollection.java:336) com.sun.jmx.mbeanserver.MBeanAnalyzer.eliminateCovariantMethods(MBeanAnalyzer.java:246) com.sun.jmx.mbeanserver.OpenConverter.makeCompositeConverter(OpenConverter.java:429) com.sun.jmx.mbeanserver.OpenConverter.makeConverter(OpenConverter.java:295) com.sun.jmx.mbeanserver.OpenConverter.toConverter(OpenConverter.java:264) com.sun.jmx.mbeanserver.ConvertingMethod.(ConvertingMethod.java:185) com.sun.jmx.mbeanserver.ConvertingMethod.from(ConvertingMethod.java:28) com.sun.jmx.mbeanserver.MXBeanIntrospector.mFrom(MXBeanIntrospector.java:63) com.sun.jmx.mbeanserver.MXBeanIntrospector.mFrom(MXBeanIntrospector.java:33) com.sun.jmx.mbeanserver.MBeanAnalyzer.initMaps(MBeanAnalyzer.java:118) com.sun.jmx.mbeanserver.MBeanAnalyzer.(MBeanAnalyzer.java:99) com.sun.jmx.mbeanserver.MBeanAnalyzer.analyzer(MBeanAnalyzer.java:87) com.sun.jmx.mbeanserver.MXBeanIntrospector.getAnalyzer(MXBeanIntrospector.java:53) com.sun.jmx.mbeanserver.MBeanIntrospector.getPerInterface(MBeanIntrospector.java:163) com.sun.jmx.mbeanserver.MBeanSupport.(MBeanSupport.java:149) com.sun.jmx.mbeanserver.MXBeanSupport.(MXBeanSupport.java:48) TRACE 300253: java.lang.System.arraycopy(System.java:Unknown line) java.lang.String.getChars(String.java:854) java.lang.AbstractStringBuilder.append(AbstractStringBuilder.java:391) java.lang.StringBuilder.append(StringBuilder.java:119) java.net.URLStreamHandler.parseURL(URLStreamHandler.java:232) sun.net.www.protocol.file.Handler.parseURL(Handler.java:50) java.net.URL.(URL.java:596) java.net.URL.(URL.java:464) sun.misc.URLClassPath$FileLoader.getResource(URLClassPath.java:992) sun.misc.URLClassPath.getResource(URLClassPath.java:173) java.net.URLClassLoader$1.run(URLClassLoader.java:194) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findClass(URLClassLoader.java:190) java.lang.ClassLoader.loadClass(ClassLoader.java:306) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:247) java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:631) java.lang.ClassLoader.defineClass(ClassLoader.java:615) java.security.SecureClassLoader.defineClass(SecureClassLoader.java:141) TRACE 300361: java.lang.StringCoding$StringEncoder.encode(StringCoding.java:232) java.lang.StringCoding.encode(StringCoding.java:272) java.lang.String.getBytes(String.java:946) java.io.UnixFileSystem.getBooleanAttributes0(UnixFileSystem.java:Unknown line) java.io.UnixFileSystem.getBooleanAttributes(UnixFileSystem.java:228) java.io.File.exists(File.java:733) sun.misc.URLClassPath$FileLoader.getResource(URLClassPath.java:1015) sun.misc.URLClassPath.getResource(URLClassPath.java:173) java.net.URLClassLoader$1.run(URLClassLoader.java:194) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findClass(URLClassLoader.java:190) java.lang.ClassLoader.loadClass(ClassLoader.java:306) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:247) scala.Predef$.(Predef.scala:104) scala.Predef$.(Predef.scala:Unknown line) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:54) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 300901: java.util.concurrent.ScheduledThreadPoolExecutor.(ScheduledThreadPoolExecutor.java:298) kafka.utils.KafkaScheduler.startup(KafkaScheduler.scala:74) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:111) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 300272: java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:631) java.lang.ClassLoader.defineClass(ClassLoader.java:615) java.security.SecureClassLoader.defineClass(SecureClassLoader.java:141) java.net.URLClassLoader.defineClass(URLClassLoader.java:283) java.net.URLClassLoader.access$000(URLClassLoader.java:58) java.net.URLClassLoader$1.run(URLClassLoader.java:197) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findClass(URLClassLoader.java:190) java.lang.ClassLoader.loadClass(ClassLoader.java:306) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:247) scala.collection.immutable.List.(List.scala:76) scala.collection.immutable.Nil$.(List.scala:399) scala.collection.immutable.Nil$.(List.scala:Unknown line) scala.sys.SystemProperties$.propertyHelp(SystemProperties.scala:57) scala.sys.SystemProperties$.addHelp(SystemProperties.scala:59) scala.sys.SystemProperties$.bool(SystemProperties.scala:63) scala.sys.SystemProperties$.noTraceSupression(SystemProperties.scala:75) scala.util.control.NoStackTrace$.(NoStackTrace.scala:26) TRACE 300964: java.lang.ClassLoader$NativeLibrary.load(ClassLoader.java:Unknown line) java.lang.ClassLoader.loadLibrary0(ClassLoader.java:1827) java.lang.ClassLoader.loadLibrary(ClassLoader.java:1724) java.lang.Runtime.loadLibrary0(Runtime.java:823) java.lang.System.loadLibrary(System.java:1045) sun.security.action.LoadLibraryAction.run(LoadLibraryAction.java:50) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) sun.nio.ch.Util.load(Util.java:462) sun.nio.ch.FileChannelImpl.(FileChannelImpl.java:1224) java.io.RandomAccessFile.getChannel(RandomAccessFile.java:253) kafka.utils.Utils$.openChannel(Utils.scala:154) kafka.log.FileMessageSet.(FileMessageSet.scala:69) kafka.log.LogSegment.(LogSegment.scala:52) kafka.log.Log.loadSegments(Log.scala:147) kafka.log.Log.(Log.scala:65) kafka.TestLinearWriteSpeed$LogWritable.(TestLinearWriteSpeed.scala:203) kafka.TestLinearWriteSpeed$$anonfun$main$1.apply$mcVI$sp(TestLinearWriteSpeed.scala:119) scala.collection.immutable.Range.foreach$mVc$sp(Range.scala:81) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:112) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 300746: java.util.Arrays.copyOfRange(Arrays.java:3209) java.lang.String.(String.java:215) java.lang.StringBuilder.toString(StringBuilder.java:430) java.security.Provider.put(Provider.java:309) sun.security.rsa.SunRsaSign.(SunRsaSign.java:51) sun.reflect.NativeConstructorAccessorImpl.newInstance0(NativeConstructorAccessorImpl.java:Unknown line) sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:39) sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:27) java.lang.reflect.Constructor.newInstance(Constructor.java:513) java.lang.Class.newInstance0(Class.java:357) java.lang.Class.newInstance(Class.java:310) sun.security.jca.ProviderConfig$4.run(ProviderConfig.java:259) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) sun.security.jca.ProviderConfig.doLoadProvider(ProviderConfig.java:244) sun.security.jca.ProviderConfig.getProvider(ProviderConfig.java:224) sun.security.jca.ProviderList.getProvider(ProviderList.java:215) sun.security.jca.ProviderList$ServiceList.tryGet(ProviderList.java:416) sun.security.jca.ProviderList$ServiceList.access$200(ProviderList.java:358) sun.security.jca.ProviderList$ServiceList$1.hasNext(ProviderList.java:468) java.security.KeyFactory.nextSpi(KeyFactory.java:264) TRACE 300027: java.nio.HeapByteBuffer.(HeapByteBuffer.java:39) java.nio.ByteBuffer.allocate(ByteBuffer.java:312) sun.nio.cs.StreamDecoder.(StreamDecoder.java:231) sun.nio.cs.StreamDecoder.(StreamDecoder.java:211) sun.nio.cs.StreamDecoder.forInputStreamReader(StreamDecoder.java:50) java.io.InputStreamReader.(InputStreamReader.java:83) sun.misc.JarIndex.read(JarIndex.java:287) sun.misc.JarIndex.(JarIndex.java:75) sun.misc.JarIndex.getJarIndex(JarIndex.java:120) sun.misc.URLClassPath$JarLoader$1.run(URLClassPath.java:614) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) sun.misc.URLClassPath$JarLoader.ensureOpen(URLClassPath.java:605) sun.misc.URLClassPath$JarLoader.(URLClassPath.java:589) sun.misc.URLClassPath$3.run(URLClassPath.java:337) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) sun.misc.URLClassPath.getLoader(URLClassPath.java:326) sun.misc.URLClassPath.getLoader(URLClassPath.java:303) sun.misc.URLClassPath.getResource(URLClassPath.java:172) java.net.URLClassLoader$1.run(URLClassLoader.java:194) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) TRACE 300093: sun.security.provider.Sun.(Sun.java:150) sun.reflect.NativeConstructorAccessorImpl.newInstance0(NativeConstructorAccessorImpl.java:Unknown line) sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:39) sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:27) java.lang.reflect.Constructor.newInstance(Constructor.java:513) java.lang.Class.newInstance0(Class.java:357) java.lang.Class.newInstance(Class.java:310) sun.security.jca.ProviderConfig$4.run(ProviderConfig.java:259) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) sun.security.jca.ProviderConfig.doLoadProvider(ProviderConfig.java:244) sun.security.jca.ProviderConfig.getProvider(ProviderConfig.java:224) sun.security.jca.ProviderList.getProvider(ProviderList.java:215) sun.security.jca.ProviderList.getService(ProviderList.java:313) sun.security.jca.GetInstance.getInstance(GetInstance.java:140) java.security.cert.CertificateFactory.getInstance(CertificateFactory.java:148) sun.security.pkcs.PKCS7.parseSignedData(PKCS7.java:244) sun.security.pkcs.PKCS7.parse(PKCS7.java:141) sun.security.pkcs.PKCS7.parse(PKCS7.java:110) sun.security.pkcs.PKCS7.(PKCS7.java:92) sun.security.util.SignatureFileVerifier.(SignatureFileVerifier.java:78) TRACE 301036: java.lang.ClassLoader.findLoadedClass0(ClassLoader.java:Unknown line) java.lang.ClassLoader.findLoadedClass(ClassLoader.java:949) java.lang.ClassLoader.loadClass(ClassLoader.java:291) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:247) kafka.log.LogSegment.append(LogSegment.scala:73) kafka.log.Log.append(Log.scala:271) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 300296: scala.collection.mutable.Map$.empty(Map.scala:72) scala.collection.mutable.Map$.empty(Map.scala:68) scala.collection.generic.MutableMapFactory.newBuilder(MutableMapFactory.scala:28) scala.collection.generic.GenMapFactory.apply(GenMapFactory.scala:48) scala.sys.SystemProperties$.propertyHelp(SystemProperties.scala:57) scala.sys.SystemProperties$.addHelp(SystemProperties.scala:59) scala.sys.SystemProperties$.bool(SystemProperties.scala:63) scala.sys.SystemProperties$.noTraceSupression(SystemProperties.scala:75) scala.util.control.NoStackTrace$.(NoStackTrace.scala:26) scala.util.control.NoStackTrace$.(NoStackTrace.scala:Unknown line) scala.util.control.NoStackTrace$class.fillInStackTrace(NoStackTrace.scala:21) scala.util.control.BreakControl.fillInStackTrace(Breaks.scala:95) java.lang.Throwable.(Throwable.java:181) scala.util.control.BreakControl.(Breaks.scala:95) scala.util.control.Breaks.(Breaks.scala:30) scala.collection.Traversable$.(Traversable.scala:103) scala.collection.Traversable$.(Traversable.scala:Unknown line) scala.package$.(package.scala:37) scala.package$.(package.scala:Unknown line) scala.Predef$.(Predef.scala:89) TRACE 301206: java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:631) java.lang.ClassLoader.defineClass(ClassLoader.java:615) java.security.SecureClassLoader.defineClass(SecureClassLoader.java:141) java.net.URLClassLoader.defineClass(URLClassLoader.java:283) java.net.URLClassLoader.access$000(URLClassLoader.java:58) java.net.URLClassLoader$1.run(URLClassLoader.java:197) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findClass(URLClassLoader.java:190) java.lang.ClassLoader.loadClass(ClassLoader.java:306) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:247) com.yammer.metrics.core.Timer.(Timer.java:18) com.yammer.metrics.core.MetricsRegistry.newTimer(MetricsRegistry.java:320) kafka.metrics.KafkaMetricsGroup$class.newTimer(KafkaMetricsGroup.scala:52) kafka.log.LogFlushStats$.newTimer(FileMessageSet.scala:269) kafka.log.LogFlushStats$.(FileMessageSet.scala:270) kafka.log.LogFlushStats$.(FileMessageSet.scala:Unknown line) kafka.log.LogSegment.flush(LogSegment.scala:237) kafka.log.Log$$anonfun$flush$2.apply(Log.scala:511) TRACE 301207: java.lang.ref.Reference$ReferenceHandler.run(Reference.java:118) TRACE 301208: java.net.URL.(URL.java:150) java.net.URL.(URL.java:464) sun.misc.URLClassPath$FileLoader.getResource(URLClassPath.java:992) sun.misc.URLClassPath.getResource(URLClassPath.java:173) java.net.URLClassLoader$1.run(URLClassLoader.java:194) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findClass(URLClassLoader.java:190) java.lang.ClassLoader.loadClass(ClassLoader.java:306) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:247) com.yammer.metrics.core.Histogram$SampleType.(Histogram.java:31) com.yammer.metrics.core.Timer.(Timer.java:18) com.yammer.metrics.core.MetricsRegistry.newTimer(MetricsRegistry.java:320) kafka.metrics.KafkaMetricsGroup$class.newTimer(KafkaMetricsGroup.scala:52) kafka.log.LogFlushStats$.newTimer(FileMessageSet.scala:269) kafka.log.LogFlushStats$.(FileMessageSet.scala:270) kafka.log.LogFlushStats$.(FileMessageSet.scala:Unknown line) kafka.log.LogSegment.flush(LogSegment.scala:237) kafka.log.Log$$anonfun$flush$2.apply(Log.scala:511) kafka.log.Log$$anonfun$flush$2.apply(Log.scala:510) TRACE 300970: java.lang.ClassLoader$NativeLibrary.find(ClassLoader.java:Unknown line) java.lang.ClassLoader.findNative(ClassLoader.java:1849) sun.nio.ch.FileChannelImpl.size0(FileChannelImpl.java:Unknown line) sun.nio.ch.FileChannelImpl.size(FileChannelImpl.java:299) kafka.log.FileMessageSet.(FileMessageSet.scala:52) kafka.log.FileMessageSet.(FileMessageSet.scala:63) kafka.log.FileMessageSet.(FileMessageSet.scala:69) kafka.log.LogSegment.(LogSegment.scala:52) kafka.log.Log.loadSegments(Log.scala:147) kafka.log.Log.(Log.scala:65) kafka.TestLinearWriteSpeed$LogWritable.(TestLinearWriteSpeed.scala:203) kafka.TestLinearWriteSpeed$$anonfun$main$1.apply$mcVI$sp(TestLinearWriteSpeed.scala:119) scala.collection.immutable.Range.foreach$mVc$sp(Range.scala:81) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:112) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 300393: scala.LowPriorityImplicits.wrapRefArray(LowPriorityImplicits.scala:67) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:86) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 300854: java.util.zip.ZipFile.read(ZipFile.java:Unknown line) java.util.zip.ZipFile.access$1200(ZipFile.java:31) java.util.zip.ZipFile$ZipFileInputStream.read(ZipFile.java:461) java.util.zip.ZipFile$1.fill(ZipFile.java:244) java.util.zip.InflaterInputStream.read(InflaterInputStream.java:141) sun.misc.Resource.getBytes(Resource.java:108) java.net.URLClassLoader.defineClass(URLClassLoader.java:257) java.net.URLClassLoader.access$000(URLClassLoader.java:58) java.net.URLClassLoader$1.run(URLClassLoader.java:197) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findClass(URLClassLoader.java:190) java.lang.ClassLoader.loadClass(ClassLoader.java:306) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:247) org.apache.log4j.Hierarchy.getLogger(Hierarchy.java:262) org.apache.log4j.PropertyConfigurator.parseCatsAndRenderers(PropertyConfigurator.java:566) org.apache.log4j.PropertyConfigurator.doConfigure(PropertyConfigurator.java:442) org.apache.log4j.PropertyConfigurator.doConfigure(PropertyConfigurator.java:476) org.apache.log4j.helpers.OptionConverter.selectAndConfigure(OptionConverter.java:471) org.apache.log4j.LogManager.(LogManager.java:125) TRACE 300454: java.util.logging.LogManager.readConfiguration(LogManager.java:1102) java.util.logging.LogManager.readConfiguration(LogManager.java:972) java.util.logging.LogManager$2.run(LogManager.java:264) java.util.logging.LogManager$2.run(LogManager.java:262) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.util.logging.LogManager.readPrimordialConfiguration(LogManager.java:262) java.util.logging.LogManager.getLogManager(LogManager.java:245) java.util.logging.Logger.(Logger.java:225) java.util.logging.LogManager$RootLogger.(LogManager.java:1295) java.util.logging.LogManager$RootLogger.(LogManager.java:1293) java.util.logging.LogManager$1.run(LogManager.java:176) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.util.logging.LogManager.(LogManager.java:153) java.util.logging.Logger.demandLogger(Logger.java:280) java.util.logging.Logger.getLogger(Logger.java:321) com.sun.jmx.remote.util.ClassLogger.(ClassLogger.java:37) javax.management.NotificationBroadcasterSupport.(NotificationBroadcasterSupport.java:335) javax.management.MBeanServerDelegate.(MBeanServerDelegate.java:58) com.sun.jmx.mbeanserver.MBeanServerDelegateImpl.(MBeanServerDelegateImpl.java:82) com.sun.jmx.mbeanserver.JmxMBeanServer.newMBeanServerDelegate(JmxMBeanServer.java:1342) TRACE 300708: sun.misc.Launcher$1.run(Launcher.java:380) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) sun.misc.Launcher.getBootstrapClassPath(Launcher.java:366) java.lang.ClassLoader.getBootstrapClassPath(ClassLoader.java:1173) java.lang.ClassLoader.getBootstrapResource(ClassLoader.java:1149) java.lang.ClassLoader.getResource(ClassLoader.java:999) java.lang.ClassLoader.getResource(ClassLoader.java:997) java.lang.ClassLoader.getResourceAsStream(ClassLoader.java:1192) org.xerial.snappy.SnappyLoader.loadSnappySystemProperties(SnappyLoader.java:105) org.xerial.snappy.SnappyLoader.(SnappyLoader.java:132) org.xerial.snappy.Snappy.(Snappy.java:44) org.xerial.snappy.SnappyOutputStream.(SnappyOutputStream.java:79) org.xerial.snappy.SnappyOutputStream.(SnappyOutputStream.java:66) kafka.message.CompressionFactory$.apply(CompressionFactory.scala:33) kafka.message.ByteBufferMessageSet$.kafka$message$ByteBufferMessageSet$$create(ByteBufferMessageSet.scala:41) kafka.message.ByteBufferMessageSet.(ByteBufferMessageSet.scala:102) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:107) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 300591: com.sun.management.OSMBeanFactory.getOperatingSystemMXBean(OSMBeanFactory.java:30) sun.management.ManagementFactory.getOperatingSystemMXBean(ManagementFactory.java:100) sun.management.ManagementFactory.createPlatformMBeanServer(ManagementFactory.java:308) java.lang.management.ManagementFactory.getPlatformMBeanServer(ManagementFactory.java:504) kafka.utils.Utils$.registerMBean(Utils.scala:252) kafka.utils.Log4jController$.(Log4jController.scala:29) kafka.utils.Log4jController$.(Log4jController.scala:Unknown line) kafka.utils.Logging$class.$init$(Logging.scala:29) kafka.message.ByteBufferMessageSet.(ByteBufferMessageSet.scala:98) kafka.message.MessageSet$.(MessageSet.scala:31) kafka.message.MessageSet$.(MessageSet.scala:Unknown line) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:106) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301045: scala.collection.immutable.Stream.(Stream.scala:186) scala.collection.immutable.Stream$Cons.(Stream.scala:1052) scala.collection.immutable.Stream.takeWhile(Stream.scala:782) scala.collection.immutable.Stream$$anonfun$takeWhile$1.apply(Stream.scala:782) scala.collection.immutable.Stream$$anonfun$takeWhile$1.apply(Stream.scala:782) scala.collection.immutable.Stream$Cons.tail(Stream.scala:1060) scala.collection.immutable.Stream$Cons.tail(Stream.scala:1052) scala.collection.immutable.Stream.foreach(Stream.scala:527) kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:178) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) TRACE 301046: java.util.Arrays.copyOf(Arrays.java:2786) java.io.ByteArrayOutputStream.toByteArray(ByteArrayOutputStream.java:133) org.xerial.snappy.SnappyCodec.writeHeader(SnappyCodec.java:84) org.xerial.snappy.SnappyOutputStream.writeHeader(SnappyOutputStream.java:84) org.xerial.snappy.SnappyOutputStream.(SnappyOutputStream.java:80) org.xerial.snappy.SnappyOutputStream.(SnappyOutputStream.java:66) kafka.message.CompressionFactory$.apply(CompressionFactory.scala:33) kafka.message.ByteBufferMessageSet$.kafka$message$ByteBufferMessageSet$$create(ByteBufferMessageSet.scala:41) kafka.message.ByteBufferMessageSet.(ByteBufferMessageSet.scala:106) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301047: scala.collection.mutable.ArrayBuffer.size0(ArrayBuffer.scala:47) scala.collection.mutable.ArrayBuffer.$plus$eq(ArrayBuffer.scala:83) scala.collection.mutable.ArrayBuffer.$plus$eq(ArrayBuffer.scala:47) scala.collection.generic.Growable$$anonfun$$plus$plus$eq$1.apply(Growable.scala:48) scala.collection.generic.Growable$$anonfun$$plus$plus$eq$1.apply(Growable.scala:48) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301221: java.nio.channels.spi.AbstractInterruptibleChannel.begin(AbstractInterruptibleChannel.java:153) sun.nio.ch.FileChannelImpl.write(FileChannelImpl.java:191) kafka.message.ByteBufferMessageSet.writeTo(ByteBufferMessageSet.scala:132) kafka.log.FileMessageSet.append(FileMessageSet.scala:203) kafka.log.LogSegment.append(LogSegment.scala:80) kafka.log.Log.append(Log.scala:271) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301222: java.lang.Object.hashCode(Object.java:Unknown line) java.util.WeakHashMap.get(WeakHashMap.java:348) com.sun.jmx.mbeanserver.MBeanIntrospector.getPerInterface(MBeanIntrospector.java:159) com.sun.jmx.mbeanserver.MBeanSupport.(MBeanSupport.java:149) com.sun.jmx.mbeanserver.StandardMBeanSupport.(StandardMBeanSupport.java:81) com.sun.jmx.mbeanserver.Introspector.makeDynamicMBean(Introspector.java:178) com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:914) com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:312) com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:492) com.yammer.metrics.reporting.JmxReporter.registerBean(JmxReporter.java:464) com.yammer.metrics.reporting.JmxReporter.processTimer(JmxReporter.java:432) com.yammer.metrics.reporting.JmxReporter.processTimer(JmxReporter.java:16) com.yammer.metrics.core.Timer.processWith(Timer.java:214) com.yammer.metrics.reporting.JmxReporter.onMetricAdded(JmxReporter.java:395) com.yammer.metrics.core.MetricsRegistry.notifyMetricAdded(MetricsRegistry.java:516) com.yammer.metrics.core.MetricsRegistry.getOrAdd(MetricsRegistry.java:491) com.yammer.metrics.core.MetricsRegistry.newTimer(MetricsRegistry.java:320) kafka.metrics.KafkaMetricsGroup$class.newTimer(KafkaMetricsGroup.scala:52) kafka.log.LogFlushStats$.newTimer(FileMessageSet.scala:269) kafka.log.LogFlushStats$.(FileMessageSet.scala:270) TRACE 301225: kafka.log.Log.append(Log.scala:271) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301052: scala.runtime.BoxesRunTime.equalsNumNum(:Unknown line) scala.runtime.BoxesRunTime.equalsNumObject(:Unknown line) scala.runtime.BoxesRunTime.equals2(:Unknown line) scala.runtime.BoxesRunTime.equals(:Unknown line) kafka.message.CompressionCodec$.getCompressionCodec(CompressionCodec.scala:22) kafka.message.Message.compressionCodec(Message.scala:213) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:173) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) TRACE 301054: java.nio.Buffer.(Buffer.java:176) java.nio.ByteBuffer.(ByteBuffer.java:259) java.nio.HeapByteBuffer.(HeapByteBuffer.java:68) java.nio.HeapByteBuffer.slice(HeapByteBuffer.java:80) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:165) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) kafka.message.ByteBufferMessageSet$$anon$1.innerDone(ByteBufferMessageSet.scala:149) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:190) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) TRACE 301231: kafka.log.Log.append(Log.scala:241) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301232: kafka.log.Log.analyzeAndValidateMessageSet(Log.scala:317) kafka.log.Log.append(Log.scala:230) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301234: kafka.log.Log$LogAppendInfo.shallowCount(Log.scala:296) kafka.log.Log.append(Log.scala:233) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301236: org.xerial.snappy.SnappyInputStream.hasNextChunk(SnappyInputStream.java:341) org.xerial.snappy.SnappyInputStream.rawRead(SnappyInputStream.java:158) org.xerial.snappy.SnappyInputStream.read(SnappyInputStream.java:142) java.io.InputStream.read(InputStream.java:82) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply$mcI$sp(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply(ByteBufferMessageSet.scala:68) scala.collection.immutable.Stream$.continually(Stream.scala:1104) kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:178) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) TRACE 301238: kafka.utils.Utils$.crc32(Utils.scala:333) kafka.message.Message.computeChecksum(Message.scala:149) kafka.message.Message.(Message.scala:130) kafka.message.Message.(Message.scala:134) kafka.message.Message.(Message.scala:137) kafka.message.ByteBufferMessageSet$.kafka$message$ByteBufferMessageSet$$create(ByteBufferMessageSet.scala:54) kafka.message.ByteBufferMessageSet.(ByteBufferMessageSet.scala:106) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301241: kafka.utils.Logging$class.trace(Logging.scala:35) kafka.log.LogSegment.trace(LogSegment.scala:40) kafka.log.LogSegment.append(LogSegment.scala:73) kafka.log.Log.append(Log.scala:271) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301242: kafka.utils.Logging$class.debug(Logging.scala:51) kafka.log.OffsetIndex.debug(OffsetIndex.scala:53) kafka.log.OffsetIndex.append(OffsetIndex.scala:195) kafka.log.LogSegment.append(LogSegment.scala:76) kafka.log.Log.append(Log.scala:271) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301244: sun.misc.Unsafe.compareAndSwapInt(Unsafe.java:Unknown line) java.util.concurrent.locks.AbstractQueuedSynchronizer.compareAndSetState(AbstractQueuedSynchronizer.java:537) java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java:319) java.util.concurrent.FutureTask.runAndReset(FutureTask.java:150) java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$101(ScheduledThreadPoolExecutor.java:98) java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(ScheduledThreadPoolExecutor.java:180) java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:204) java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918) java.lang.Thread.run(Thread.java:680) TRACE 301245: java.util.Arrays.copyOfRange(Arrays.java:3209) java.lang.String.(String.java:215) java.lang.StringBuilder.toString(StringBuilder.java:430) java.util.Formatter$FormatSpecifier.print(Formatter.java:3158) java.util.Formatter$FormatSpecifier.printFloat(Formatter.java:2718) java.util.Formatter$FormatSpecifier.print(Formatter.java:2667) java.util.Formatter.format(Formatter.java:2433) java.util.Formatter.format(Formatter.java:2367) java.lang.String.format(String.java:2769) scala.collection.immutable.StringLike$class.format(StringLike.scala:270) scala.collection.immutable.StringOps.format(StringOps.scala:31) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:148) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301246: java.io.DataInputStream.(DataInputStream.java:42) org.xerial.snappy.SnappyCodec.readHeader(SnappyCodec.java:92) org.xerial.snappy.SnappyInputStream.readHeader(SnappyInputStream.java:92) org.xerial.snappy.SnappyInputStream.(SnappyInputStream.java:58) kafka.message.CompressionFactory$.apply(CompressionFactory.scala:45) kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:66) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:178) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) TRACE 301247: org.xerial.snappy.SnappyCodec.readHeader(SnappyCodec.java:95) org.xerial.snappy.SnappyInputStream.readHeader(SnappyInputStream.java:92) org.xerial.snappy.SnappyInputStream.(SnappyInputStream.java:58) kafka.message.CompressionFactory$.apply(CompressionFactory.scala:45) kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:66) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:178) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) TRACE 301248: java.nio.HeapByteBuffer.slice(HeapByteBuffer.java:80) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:165) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301249: scala.collection.Iterator$class.map(Iterator.scala:399) kafka.utils.IteratorTemplate.map(IteratorTemplate.scala:32) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:218) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301250: org.xerial.snappy.SnappyInputStream.readHeader(SnappyInputStream.java:83) org.xerial.snappy.SnappyInputStream.(SnappyInputStream.java:58) kafka.message.CompressionFactory$.apply(CompressionFactory.scala:45) kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:66) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:178) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) TRACE 301252: com.apple.eawt._AppEventHandler.handleNativeNotification(_AppEventHandler.java:198) TRACE 301253: scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301254: java.nio.MappedByteBuffer.force0(MappedByteBuffer.java:Unknown line) java.nio.MappedByteBuffer.force(MappedByteBuffer.java:154) kafka.log.OffsetIndex.flush(OffsetIndex.scala:289) kafka.log.LogSegment$$anonfun$flush$1.apply$mcV$sp(LogSegment.scala:239) kafka.log.LogSegment$$anonfun$flush$1.apply(LogSegment.scala:237) kafka.log.LogSegment$$anonfun$flush$1.apply(LogSegment.scala:237) kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33) kafka.log.LogSegment.flush(LogSegment.scala:237) kafka.log.Log$$anonfun$flush$2.apply(Log.scala:511) kafka.log.Log$$anonfun$flush$2.apply(Log.scala:510) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.JavaConversions$JIteratorWrapper.foreach(JavaConversions.scala:573) scala.collection.IterableLike$class.foreach(IterableLike.scala:73) scala.collection.JavaConversions$JCollectionWrapper.foreach(JavaConversions.scala:592) kafka.log.Log.flush(Log.scala:510) kafka.log.Log$$anonfun$roll$1.apply$mcV$sp(Log.scala:483) kafka.utils.KafkaScheduler$$anon$1.run(KafkaScheduler.scala:100) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439) java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303) java.util.concurrent.FutureTask.run(FutureTask.java:138) TRACE 301255: java.util.regex.Pattern$Branch.match(Pattern.java:4110) java.util.regex.Pattern$BmpCharProperty.match(Pattern.java:3366) java.util.regex.Pattern$Start.match(Pattern.java:3055) java.util.regex.Matcher.search(Matcher.java:1105) java.util.regex.Matcher.find(Matcher.java:561) java.util.Formatter.parse(Formatter.java:2461) java.util.Formatter.format(Formatter.java:2414) java.util.Formatter.format(Formatter.java:2367) java.lang.String.format(String.java:2769) scala.collection.immutable.StringLike$class.format(StringLike.scala:270) scala.collection.immutable.StringOps.format(StringOps.scala:31) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:148) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301055: kafka.utils.IteratorTemplate.next(IteratorTemplate.scala:38) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:193) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301056: java.nio.Buffer.hasRemaining(Buffer.java:374) kafka.message.ByteBufferBackedInputStream.read(ByteBufferBackedInputStream.scala:33) org.xerial.snappy.SnappyInputStream.hasNextChunk(SnappyInputStream.java:327) org.xerial.snappy.SnappyInputStream.rawRead(SnappyInputStream.java:158) org.xerial.snappy.SnappyInputStream.read(SnappyInputStream.java:142) java.io.InputStream.read(InputStream.java:82) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply$mcI$sp(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply(ByteBufferMessageSet.scala:68) scala.collection.immutable.Stream$.continually(Stream.scala:1104) kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:178) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) TRACE 301057: java.nio.Bits.makeLong(Bits.java:288) java.nio.Bits.getLongB(Bits.java:321) java.nio.Bits.getLong(Bits.java:343) java.nio.HeapByteBuffer.getLong(HeapByteBuffer.java:387) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:155) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) kafka.message.ByteBufferMessageSet$$anon$1.innerDone(ByteBufferMessageSet.scala:149) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:190) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) TRACE 301058: scala.collection.mutable.ArrayBuffer.$plus$eq(ArrayBuffer.scala:83) scala.collection.mutable.ArrayBuffer.$plus$eq(ArrayBuffer.scala:47) scala.collection.generic.Growable$$anonfun$$plus$plus$eq$1.apply(Growable.scala:48) scala.collection.generic.Growable$$anonfun$$plus$plus$eq$1.apply(Growable.scala:48) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301060: scala.collection.mutable.ResizableArray$class.ensureSize(ResizableArray.scala:98) scala.collection.mutable.ArrayBuffer.ensureSize(ArrayBuffer.scala:47) scala.collection.mutable.ArrayBuffer.$plus$eq(ArrayBuffer.scala:82) scala.collection.mutable.ArrayBuffer.$plus$eq(ArrayBuffer.scala:47) scala.collection.generic.Growable$$anonfun$$plus$plus$eq$1.apply(Growable.scala:48) scala.collection.generic.Growable$$anonfun$$plus$plus$eq$1.apply(Growable.scala:48) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301059: scala.collection.mutable.ResizableArray$class.$init$(ResizableArray.scala:33) scala.collection.mutable.ArrayBuffer.(ArrayBuffer.scala:47) scala.collection.mutable.ArrayBuffer.(ArrayBuffer.scala:61) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301062: java.io.DataOutputStream.(DataOutputStream.java:187) org.xerial.snappy.SnappyCodec.writeHeader(SnappyCodec.java:79) org.xerial.snappy.SnappyOutputStream.writeHeader(SnappyOutputStream.java:84) org.xerial.snappy.SnappyOutputStream.(SnappyOutputStream.java:80) org.xerial.snappy.SnappyOutputStream.(SnappyOutputStream.java:66) kafka.message.CompressionFactory$.apply(CompressionFactory.scala:33) kafka.message.ByteBufferMessageSet$.kafka$message$ByteBufferMessageSet$$create(ByteBufferMessageSet.scala:41) kafka.message.ByteBufferMessageSet.(ByteBufferMessageSet.scala:106) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301066: java.lang.System.arraycopy(System.java:Unknown line) java.nio.HeapByteBuffer.get(HeapByteBuffer.java:128) kafka.message.ByteBufferBackedInputStream.read(ByteBufferBackedInputStream.scala:37) org.xerial.snappy.SnappyInputStream.hasNextChunk(SnappyInputStream.java:341) org.xerial.snappy.SnappyInputStream.rawRead(SnappyInputStream.java:158) org.xerial.snappy.SnappyInputStream.read(SnappyInputStream.java:142) java.io.InputStream.read(InputStream.java:82) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply$mcI$sp(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply(ByteBufferMessageSet.scala:68) scala.collection.immutable.Stream$.continually(Stream.scala:1104) scala.collection.immutable.Stream$$anonfun$continually$1.apply(Stream.scala:1104) scala.collection.immutable.Stream$$anonfun$continually$1.apply(Stream.scala:1104) scala.collection.immutable.Stream$Cons.tail(Stream.scala:1060) scala.collection.immutable.Stream$Cons.tail(Stream.scala:1052) scala.collection.immutable.Stream$$anonfun$takeWhile$1.apply(Stream.scala:782) scala.collection.immutable.Stream$$anonfun$takeWhile$1.apply(Stream.scala:782) scala.collection.immutable.Stream$Cons.tail(Stream.scala:1060) scala.collection.immutable.Stream$Cons.tail(Stream.scala:1052) scala.collection.immutable.Stream.foreach(Stream.scala:527) TRACE 301067: kafka.message.CompressionCodec$.getCompressionCodec(CompressionCodec.scala:22) kafka.message.Message.compressionCodec(Message.scala:213) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:173) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) kafka.message.ByteBufferMessageSet$$anon$1.innerDone(ByteBufferMessageSet.scala:149) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:190) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) TRACE 301069: kafka.log.Log.append(Log.scala:233) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301071: java.lang.System.arraycopy(System.java:Unknown line) java.util.Arrays.copyOf(Arrays.java:2787) java.io.ByteArrayOutputStream.toByteArray(ByteArrayOutputStream.java:133) kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:75) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:178) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) TRACE 301072: kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:153) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) kafka.message.ByteBufferMessageSet$$anon$1.innerDone(ByteBufferMessageSet.scala:149) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:190) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) TRACE 301077: java.nio.Buffer.limit(Buffer.java:228) kafka.log.OffsetIndex.maxEntries(OffsetIndex.scala:112) kafka.log.OffsetIndex.isFull(OffsetIndex.scala:212) kafka.log.OffsetIndex.append(OffsetIndex.scala:193) kafka.log.LogSegment.append(LogSegment.scala:76) kafka.log.Log.append(Log.scala:271) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301078: java.lang.System.arraycopy(System.java:Unknown line) java.nio.HeapByteBuffer.get(HeapByteBuffer.java:128) kafka.message.ByteBufferBackedInputStream.read(ByteBufferBackedInputStream.scala:37) org.xerial.snappy.SnappyInputStream.hasNextChunk(SnappyInputStream.java:327) org.xerial.snappy.SnappyInputStream.rawRead(SnappyInputStream.java:158) org.xerial.snappy.SnappyInputStream.read(SnappyInputStream.java:142) java.io.InputStream.read(InputStream.java:82) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply$mcI$sp(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply(ByteBufferMessageSet.scala:68) kafka.message.ByteBufferMessageSet$$anonfun$decompress$1.apply(ByteBufferMessageSet.scala:68) scala.collection.immutable.Stream$.continually(Stream.scala:1104) scala.collection.immutable.Stream$$anonfun$continually$1.apply(Stream.scala:1104) scala.collection.immutable.Stream$$anonfun$continually$1.apply(Stream.scala:1104) scala.collection.immutable.Stream$Cons.tail(Stream.scala:1060) scala.collection.immutable.Stream$Cons.tail(Stream.scala:1052) scala.collection.immutable.Stream$$anonfun$takeWhile$1.apply(Stream.scala:782) scala.collection.immutable.Stream$$anonfun$takeWhile$1.apply(Stream.scala:782) scala.collection.immutable.Stream$Cons.tail(Stream.scala:1060) scala.collection.immutable.Stream$Cons.tail(Stream.scala:1052) scala.collection.immutable.Stream.foreach(Stream.scala:527) TRACE 301080: kafka.message.CompressionFactory$.apply(CompressionFactory.scala:40) kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:66) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:178) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301082: java.lang.Thread.currentThread(Thread.java:Unknown line) java.lang.ThreadLocal.get(ThreadLocal.java:124) sun.nio.ch.Util.offerFirstTemporaryDirectBuffer(Util.java:173) sun.nio.ch.IOUtil.write(IOUtil.java:47) sun.nio.ch.FileChannelImpl.write(FileChannelImpl.java:198) kafka.message.ByteBufferMessageSet.writeTo(ByteBufferMessageSet.scala:132) kafka.log.FileMessageSet.append(FileMessageSet.scala:203) kafka.log.LogSegment.append(LogSegment.scala:80) kafka.log.Log.append(Log.scala:271) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301087: java.util.concurrent.atomic.AtomicInteger.get(AtomicInteger.java:61) kafka.log.FileMessageSet.sizeInBytes(FileMessageSet.scala:197) kafka.log.LogSegment.size(LogSegment.scala:59) kafka.log.Log.maybeRoll(Log.scala:438) kafka.log.Log.append(Log.scala:245) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301088: sun.misc.Unsafe.compareAndSwapInt(Unsafe.java:Unknown line) java.util.concurrent.atomic.AtomicInteger.compareAndSet(AtomicInteger.java:107) java.util.concurrent.atomic.AtomicInteger.getAndAdd(AtomicInteger.java:164) kafka.log.FileMessageSet.append(FileMessageSet.scala:204) kafka.log.LogSegment.append(LogSegment.scala:80) kafka.log.Log.append(Log.scala:271) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301091: kafka.log.OffsetIndex.logger(OffsetIndex.scala:53) kafka.utils.Logging$class.debug(Logging.scala:51) kafka.log.OffsetIndex.debug(OffsetIndex.scala:53) kafka.log.OffsetIndex.append(OffsetIndex.scala:195) kafka.log.LogSegment.append(LogSegment.scala:76) kafka.log.Log.append(Log.scala:271) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 300423: sun.management.ManagementFactory.(ManagementFactory.java:204) java.lang.management.ManagementFactory.getPlatformMBeanServer(ManagementFactory.java:504) kafka.utils.Utils$.registerMBean(Utils.scala:252) kafka.utils.Log4jController$.(Log4jController.scala:29) kafka.utils.Log4jController$.(Log4jController.scala:Unknown line) kafka.utils.Logging$class.$init$(Logging.scala:29) kafka.message.ByteBufferMessageSet.(ByteBufferMessageSet.scala:98) kafka.message.MessageSet$.(MessageSet.scala:31) kafka.message.MessageSet$.(MessageSet.scala:Unknown line) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:106) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 300914: java.util.Arrays.copyOf(Arrays.java:2786) sun.misc.Resource.getBytes(Resource.java:101) java.net.URLClassLoader.defineClass(URLClassLoader.java:257) java.net.URLClassLoader.access$000(URLClassLoader.java:58) java.net.URLClassLoader$1.run(URLClassLoader.java:197) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findClass(URLClassLoader.java:190) java.lang.ClassLoader.loadClass(ClassLoader.java:306) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:247) scala.collection.immutable.Set$.empty(Set.scala:47) scala.collection.immutable.Set$.empty(Set.scala:44) scala.collection.generic.ImmutableSetFactory.newBuilder(ImmutableSetFactory.scala:17) scala.collection.Set$.newBuilder(Set.scala:43) scala.collection.generic.GenericCompanion.apply(GenericCompanion.scala:46) kafka.log.LogConfig$.(LogConfig.scala:89) kafka.log.LogConfig$.(LogConfig.scala:Unknown line) kafka.TestLinearWriteSpeed$$anonfun$main$1.apply$mcVI$sp(TestLinearWriteSpeed.scala:119) scala.collection.immutable.Range.foreach$mVc$sp(Range.scala:81) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:112) TRACE 300668: java.util.HashMap.get(HashMap.java:300) sun.misc.ProxyGenerator$ConstantPool.getValue(ProxyGenerator.java:1839) sun.misc.ProxyGenerator$ConstantPool.getUtf8(ProxyGenerator.java:1699) sun.misc.ProxyGenerator$ConstantPool.getString(ProxyGenerator.java:1729) sun.misc.ProxyGenerator.codeClassForName(ProxyGenerator.java:1380) sun.misc.ProxyGenerator.access$1700(ProxyGenerator.java:36) sun.misc.ProxyGenerator$ProxyMethod.codeFieldInitialization(ProxyGenerator.java:1076) sun.misc.ProxyGenerator$ProxyMethod.access$1900(ProxyGenerator.java:831) sun.misc.ProxyGenerator.generateStaticInitializer(ProxyGenerator.java:1162) sun.misc.ProxyGenerator.generateClassFile(ProxyGenerator.java:443) sun.misc.ProxyGenerator.generateProxyClass(ProxyGenerator.java:306) java.lang.reflect.Proxy.getProxyClass0(Proxy.java:608) java.lang.reflect.Proxy.newProxyInstance(Proxy.java:688) sun.reflect.annotation.AnnotationParser.annotationForMap(AnnotationParser.java:239) sun.reflect.annotation.AnnotationParser.parseAnnotation(AnnotationParser.java:229) sun.reflect.annotation.AnnotationParser.parseAnnotations2(AnnotationParser.java:69) sun.reflect.annotation.AnnotationParser.parseAnnotations(AnnotationParser.java:52) java.lang.Class.initAnnotationsIfNecessary(Class.java:3118) java.lang.Class.getAnnotation(Class.java:3077) sun.reflect.annotation.AnnotationType.(AnnotationType.java:113) TRACE 300757: java.lang.ClassLoader.findBootstrapClass(ClassLoader.java:Unknown line) java.lang.ClassLoader.findBootstrapClassOrNull(ClassLoader.java:926) java.lang.ClassLoader.loadClass(ClassLoader.java:297) java.lang.ClassLoader.loadClass(ClassLoader.java:247) java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:631) java.lang.ClassLoader.defineClass(ClassLoader.java:615) java.security.SecureClassLoader.defineClass(SecureClassLoader.java:141) java.net.URLClassLoader.defineClass(URLClassLoader.java:283) java.net.URLClassLoader.access$000(URLClassLoader.java:58) java.net.URLClassLoader$1.run(URLClassLoader.java:197) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findClass(URLClassLoader.java:190) sun.misc.Launcher$ExtClassLoader.findClass(Launcher.java:229) java.lang.ClassLoader.loadClass(ClassLoader.java:306) java.lang.ClassLoader.loadClass(ClassLoader.java:295) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:247) sun.security.jca.ProviderConfig$4.run(ProviderConfig.java:253) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) TRACE 300425: java.lang.ClassLoader$NativeLibrary.load(ClassLoader.java:Unknown line) java.lang.ClassLoader.loadLibrary0(ClassLoader.java:1827) java.lang.ClassLoader.loadLibrary(ClassLoader.java:1724) java.lang.Runtime.loadLibrary0(Runtime.java:823) java.lang.System.loadLibrary(System.java:1045) sun.security.action.LoadLibraryAction.run(LoadLibraryAction.java:50) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) sun.management.ManagementFactory.(ManagementFactory.java:467) java.lang.management.ManagementFactory.getPlatformMBeanServer(ManagementFactory.java:504) kafka.utils.Utils$.registerMBean(Utils.scala:252) kafka.utils.Log4jController$.(Log4jController.scala:29) kafka.utils.Log4jController$.(Log4jController.scala:Unknown line) kafka.utils.Logging$class.$init$(Logging.scala:29) kafka.message.ByteBufferMessageSet.(ByteBufferMessageSet.scala:98) kafka.message.MessageSet$.(MessageSet.scala:31) kafka.message.MessageSet$.(MessageSet.scala:Unknown line) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:106) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 300231: java.util.zip.Inflater.inflateBytes(Inflater.java:Unknown line) java.util.zip.Inflater.inflate(Inflater.java:238) java.util.zip.InflaterInputStream.read(InflaterInputStream.java:135) sun.misc.Resource.getBytes(Resource.java:108) java.net.URLClassLoader.defineClass(URLClassLoader.java:257) java.net.URLClassLoader.access$000(URLClassLoader.java:58) java.net.URLClassLoader$1.run(URLClassLoader.java:197) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findClass(URLClassLoader.java:190) java.lang.ClassLoader.loadClass(ClassLoader.java:306) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:247) java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:631) java.lang.ClassLoader.defineClass(ClassLoader.java:615) java.security.SecureClassLoader.defineClass(SecureClassLoader.java:141) java.net.URLClassLoader.defineClass(URLClassLoader.java:283) java.net.URLClassLoader.access$000(URLClassLoader.java:58) java.net.URLClassLoader$1.run(URLClassLoader.java:197) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) TRACE 300212: sun.net.www.protocol.file.Handler.createFileURLConnection(Handler.java:95) sun.net.www.protocol.file.Handler.openConnection(Handler.java:64) sun.net.www.protocol.file.Handler.openConnection(Handler.java:55) java.net.URL.openConnection(URL.java:945) java.net.URLClassLoader.getPermissions(URLClassLoader.java:474) sun.misc.Launcher$AppClassLoader.getPermissions(Launcher.java:309) java.security.SecureClassLoader.getProtectionDomain(SecureClassLoader.java:235) java.security.SecureClassLoader.defineClass(SecureClassLoader.java:141) java.net.URLClassLoader.defineClass(URLClassLoader.java:283) java.net.URLClassLoader.access$000(URLClassLoader.java:58) java.net.URLClassLoader$1.run(URLClassLoader.java:197) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findClass(URLClassLoader.java:190) java.lang.ClassLoader.loadClass(ClassLoader.java:306) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:247) TRACE 300813: java.io.UnixFileSystem.getBooleanAttributes0(UnixFileSystem.java:Unknown line) java.io.UnixFileSystem.getBooleanAttributes(UnixFileSystem.java:228) java.io.File.exists(File.java:733) sun.misc.URLClassPath$FileLoader.getResource(URLClassPath.java:1015) sun.misc.URLClassPath.getResource(URLClassPath.java:173) java.net.URLClassLoader$1.run(URLClassLoader.java:194) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findClass(URLClassLoader.java:190) java.lang.ClassLoader.loadClass(ClassLoader.java:306) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:247) java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:631) java.lang.ClassLoader.defineClass(ClassLoader.java:615) java.security.SecureClassLoader.defineClass(SecureClassLoader.java:141) java.net.URLClassLoader.defineClass(URLClassLoader.java:283) java.net.URLClassLoader.access$000(URLClassLoader.java:58) java.net.URLClassLoader$1.run(URLClassLoader.java:197) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findClass(URLClassLoader.java:190) TRACE 300131: sun.security.x509.X509Key.buildX509Key(X509Key.java:198) sun.security.x509.X509Key.parse(X509Key.java:153) sun.security.x509.CertificateX509Key.(CertificateX509Key.java:58) sun.security.x509.X509CertInfo.parse(X509CertInfo.java:688) sun.security.x509.X509CertInfo.(X509CertInfo.java:152) sun.security.x509.X509CertImpl.parse(X509CertImpl.java:1731) sun.security.x509.X509CertImpl.(X509CertImpl.java:177) sun.security.provider.X509Factory.engineGenerateCertificate(X509Factory.java:90) java.security.cert.CertificateFactory.generateCertificate(CertificateFactory.java:305) sun.security.pkcs.PKCS7.parseSignedData(PKCS7.java:267) sun.security.pkcs.PKCS7.parse(PKCS7.java:141) sun.security.pkcs.PKCS7.parse(PKCS7.java:110) sun.security.pkcs.PKCS7.(PKCS7.java:92) sun.security.util.SignatureFileVerifier.(SignatureFileVerifier.java:78) java.util.jar.JarVerifier.processEntry(JarVerifier.java:267) java.util.jar.JarVerifier.update(JarVerifier.java:199) java.util.jar.JarFile.initializeVerifier(JarFile.java:327) java.util.jar.JarFile.getInputStream(JarFile.java:395) sun.misc.JarIndex.getJarIndex(JarIndex.java:120) sun.misc.URLClassPath$JarLoader$1.run(URLClassPath.java:614) TRACE 300924: java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:631) java.lang.ClassLoader.defineClass(ClassLoader.java:615) java.security.SecureClassLoader.defineClass(SecureClassLoader.java:141) java.net.URLClassLoader.defineClass(URLClassLoader.java:283) java.net.URLClassLoader.access$000(URLClassLoader.java:58) java.net.URLClassLoader$1.run(URLClassLoader.java:197) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findClass(URLClassLoader.java:190) java.lang.ClassLoader.loadClass(ClassLoader.java:306) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:247) scala.collection.immutable.Set$Set1.$plus(Set.scala:79) scala.collection.immutable.Set$Set1.$plus(Set.scala:73) scala.collection.mutable.SetBuilder.$plus$eq(SetBuilder.scala:24) scala.collection.mutable.SetBuilder.$plus$eq(SetBuilder.scala:22) scala.collection.generic.Growable$$anonfun$$plus$plus$eq$1.apply(Growable.scala:48) scala.collection.generic.Growable$$anonfun$$plus$plus$eq$1.apply(Growable.scala:48) scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:34) scala.collection.mutable.WrappedArray.foreach(WrappedArray.scala:33) TRACE 300988: java.lang.StringCoding$StringEncoder.encode(StringCoding.java:232) java.lang.StringCoding.encode(StringCoding.java:272) java.lang.String.getBytes(String.java:946) java.io.FileInputStream.open(FileInputStream.java:Unknown line) java.io.FileInputStream.(FileInputStream.java:120) sun.misc.URLClassPath$FileLoader$1.getInputStream(URLClassPath.java:1021) sun.misc.Resource.cachedInputStream(Resource.java:61) sun.misc.Resource.getByteBuffer(Resource.java:144) java.net.URLClassLoader.defineClass(URLClassLoader.java:256) java.net.URLClassLoader.access$000(URLClassLoader.java:58) java.net.URLClassLoader$1.run(URLClassLoader.java:197) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findClass(URLClassLoader.java:190) java.lang.ClassLoader.loadClass(ClassLoader.java:306) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:247) kafka.message.ByteBufferMessageSet.kafka$message$ByteBufferMessageSet$$internalIterator(ByteBufferMessageSet.scala:145) kafka.message.ByteBufferMessageSet.iterator(ByteBufferMessageSet.scala:138) scala.collection.IterableLike$class.isEmpty(IterableLike.scala:82) kafka.message.MessageSet.isEmpty(MessageSet.scala:67) TRACE 300346: java.lang.ClassLoader.findBootstrapClass(ClassLoader.java:Unknown line) java.lang.ClassLoader.findBootstrapClassOrNull(ClassLoader.java:926) java.lang.ClassLoader.loadClass(ClassLoader.java:297) java.lang.ClassLoader.loadClass(ClassLoader.java:295) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:247) scala.math.BigDecimal$.(BigDecimal.scala:28) scala.math.BigDecimal$.(BigDecimal.scala:Unknown line) scala.package$.(package.scala:86) scala.package$.(package.scala:Unknown line) scala.Predef$.(Predef.scala:89) scala.Predef$.(Predef.scala:Unknown line) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:54) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 300261: java.util.Arrays.copyOf(Arrays.java:2786) java.lang.StringCoding.safeTrim(StringCoding.java:64) java.lang.StringCoding.access$300(StringCoding.java:34) java.lang.StringCoding$StringEncoder.encode(StringCoding.java:251) java.lang.StringCoding.encode(StringCoding.java:272) java.lang.String.getBytes(String.java:946) java.io.UnixFileSystem.getBooleanAttributes0(UnixFileSystem.java:Unknown line) java.io.UnixFileSystem.getBooleanAttributes(UnixFileSystem.java:228) java.io.File.exists(File.java:733) sun.misc.URLClassPath$FileLoader.getResource(URLClassPath.java:1015) sun.misc.URLClassPath.getResource(URLClassPath.java:173) java.net.URLClassLoader$1.run(URLClassLoader.java:194) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findClass(URLClassLoader.java:190) java.lang.ClassLoader.loadClass(ClassLoader.java:306) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:247) scala.util.control.NoStackTrace$.(NoStackTrace.scala:26) scala.util.control.NoStackTrace$.(NoStackTrace.scala:Unknown line) scala.util.control.NoStackTrace$class.fillInStackTrace(NoStackTrace.scala:21) TRACE 300638: java.util.Arrays.copyOfRange(Arrays.java:3209) java.lang.String.(String.java:215) java.lang.StringBuilder.toString(StringBuilder.java:430) sun.management.MemoryPoolImpl.(MemoryPoolImpl.java:54) sun.management.ManagementFactory.createMemoryPool(ManagementFactory.java:452) sun.management.MemoryImpl.getMemoryPools0(MemoryImpl.java:Unknown line) sun.management.MemoryImpl.getMemoryPools(MemoryImpl.java:82) sun.management.ManagementFactory.addMemoryPools(ManagementFactory.java:429) sun.management.ManagementFactory.createPlatformMBeanServer(ManagementFactory.java:325) java.lang.management.ManagementFactory.getPlatformMBeanServer(ManagementFactory.java:504) kafka.utils.Utils$.registerMBean(Utils.scala:252) kafka.utils.Log4jController$.(Log4jController.scala:29) kafka.utils.Log4jController$.(Log4jController.scala:Unknown line) kafka.utils.Logging$class.$init$(Logging.scala:29) kafka.message.ByteBufferMessageSet.(ByteBufferMessageSet.scala:98) kafka.message.MessageSet$.(MessageSet.scala:31) kafka.message.MessageSet$.(MessageSet.scala:Unknown line) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:106) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 300678: java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findClass(URLClassLoader.java:190) sun.misc.Launcher$ExtClassLoader.findClass(Launcher.java:229) java.lang.ClassLoader.loadClass(ClassLoader.java:306) java.lang.ClassLoader.loadClass(ClassLoader.java:295) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:247) scala.math.Numeric$IntIsIntegral$.(Numeric.scala:55) scala.math.Numeric$IntIsIntegral$.(Numeric.scala:Unknown line) scala.runtime.RichInt.(RichInt.scala:17) scala.LowPriorityImplicits.intWrapper(LowPriorityImplicits.scala:32) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:107) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 300234: joptsimple.OptionParser.(OptionParser.java:213) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:36) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 300994: java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:631) java.lang.ClassLoader.defineClass(ClassLoader.java:615) java.security.SecureClassLoader.defineClass(SecureClassLoader.java:141) java.net.URLClassLoader.defineClass(URLClassLoader.java:283) java.net.URLClassLoader.access$000(URLClassLoader.java:58) java.net.URLClassLoader$1.run(URLClassLoader.java:197) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findClass(URLClassLoader.java:190) java.lang.ClassLoader.loadClass(ClassLoader.java:306) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:247) scala.collection.TraversableOnce$class.copyToArray(TraversableOnce.scala:226) scala.collection.mutable.ArrayBuffer.copyToArray(ArrayBuffer.scala:47) scala.collection.TraversableOnce$class.toArray(TraversableOnce.scala:234) scala.collection.mutable.ArrayBuffer.toArray(ArrayBuffer.scala:47) scala.collection.immutable.StringLike$class.format(StringLike.scala:270) scala.collection.immutable.StringOps.format(StringOps.scala:31) kafka.log.Log$$anonfun$1.apply(Log.scala:73) kafka.log.Log$$anonfun$1.apply(Log.scala:73) TRACE 300930: java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:631) java.lang.ClassLoader.defineClass(ClassLoader.java:615) java.security.SecureClassLoader.defineClass(SecureClassLoader.java:141) java.net.URLClassLoader.defineClass(URLClassLoader.java:283) java.net.URLClassLoader.access$000(URLClassLoader.java:58) java.net.URLClassLoader$1.run(URLClassLoader.java:197) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findClass(URLClassLoader.java:190) java.lang.ClassLoader.loadClass(ClassLoader.java:306) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:247) scala.collection.immutable.HashSet$HashSet1.updated0(HashSet.scala:118) scala.collection.immutable.HashSet.$plus(HashSet.scala:55) scala.collection.immutable.HashSet.$plus(HashSet.scala:58) scala.collection.immutable.Set$Set4.$plus(Set.scala:139) scala.collection.immutable.Set$Set4.$plus(Set.scala:133) scala.collection.mutable.SetBuilder.$plus$eq(SetBuilder.scala:24) scala.collection.mutable.SetBuilder.$plus$eq(SetBuilder.scala:22) scala.collection.generic.Growable$$anonfun$$plus$plus$eq$1.apply(Growable.scala:48) TRACE 300873: java.lang.ClassLoader.findBootstrapClass(ClassLoader.java:Unknown line) java.lang.ClassLoader.findBootstrapClassOrNull(ClassLoader.java:926) java.lang.ClassLoader.loadClass(ClassLoader.java:297) java.lang.ClassLoader.loadClass(ClassLoader.java:295) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:247) java.util.ResourceBundle$RBClassLoader.loadClass(ResourceBundle.java:435) java.util.ResourceBundle$Control.newBundle(ResourceBundle.java:2289) java.util.ResourceBundle.loadBundle(ResourceBundle.java:1364) java.util.ResourceBundle.findBundle(ResourceBundle.java:1328) java.util.ResourceBundle.findBundle(ResourceBundle.java:1282) java.util.ResourceBundle.findBundle(ResourceBundle.java:1282) java.util.ResourceBundle.getBundleImpl(ResourceBundle.java:1224) java.util.ResourceBundle.getBundle(ResourceBundle.java:822) sun.util.resources.LocaleData$1.run(LocaleData.java:127) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) sun.util.resources.LocaleData.getBundle(LocaleData.java:125) sun.util.resources.LocaleData.getDateFormatData(LocaleData.java:113) java.text.DateFormatSymbols.initializeData(DateFormatSymbols.java:620) java.text.DateFormatSymbols.(DateFormatSymbols.java:123) TRACE 300769: java.util.ArrayList.(ArrayList.java:112) java.util.ArrayList.(ArrayList.java:119) sun.security.util.ManifestEntryVerifier.(ManifestEntryVerifier.java:60) java.util.jar.JarVerifier$VerifierStream.(JarVerifier.java:418) java.util.jar.JarFile.getInputStream(JarFile.java:405) sun.misc.URLClassPath$JarLoader$2.getInputStream(URLClassPath.java:708) sun.misc.Resource.cachedInputStream(Resource.java:61) sun.misc.Resource.getByteBuffer(Resource.java:144) java.net.URLClassLoader.defineClass(URLClassLoader.java:256) java.net.URLClassLoader.access$000(URLClassLoader.java:58) java.net.URLClassLoader$1.run(URLClassLoader.java:197) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findClass(URLClassLoader.java:190) sun.misc.Launcher$ExtClassLoader.findClass(Launcher.java:229) java.lang.ClassLoader.loadClass(ClassLoader.java:306) java.lang.ClassLoader.loadClass(ClassLoader.java:247) sun.security.pkcs11.TemplateManager.addTemplate(TemplateManager.java:83) sun.security.pkcs11.Config.setCompatibilityAttributes(Config.java:783) sun.security.pkcs11.Config.parseAttributes(Config.java:742) sun.security.pkcs11.Config.parse(Config.java:374) TRACE 300374: java.util.zip.Inflater.inflateBytes(Inflater.java:Unknown line) java.util.zip.Inflater.inflate(Inflater.java:238) java.util.zip.InflaterInputStream.read(InflaterInputStream.java:135) sun.misc.Resource.getBytes(Resource.java:108) java.net.URLClassLoader.defineClass(URLClassLoader.java:257) java.net.URLClassLoader.access$000(URLClassLoader.java:58) java.net.URLClassLoader$1.run(URLClassLoader.java:197) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findClass(URLClassLoader.java:190) java.lang.ClassLoader.loadClass(ClassLoader.java:306) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:247) scala.reflect.Manifest$.(Manifest.scala:152) scala.reflect.Manifest$.(Manifest.scala:Unknown line) scala.reflect.ClassManifest$.(ClassManifest.scala:152) scala.reflect.ClassManifest$.(ClassManifest.scala:Unknown line) scala.Predef$.(Predef.scala:104) scala.Predef$.(Predef.scala:Unknown line) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:54) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 300197: java.math.BigInteger.mulAdd(BigInteger.java:1902) java.math.BigInteger.squareToLen(BigInteger.java:1291) java.math.BigInteger.oddModPow(BigInteger.java:1821) java.math.BigInteger.modPow(BigInteger.java:1571) sun.security.provider.DSA.generateV(DSA.java:374) sun.security.provider.DSA.engineVerify(DSA.java:331) sun.security.provider.DSA.engineVerify(DSA.java:283) java.security.Signature$Delegate.engineVerify(Signature.java:1140) java.security.Signature.verify(Signature.java:592) sun.security.pkcs.SignerInfo.verify(SignerInfo.java:374) sun.security.pkcs.PKCS7.verify(PKCS7.java:494) sun.security.pkcs.PKCS7.verify(PKCS7.java:511) sun.security.util.SignatureFileVerifier.processImpl(SignatureFileVerifier.java:197) sun.security.util.SignatureFileVerifier.process(SignatureFileVerifier.java:174) java.util.jar.JarVerifier.processEntry(JarVerifier.java:288) java.util.jar.JarVerifier.update(JarVerifier.java:199) java.util.jar.JarFile.initializeVerifier(JarFile.java:327) java.util.jar.JarFile.getInputStream(JarFile.java:395) sun.misc.JarIndex.getJarIndex(JarIndex.java:120) sun.misc.URLClassPath$JarLoader$1.run(URLClassPath.java:614) TRACE 300403: java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findClass(URLClassLoader.java:190) sun.misc.Launcher$ExtClassLoader.findClass(Launcher.java:229) java.lang.ClassLoader.loadClass(ClassLoader.java:306) java.lang.ClassLoader.loadClass(ClassLoader.java:295) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:247) scala.collection.mutable.ListBuffer.(ListBuffer.scala:45) scala.collection.TraversableOnce$class.toList(TraversableOnce.scala:242) scala.collection.mutable.WrappedArray.toList(WrappedArray.scala:33) scala.collection.immutable.List$.apply(List.scala:465) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:86) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 300937: kafka.TestLinearWriteSpeed$LogWritable.(TestLinearWriteSpeed.scala:203) kafka.TestLinearWriteSpeed$$anonfun$main$1.apply$mcVI$sp(TestLinearWriteSpeed.scala:119) scala.collection.immutable.Range.foreach$mVc$sp(Range.scala:81) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:112) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 300326: java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:631) java.lang.ClassLoader.defineClass(ClassLoader.java:615) java.security.SecureClassLoader.defineClass(SecureClassLoader.java:141) java.net.URLClassLoader.defineClass(URLClassLoader.java:283) java.net.URLClassLoader.access$000(URLClassLoader.java:58) java.net.URLClassLoader$1.run(URLClassLoader.java:197) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findClass(URLClassLoader.java:190) java.lang.ClassLoader.loadClass(ClassLoader.java:306) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:247) scala.sys.SystemProperties$$anonfun$contains$1.apply(SystemProperties.scala:35) scala.sys.SystemProperties.wrapAccess(SystemProperties.scala:41) scala.sys.SystemProperties.contains(SystemProperties.scala:35) scala.sys.SystemProperties.contains(SystemProperties.scala:26) scala.sys.PropImpl.isSet(PropImpl.scala:17) scala.sys.PropImpl.value(PropImpl.scala:16) scala.sys.BooleanProp$BooleanPropImpl.value(BooleanProp.scala:33) scala.util.control.NoStackTrace$.(NoStackTrace.scala:26) TRACE 300825: java.util.zip.ZipFile.getEntry(ZipFile.java:Unknown line) java.util.zip.ZipFile.getEntry(ZipFile.java:163) java.util.jar.JarFile.getEntry(JarFile.java:209) java.util.jar.JarFile.getJarEntry(JarFile.java:192) sun.misc.URLClassPath$JarLoader.getResource(URLClassPath.java:773) sun.misc.URLClassPath.getResource(URLClassPath.java:173) java.net.URLClassLoader$1.run(URLClassLoader.java:194) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findClass(URLClassLoader.java:190) sun.misc.Launcher$ExtClassLoader.findClass(Launcher.java:229) java.lang.ClassLoader.loadClass(ClassLoader.java:306) java.lang.ClassLoader.loadClass(ClassLoader.java:295) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:247) org.apache.log4j.PropertyConfigurator.parseAppender(PropertyConfigurator.java:684) org.apache.log4j.PropertyConfigurator.parseCategory(PropertyConfigurator.java:647) org.apache.log4j.PropertyConfigurator.configureRootCategory(PropertyConfigurator.java:544) org.apache.log4j.PropertyConfigurator.doConfigure(PropertyConfigurator.java:440) org.apache.log4j.PropertyConfigurator.doConfigure(PropertyConfigurator.java:476) org.apache.log4j.helpers.OptionConverter.selectAndConfigure(OptionConverter.java:471) TRACE 301005: java.util.zip.Inflater.inflateBytes(Inflater.java:Unknown line) java.util.zip.Inflater.inflate(Inflater.java:238) java.util.zip.InflaterInputStream.read(InflaterInputStream.java:135) sun.misc.IOUtils.readFully(IOUtils.java:48) java.util.jar.JarFile.getBytes(JarFile.java:369) java.util.jar.JarFile.initializeVerifier(JarFile.java:323) java.util.jar.JarFile.getInputStream(JarFile.java:395) sun.misc.URLClassPath$JarLoader$2.getInputStream(URLClassPath.java:708) sun.misc.Resource.cachedInputStream(Resource.java:61) sun.misc.Resource.getByteBuffer(Resource.java:144) java.net.URLClassLoader.defineClass(URLClassLoader.java:256) java.net.URLClassLoader.access$000(URLClassLoader.java:58) java.net.URLClassLoader$1.run(URLClassLoader.java:197) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findClass(URLClassLoader.java:190) java.lang.ClassLoader.loadClass(ClassLoader.java:306) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:247) org.slf4j.LoggerFactory.bind(LoggerFactory.java:128) org.slf4j.LoggerFactory.performInitialization(LoggerFactory.java:107) TRACE 300198: java.lang.Character.isWhitespace(Character.java:4881) java.lang.Character.isWhitespace(Character.java:4849) sun.security.x509.AVA.toRFC2253CanonicalString(AVA.java:936) sun.security.x509.RDN.toRFC2253StringInternal(RDN.java:430) sun.security.x509.RDN.toRFC2253String(RDN.java:409) sun.security.x509.X500Name.getRFC2253CanonicalName(X500Name.java:714) sun.security.x509.X500Name.equals(X500Name.java:401) sun.security.pkcs.SignerInfo.getCertificateChain(SignerInfo.java:236) sun.security.util.SignatureFileVerifier.getSigners(SignatureFileVerifier.java:464) sun.security.util.SignatureFileVerifier.processImpl(SignatureFileVerifier.java:206) sun.security.util.SignatureFileVerifier.process(SignatureFileVerifier.java:174) java.util.jar.JarVerifier.processEntry(JarVerifier.java:288) java.util.jar.JarVerifier.update(JarVerifier.java:199) java.util.jar.JarFile.initializeVerifier(JarFile.java:327) java.util.jar.JarFile.getInputStream(JarFile.java:395) sun.misc.JarIndex.getJarIndex(JarIndex.java:120) sun.misc.URLClassPath$JarLoader$1.run(URLClassPath.java:614) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) sun.misc.URLClassPath$JarLoader.ensureOpen(URLClassPath.java:605) sun.misc.URLClassPath$JarLoader.(URLClassPath.java:589) TRACE 300249: java.util.zip.Inflater.inflateBytes(Inflater.java:Unknown line) java.util.zip.Inflater.inflate(Inflater.java:238) java.util.zip.InflaterInputStream.read(InflaterInputStream.java:135) sun.misc.Resource.getBytes(Resource.java:108) java.net.URLClassLoader.defineClass(URLClassLoader.java:257) java.net.URLClassLoader.access$000(URLClassLoader.java:58) java.net.URLClassLoader$1.run(URLClassLoader.java:197) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findClass(URLClassLoader.java:190) java.lang.ClassLoader.loadClass(ClassLoader.java:306) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:247) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:54) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 300250: kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:54) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301131: scala.collection.mutable.ArrayBuffer.(ArrayBuffer.scala:47) scala.collection.mutable.ArrayBuffer.(ArrayBuffer.scala:61) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301140: java.io.DataOutputStream.(DataOutputStream.java:187) kafka.message.ByteBufferMessageSet$.kafka$message$ByteBufferMessageSet$$create(ByteBufferMessageSet.scala:41) kafka.message.ByteBufferMessageSet.(ByteBufferMessageSet.scala:106) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301142: java.lang.Object.getClass(Object.java:Unknown line) kafka.utils.Logging$class.$init$(Logging.scala:23) kafka.message.ByteBufferMessageSet.(ByteBufferMessageSet.scala:98) kafka.message.ByteBufferMessageSet.(ByteBufferMessageSet.scala:106) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301143: kafka.utils.Crc32.getValue(Crc32.java:48) kafka.utils.Utils$.crc32(Utils.scala:334) kafka.message.Message.computeChecksum(Message.scala:149) kafka.message.Message.isValid(Message.scala:159) kafka.message.Message.ensureValid(Message.scala:165) kafka.log.Log$$anonfun$analyzeAndValidateMessageSet$1.apply(Log.scala:330) kafka.log.Log$$anonfun$analyzeAndValidateMessageSet$1.apply(Log.scala:318) scala.collection.Iterator$class.foreach(Iterator.scala:772) kafka.utils.IteratorTemplate.foreach(IteratorTemplate.scala:32) kafka.log.Log.analyzeAndValidateMessageSet(Log.scala:318) kafka.log.Log.append(Log.scala:230) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301144: java.lang.Thread.currentThread(Thread.java:Unknown line) java.nio.channels.spi.AbstractInterruptibleChannel.blockedOn(AbstractInterruptibleChannel.java:191) java.nio.channels.spi.AbstractInterruptibleChannel.end(AbstractInterruptibleChannel.java:179) sun.nio.ch.FileChannelImpl.write(FileChannelImpl.java:203) kafka.message.ByteBufferMessageSet.writeTo(ByteBufferMessageSet.scala:132) kafka.log.FileMessageSet.append(FileMessageSet.scala:203) kafka.log.LogSegment.append(LogSegment.scala:80) kafka.log.Log.append(Log.scala:271) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301145: java.nio.Buffer.position(Buffer.java:198) java.nio.HeapByteBuffer.put(HeapByteBuffer.java:166) java.nio.ByteBuffer.put(ByteBuffer.java:813) kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:75) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:178) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) TRACE 301146: java.lang.System.arraycopy(System.java:Unknown line) java.io.ByteArrayInputStream.read(ByteArrayInputStream.java:174) java.io.DataInputStream.read(DataInputStream.java:132) org.xerial.snappy.SnappyCodec.readHeader(SnappyCodec.java:94) org.xerial.snappy.SnappyInputStream.readHeader(SnappyInputStream.java:92) org.xerial.snappy.SnappyInputStream.(SnappyInputStream.java:58) kafka.message.CompressionFactory$.apply(CompressionFactory.scala:45) kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:66) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:178) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) TRACE 301148: kafka.log.Log.trimInvalidBytes(Log.scala:346) kafka.log.Log.append(Log.scala:237) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301150: java.util.concurrent.atomic.AtomicInteger.get(AtomicInteger.java:61) java.util.concurrent.atomic.AtomicInteger.incrementAndGet(AtomicInteger.java:176) kafka.log.OffsetIndex.append(OffsetIndex.scala:198) kafka.log.LogSegment.append(LogSegment.scala:76) kafka.log.Log.append(Log.scala:271) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301151: kafka.message.MessageSet$.messageSetSize(MessageSet.scala:37) kafka.message.ByteBufferMessageSet$.kafka$message$ByteBufferMessageSet$$create(ByteBufferMessageSet.scala:40) kafka.message.ByteBufferMessageSet.(ByteBufferMessageSet.scala:106) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301154: scala.collection.mutable.ArrayBuffer.(ArrayBuffer.scala:47) scala.collection.mutable.ArrayBuffer.(ArrayBuffer.scala:61) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301158: kafka.log.Log$$anonfun$analyzeAndValidateMessageSet$1.apply(Log.scala:318) scala.collection.Iterator$class.foreach(Iterator.scala:772) kafka.utils.IteratorTemplate.foreach(IteratorTemplate.scala:32) kafka.log.Log.analyzeAndValidateMessageSet(Log.scala:318) kafka.log.Log.append(Log.scala:230) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301159: kafka.message.MessageSet$.LogOverhead(MessageSet.scala:30) kafka.message.ByteBufferMessageSet$.kafka$message$ByteBufferMessageSet$$create(ByteBufferMessageSet.scala:55) kafka.message.ByteBufferMessageSet.(ByteBufferMessageSet.scala:106) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301160: kafka.log.Log.analyzeAndValidateMessageSet(Log.scala:337) kafka.log.Log.append(Log.scala:230) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301161: kafka.log.OffsetIndex.append(OffsetIndex.scala:200) kafka.log.LogSegment.append(LogSegment.scala:76) kafka.log.Log.append(Log.scala:271) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301163: kafka.message.Message.isValid(Message.scala:159) kafka.message.Message.ensureValid(Message.scala:165) kafka.log.Log$$anonfun$analyzeAndValidateMessageSet$1.apply(Log.scala:330) kafka.log.Log$$anonfun$analyzeAndValidateMessageSet$1.apply(Log.scala:318) scala.collection.Iterator$class.foreach(Iterator.scala:772) kafka.utils.IteratorTemplate.foreach(IteratorTemplate.scala:32) kafka.log.Log.analyzeAndValidateMessageSet(Log.scala:318) kafka.log.Log.append(Log.scala:230) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) kafka.TestLinearWriteSpeed$.main(TestLinearWriteSpeed.scala:138) kafka.TestLinearWriteSpeed.main(TestLinearWriteSpeed.scala:Unknown line) TRACE 301164: java.nio.HeapByteBuffer.duplicate(HeapByteBuffer.java:89) kafka.message.Message.sliceDelimited(Message.scala:233) kafka.message.Message.payload(Message.scala:218) kafka.message.ByteBufferMessageSet$.decompress(ByteBufferMessageSet.scala:64) kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter(ByteBufferMessageSet.scala:178) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:191) kafka.message.ByteBufferMessageSet$$anon$1.makeNext(ByteBufferMessageSet.scala:145) kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66) kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58) scala.collection.Iterator$$anon$19.hasNext(Iterator.scala:400) scala.collection.Iterator$class.foreach(Iterator.scala:772) scala.collection.Iterator$$anon$19.foreach(Iterator.scala:399) scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:102) scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:250) scala.collection.Iterator$$anon$19.toBuffer(Iterator.scala:399) kafka.message.ByteBufferMessageSet.assignOffsets(ByteBufferMessageSet.scala:219) kafka.log.Log.liftedTree1$1(Log.scala:251) kafka.log.Log.append(Log.scala:250) kafka.TestLinearWriteSpeed$LogWritable.write(TestLinearWriteSpeed.scala:205) TRACE 300267: java.lang.AbstractStringBuilder.(AbstractStringBuilder.java:45) java.lang.StringBuilder.(StringBuilder.java:68) sun.net.www.protocol.jar.Handler.parseURL(Handler.java:74) java.net.URL.(URL.java:596) java.net.URL.(URL.java:464) sun.misc.URLClassPath$JarLoader.checkResource(URLClassPath.java:690) sun.misc.URLClassPath$JarLoader.getResource(URLClassPath.java:775) sun.misc.URLClassPath.getResource(URLClassPath.java:173) java.net.URLClassLoader$1.run(URLClassLoader.java:194) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findClass(URLClassLoader.java:190) java.lang.ClassLoader.loadClass(ClassLoader.java:306) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:247) java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:631) java.lang.ClassLoader.defineClass(ClassLoader.java:615) java.security.SecureClassLoader.defineClass(SecureClassLoader.java:141) java.net.URLClassLoader.defineClass(URLClassLoader.java:283) java.net.URLClassLoader.access$000(URLClassLoader.java:58) TRACE 300287: java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:631) java.lang.ClassLoader.defineClass(ClassLoader.java:615) java.security.SecureClassLoader.defineClass(SecureClassLoader.java:141) java.net.URLClassLoader.defineClass(URLClassLoader.java:283) java.net.URLClassLoader.access$000(URLClassLoader.java:58) java.net.URLClassLoader$1.run(URLClassLoader.java:197) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findClass(URLClassLoader.java:190) java.lang.ClassLoader.loadClass(ClassLoader.java:306) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:247) scala.collection.immutable.List.(List.scala:76) scala.collection.immutable.Nil$.(List.scala:399) scala.collection.immutable.Nil$.(List.scala:Unknown line) scala.sys.SystemProperties$.propertyHelp(SystemProperties.scala:57) scala.sys.SystemProperties$.addHelp(SystemProperties.scala:59) scala.sys.SystemProperties$.bool(SystemProperties.scala:63) scala.sys.SystemProperties$.noTraceSupression(SystemProperties.scala:75) scala.util.control.NoStackTrace$.(NoStackTrace.scala:26) TRACE 300732: java.util.zip.ZipFile.getEntry(ZipFile.java:Unknown line) java.util.zip.ZipFile.getEntry(ZipFile.java:163) java.util.jar.JarFile.getEntry(JarFile.java:209) java.util.jar.JarFile.getJarEntry(JarFile.java:192) sun.misc.URLClassPath$JarLoader.getResource(URLClassPath.java:773) sun.misc.URLClassPath$JarLoader.findResource(URLClassPath.java:751) sun.misc.URLClassPath.findResource(URLClassPath.java:150) java.net.URLClassLoader$2.run(URLClassLoader.java:385) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findResource(URLClassLoader.java:382) java.lang.ClassLoader.getResource(ClassLoader.java:1002) java.lang.ClassLoader.getResource(ClassLoader.java:997) java.lang.ClassLoader.getResourceAsStream(ClassLoader.java:1192) java.lang.Class.getResourceAsStream(Class.java:2057) org.xerial.snappy.SnappyLoader.getByteCode(SnappyLoader.java:145) org.xerial.snappy.SnappyLoader.injectSnappyNativeLoader(SnappyLoader.java:254) org.xerial.snappy.SnappyLoader.load(SnappyLoader.java:217) org.xerial.snappy.Snappy.(Snappy.java:44) org.xerial.snappy.SnappyOutputStream.(SnappyOutputStream.java:79) org.xerial.snappy.SnappyOutputStream.(SnappyOutputStream.java:66) TRACE 300049: sun.security.jca.Providers.(Providers.java:36) sun.security.util.SignatureFileVerifier.(SignatureFileVerifier.java:77) java.util.jar.JarVerifier.processEntry(JarVerifier.java:267) java.util.jar.JarVerifier.update(JarVerifier.java:199) java.util.jar.JarFile.initializeVerifier(JarFile.java:327) java.util.jar.JarFile.getInputStream(JarFile.java:395) sun.misc.JarIndex.getJarIndex(JarIndex.java:120) sun.misc.URLClassPath$JarLoader$1.run(URLClassPath.java:614) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) sun.misc.URLClassPath$JarLoader.ensureOpen(URLClassPath.java:605) sun.misc.URLClassPath$JarLoader.(URLClassPath.java:589) sun.misc.URLClassPath$3.run(URLClassPath.java:337) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) sun.misc.URLClassPath.getLoader(URLClassPath.java:326) sun.misc.URLClassPath.getLoader(URLClassPath.java:303) sun.misc.URLClassPath.getResource(URLClassPath.java:172) java.net.URLClassLoader$1.run(URLClassLoader.java:194) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) java.net.URLClassLoader.findClass(URLClassLoader.java:190) sun.misc.Launcher$ExtClassLoader.findClass(Launcher.java:229) TRACE 300507: sun.awt.SunToolkit.initEQ(SunToolkit.java:77) sun.awt.SunToolkit.createNewAppContext(SunToolkit.java:288) sun.awt.AppContext$2.run(AppContext.java:237) sun.awt.AppContext$2.run(AppContext.java:226) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) sun.awt.AppContext.initMainAppContext(AppContext.java:226) sun.awt.AppContext.access$200(AppContext.java:112) sun.awt.AppContext$3.run(AppContext.java:299) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) sun.awt.AppContext.getAppContext(AppContext.java:280) apple.awt.RuntimeOptions.getCurrentOptions(RuntimeOptions.java:390) apple.awt.CToolkit$LookAndFeelChangeListener.(CToolkit.java:33) apple.awt.CToolkit.(CToolkit.java:46) java.lang.ClassLoader$NativeLibrary.load(ClassLoader.java:Unknown line) java.lang.ClassLoader.loadLibrary0(ClassLoader.java:1827) java.lang.ClassLoader.loadLibrary(ClassLoader.java:1724) java.lang.Runtime.loadLibrary0(Runtime.java:823) java.lang.System.loadLibrary(System.java:1045) sun.security.action.LoadLibraryAction.run(LoadLibraryAction.java:50) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) TRACE 301170: java.lang.ProcessEnvironment.(ProcessEnvironment.java:61) java.lang.System.getenv(System.java:847) com.apple.java.Application$1.run(Application.java:25) com.apple.java.Application$1.run(Application.java:25) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) com.apple.java.Application.getAppTask(Application.java:24) com.apple.java.Usage.performReport(Usage.java:51) com.apple.java.Usage.performAfterDelay(Usage.java:27) CPU SAMPLES BEGIN (total = 4910) Fri Aug 2 21:41:04 2013 rank self accum count trace method 1 16.44% 16.44% 807 301044 org.xerial.snappy.SnappyNative.arrayCopy 2 14.81% 31.24% 727 301073 java.util.Arrays.copyOf 3 9.61% 40.86% 472 301053 org.xerial.snappy.SnappyNative.rawCompress 4 7.45% 48.31% 366 301084 org.xerial.snappy.SnappyNative.rawUncompress 5 5.60% 53.91% 275 301063 java.io.ByteArrayOutputStream. 6 5.13% 59.04% 252 301090 sun.nio.ch.FileDispatcher.write0 7 4.32% 63.36% 212 301074 java.nio.HeapByteBuffer. 8 3.97% 67.33% 195 301049 java.util.Arrays.copyOf 9 3.83% 71.16% 188 301070 org.xerial.snappy.SnappyNative.arrayCopy 10 3.22% 74.38% 158 301068 org.xerial.snappy.SnappyNative.rawUncompress 11 2.10% 76.48% 103 301065 org.xerial.snappy.SnappyNative.arrayCopy 12 1.91% 78.39% 94 301089 java.nio.HeapByteBuffer. 13 1.83% 80.22% 90 301103 kafka.message.ByteBufferMessageSet$$anon$1.innerIter 14 1.45% 81.67% 71 301100 org.xerial.snappy.SnappyNative.rawCompress 15 1.41% 83.08% 69 301137 kafka.message.ByteBufferMessageSet$$anonfun$decompress$3.apply$mcVI$sp 16 1.34% 84.42% 66 301152 kafka.message.ByteBufferMessageSet$$anon$1.innerIter 17 1.28% 85.70% 63 301086 org.xerial.snappy.SnappyOutputStream. 18 1.16% 86.86% 57 301139 org.xerial.snappy.SnappyInputStream.hasNextChunk 19 1.12% 87.98% 55 301138 org.xerial.snappy.SnappyInputStream.hasNextChunk 20 1.04% 89.02% 51 301149 org.xerial.snappy.SnappyOutputStream. 21 1.00% 90.02% 49 301174 java.nio.ByteBuffer.put 22 0.94% 90.96% 46 301104 java.lang.Thread.isInterrupted 23 0.86% 91.81% 42 301085 org.xerial.snappy.SnappyNative.uncompressedLength 24 0.67% 92.48% 33 301064 kafka.message.ByteBufferMessageSet$.decompress 25 0.51% 92.99% 25 301133 java.nio.HeapByteBuffer. 26 0.49% 93.48% 24 301226 sun.nio.ch.FileChannelImpl.force0 27 0.41% 93.89% 20 300491 java.lang.ClassLoader$NativeLibrary.load 28 0.29% 94.18% 14 301175 org.xerial.snappy.SnappyNative.uncompressedLength 29 0.18% 94.36% 9 300024 java.util.zip.ZipFile.open 30 0.18% 94.54% 9 301155 java.lang.Integer.valueOf 31 0.16% 94.70% 8 301081 java.lang.Thread.currentThread 32 0.14% 94.85% 7 301076 org.xerial.snappy.SnappyInputStream. 33 0.14% 94.99% 7 301173 java.util.Arrays.copyOf 34 0.14% 95.13% 7 301061 java.lang.System.arraycopy 35 0.12% 95.25% 6 301227 org.xerial.snappy.SnappyInputStream.readHeader 36 0.12% 95.38% 6 301136 java.lang.System.nanoTime 37 0.12% 95.50% 6 300935 java.io.UnixFileSystem.delete0 38 0.12% 95.62% 6 301147 org.xerial.snappy.SnappyNative.arrayCopy 39 0.08% 95.70% 4 301243 kafka.log.Log.analyzeAndValidateMessageSet 40 0.08% 95.78% 4 301075 java.io.DataInputStream. 41 0.08% 95.87% 4 301141 scala.collection.mutable.ResizableArray$class.$init$ 42 0.08% 95.95% 4 301079 java.lang.Thread.currentThread 43 0.08% 96.03% 4 301099 scala.collection.IndexedSeqOptimized$class.foldLeft 44 0.08% 96.11% 4 301101 java.lang.System.currentTimeMillis 45 0.08% 96.19% 4 301182 kafka.message.CompressionFactory$.apply 46 0.08% 96.27% 4 301237 kafka.message.ByteBufferMessageSet$$anon$1.makeNext 47 0.06% 96.33% 3 301178 org.xerial.snappy.SnappyNative.maxCompressedLength 48 0.06% 96.40% 3 301083 java.lang.System.nanoTime 49 0.06% 96.46% 3 301162 kafka.utils.Utils$.crc32 50 0.06% 96.52% 3 301239 kafka.message.ByteBufferMessageSet$$anon$1.makeNext 51 0.06% 96.58% 3 301240 kafka.message.ByteBufferMessageSet.assignOffsets 52 0.06% 96.64% 3 301179 kafka.message.ByteBufferMessageSet$$anon$1.makeNext 53 0.06% 96.70% 3 301132 java.lang.System.arraycopy 54 0.04% 96.74% 2 301102 java.lang.System.arraycopy 55 0.04% 96.78% 2 301235 kafka.log.Log.maybeRoll 56 0.04% 96.82% 2 300229 java.lang.ClassLoader.defineClass1 57 0.04% 96.86% 2 301233 kafka.log.Log.append 58 0.04% 96.90% 2 301251 scala.collection.immutable.Stream.takeWhile 59 0.04% 96.95% 2 301134 java.util.concurrent.ConcurrentSkipListMap$Node.isBaseHeader 60 0.04% 96.99% 2 301135 sun.misc.Unsafe.putInt 61 0.04% 97.03% 2 301051 scala.collection.mutable.ArrayBuffer.size0 62 0.04% 97.07% 2 301050 java.lang.System.arraycopy 63 0.04% 97.11% 2 301048 scala.collection.mutable.ArrayBuffer.size0 64 0.04% 97.15% 2 301157 kafka.log.Log.maybeRoll 65 0.04% 97.19% 2 301156 kafka.log.OffsetIndex.append 66 0.04% 97.23% 2 301153 scala.collection.mutable.ArrayBuffer.initialSize 67 0.04% 97.27% 2 301181 scala.runtime.BoxesRunTime.equals2 68 0.02% 97.29% 1 300269 scala.sys.SystemProperties$.propertyHelp 69 0.02% 97.31% 1 301172 scala.runtime.BoxesRunTime.equals2 70 0.02% 97.33% 1 301176 scala.collection.Iterator$class.foreach 71 0.02% 97.35% 1 301177 org.xerial.snappy.SnappyInputStream.hasNextChunk 72 0.02% 97.37% 1 301180 kafka.log.Log$$anonfun$analyzeAndValidateMessageSet$1.apply 73 0.02% 97.39% 1 300543 java.util.concurrent.CopyOnWriteArrayList.iterator 74 0.02% 97.41% 1 300693 kafka.utils.Crc32.update 75 0.02% 97.43% 1 300412 sun.misc.Unsafe.compareAndSwapLong 76 0.02% 97.45% 1 300952 java.lang.AbstractStringBuilder. 77 0.02% 97.47% 1 300786 java.security.MessageDigest.update 78 0.02% 97.49% 1 300787 java.security.DigestInputStream.read 79 0.02% 97.52% 1 300788 sun.misc.Unsafe.getInt 80 0.02% 97.54% 1 300311 java.lang.ClassLoader.defineClass1 81 0.02% 97.56% 1 301023 java.io.FileInputStream.open 82 0.02% 97.58% 1 300168 sun.text.normalizer.NormalizerBase. 83 0.02% 97.60% 1 300697 java.lang.ClassLoader.defineClass1 84 0.02% 97.62% 1 300618 java.lang.reflect.Method.hashCode 85 0.02% 97.64% 1 300253 java.lang.System.arraycopy 86 0.02% 97.66% 1 300361 java.lang.StringCoding$StringEncoder.encode 87 0.02% 97.68% 1 300901 java.util.concurrent.ScheduledThreadPoolExecutor. 88 0.02% 97.70% 1 300272 java.lang.ClassLoader.defineClass1 89 0.02% 97.72% 1 300964 java.lang.ClassLoader$NativeLibrary.load 90 0.02% 97.74% 1 300746 java.util.Arrays.copyOfRange 91 0.02% 97.76% 1 300027 java.nio.HeapByteBuffer. 92 0.02% 97.78% 1 300093 sun.security.provider.Sun. 93 0.02% 97.80% 1 301036 java.lang.ClassLoader.findLoadedClass0 94 0.02% 97.82% 1 300296 scala.collection.mutable.Map$.empty 95 0.02% 97.84% 1 301206 java.lang.ClassLoader.defineClass1 96 0.02% 97.86% 1 301207 java.lang.ref.Reference$ReferenceHandler.run 97 0.02% 97.88% 1 301208 java.net.URL. 98 0.02% 97.90% 1 300970 java.lang.ClassLoader$NativeLibrary.find 99 0.02% 97.92% 1 300393 scala.LowPriorityImplicits.wrapRefArray 100 0.02% 97.94% 1 300854 java.util.zip.ZipFile.read 101 0.02% 97.96% 1 300454 java.util.logging.LogManager.readConfiguration 102 0.02% 97.98% 1 300708 sun.misc.Launcher$1.run 103 0.02% 98.00% 1 300591 com.sun.management.OSMBeanFactory.getOperatingSystemMXBean 104 0.02% 98.02% 1 301045 scala.collection.immutable.Stream. 105 0.02% 98.04% 1 301046 java.util.Arrays.copyOf 106 0.02% 98.07% 1 301047 scala.collection.mutable.ArrayBuffer.size0 107 0.02% 98.09% 1 301221 java.nio.channels.spi.AbstractInterruptibleChannel.begin 108 0.02% 98.11% 1 301222 java.lang.Object.hashCode 109 0.02% 98.13% 1 301225 kafka.log.Log.append 110 0.02% 98.15% 1 301052 scala.runtime.BoxesRunTime.equalsNumNum 111 0.02% 98.17% 1 301054 java.nio.Buffer. 112 0.02% 98.19% 1 301231 kafka.log.Log.append 113 0.02% 98.21% 1 301232 kafka.log.Log.analyzeAndValidateMessageSet 114 0.02% 98.23% 1 301234 kafka.log.Log$LogAppendInfo.shallowCount 115 0.02% 98.25% 1 301236 org.xerial.snappy.SnappyInputStream.hasNextChunk 116 0.02% 98.27% 1 301238 kafka.utils.Utils$.crc32 117 0.02% 98.29% 1 301241 kafka.utils.Logging$class.trace 118 0.02% 98.31% 1 301242 kafka.utils.Logging$class.debug 119 0.02% 98.33% 1 301244 sun.misc.Unsafe.compareAndSwapInt 120 0.02% 98.35% 1 301245 java.util.Arrays.copyOfRange 121 0.02% 98.37% 1 301246 java.io.DataInputStream. 122 0.02% 98.39% 1 301247 org.xerial.snappy.SnappyCodec.readHeader 123 0.02% 98.41% 1 301248 java.nio.HeapByteBuffer.slice 124 0.02% 98.43% 1 301249 scala.collection.Iterator$class.map 125 0.02% 98.45% 1 301250 org.xerial.snappy.SnappyInputStream.readHeader 126 0.02% 98.47% 1 301252 com.apple.eawt._AppEventHandler.handleNativeNotification 127 0.02% 98.49% 1 301253 scala.collection.Iterator$class.foreach 128 0.02% 98.51% 1 301254 java.nio.MappedByteBuffer.force0 129 0.02% 98.53% 1 301255 java.util.regex.Pattern$Branch.match 130 0.02% 98.55% 1 301055 kafka.utils.IteratorTemplate.next 131 0.02% 98.57% 1 301056 java.nio.Buffer.hasRemaining 132 0.02% 98.59% 1 301057 java.nio.Bits.makeLong 133 0.02% 98.62% 1 301058 scala.collection.mutable.ArrayBuffer.$plus$eq 134 0.02% 98.64% 1 301060 scala.collection.mutable.ResizableArray$class.ensureSize 135 0.02% 98.66% 1 301059 scala.collection.mutable.ResizableArray$class.$init$ 136 0.02% 98.68% 1 301062 java.io.DataOutputStream. 137 0.02% 98.70% 1 301066 java.lang.System.arraycopy 138 0.02% 98.72% 1 301067 kafka.message.CompressionCodec$.getCompressionCodec 139 0.02% 98.74% 1 301069 kafka.log.Log.append 140 0.02% 98.76% 1 301071 java.lang.System.arraycopy 141 0.02% 98.78% 1 301072 kafka.message.ByteBufferMessageSet$$anon$1.makeNextOuter 142 0.02% 98.80% 1 301077 java.nio.Buffer.limit 143 0.02% 98.82% 1 301078 java.lang.System.arraycopy 144 0.02% 98.84% 1 301080 kafka.message.CompressionFactory$.apply 145 0.02% 98.86% 1 301082 java.lang.Thread.currentThread 146 0.02% 98.88% 1 301087 java.util.concurrent.atomic.AtomicInteger.get 147 0.02% 98.90% 1 301088 sun.misc.Unsafe.compareAndSwapInt 148 0.02% 98.92% 1 301091 kafka.log.OffsetIndex.logger 149 0.02% 98.94% 1 300423 sun.management.ManagementFactory. 150 0.02% 98.96% 1 300914 java.util.Arrays.copyOf 151 0.02% 98.98% 1 300668 java.util.HashMap.get 152 0.02% 99.00% 1 300757 java.lang.ClassLoader.findBootstrapClass 153 0.02% 99.02% 1 300425 java.lang.ClassLoader$NativeLibrary.load 154 0.02% 99.04% 1 300231 java.util.zip.Inflater.inflateBytes 155 0.02% 99.06% 1 300212 sun.net.www.protocol.file.Handler.createFileURLConnection 156 0.02% 99.08% 1 300813 java.io.UnixFileSystem.getBooleanAttributes0 157 0.02% 99.10% 1 300131 sun.security.x509.X509Key.buildX509Key 158 0.02% 99.12% 1 300924 java.lang.ClassLoader.defineClass1 159 0.02% 99.14% 1 300988 java.lang.StringCoding$StringEncoder.encode 160 0.02% 99.16% 1 300346 java.lang.ClassLoader.findBootstrapClass 161 0.02% 99.19% 1 300261 java.util.Arrays.copyOf 162 0.02% 99.21% 1 300638 java.util.Arrays.copyOfRange 163 0.02% 99.23% 1 300678 java.security.AccessController.doPrivileged 164 0.02% 99.25% 1 300234 joptsimple.OptionParser. 165 0.02% 99.27% 1 300994 java.lang.ClassLoader.defineClass1 166 0.02% 99.29% 1 300930 java.lang.ClassLoader.defineClass1 167 0.02% 99.31% 1 300873 java.lang.ClassLoader.findBootstrapClass 168 0.02% 99.33% 1 300769 java.util.ArrayList. 169 0.02% 99.35% 1 300374 java.util.zip.Inflater.inflateBytes 170 0.02% 99.37% 1 300197 java.math.BigInteger.mulAdd 171 0.02% 99.39% 1 300403 java.security.AccessController.doPrivileged 172 0.02% 99.41% 1 300937 kafka.TestLinearWriteSpeed$LogWritable. 173 0.02% 99.43% 1 300326 java.lang.ClassLoader.defineClass1 174 0.02% 99.45% 1 300825 java.util.zip.ZipFile.getEntry 175 0.02% 99.47% 1 301005 java.util.zip.Inflater.inflateBytes 176 0.02% 99.49% 1 300198 java.lang.Character.isWhitespace 177 0.02% 99.51% 1 300249 java.util.zip.Inflater.inflateBytes 178 0.02% 99.53% 1 300250 kafka.TestLinearWriteSpeed$.main 179 0.02% 99.55% 1 301131 scala.collection.mutable.ArrayBuffer. 180 0.02% 99.57% 1 301140 java.io.DataOutputStream. 181 0.02% 99.59% 1 301142 java.lang.Object.getClass 182 0.02% 99.61% 1 301143 kafka.utils.Crc32.getValue 183 0.02% 99.63% 1 301144 java.lang.Thread.currentThread 184 0.02% 99.65% 1 301145 java.nio.Buffer.position 185 0.02% 99.67% 1 301146 java.lang.System.arraycopy 186 0.02% 99.69% 1 301148 kafka.log.Log.trimInvalidBytes 187 0.02% 99.71% 1 301150 java.util.concurrent.atomic.AtomicInteger.get 188 0.02% 99.74% 1 301151 kafka.message.MessageSet$.messageSetSize 189 0.02% 99.76% 1 301154 scala.collection.mutable.ArrayBuffer. 190 0.02% 99.78% 1 301158 kafka.log.Log$$anonfun$analyzeAndValidateMessageSet$1.apply 191 0.02% 99.80% 1 301159 kafka.message.MessageSet$.LogOverhead 192 0.02% 99.82% 1 301160 kafka.log.Log.analyzeAndValidateMessageSet 193 0.02% 99.84% 1 301161 kafka.log.OffsetIndex.append 194 0.02% 99.86% 1 301163 kafka.message.Message.isValid 195 0.02% 99.88% 1 301164 java.nio.HeapByteBuffer.duplicate 196 0.02% 99.90% 1 300267 java.lang.AbstractStringBuilder. 197 0.02% 99.92% 1 300287 java.lang.ClassLoader.defineClass1 198 0.02% 99.94% 1 300732 java.util.zip.ZipFile.getEntry 199 0.02% 99.96% 1 300049 sun.security.jca.Providers. 200 0.02% 99.98% 1 300507 sun.awt.SunToolkit.initEQ 201 0.02% 100.00% 1 301170 java.lang.ProcessEnvironment. CPU SAMPLES END