JAVA PROFILE 1.0.1, created Tue Aug 21 16:44:39 2012 Header for -agentlib:hprof (or -Xrunhprof) ASCII Output (JDK 5.0 JVMTI based) @(#)jvm.hprof.txt 1.5 06/01/28 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=50000142, id = 200001, name="main", group="main") THREAD START (obj=50000142, id = 200004, name="pool-1-thread-1", group="main") THREAD START (obj=500006c9, id = 200005, name="ZkClient-EventThread-12-eat1-qa463.corp.linkedin.com:12913,eat1-qa464.corp.linkedin.com:12913,eat1-qa465.corp.linkedin.com:12913,eat1-qa466.corp.linkedin.com:12913,eat1-qa467.corp.linkedin.com:12913/kafka-samsa", group="main") THREAD START (obj=50000702, id = 200006, name="main-SendThread()", group="main") THREAD START (obj=50000703, id = 200007, name="main-EventThread", group="main") THREAD START (obj=50000142, id = 200008, name="Kafka-consumer-autocommit-0", group="main") THREAD START (obj=500006c9, id = 200009, name="page-key-groups-joiner-dev_criccomi-ld-1345592680172-741deb44_watcher_executor", group="main") THREAD START (obj=500006c9, id = 200010, name="ZkClient-EventThread-17-eat1-qa463.corp.linkedin.com:12913,eat1-qa464.corp.linkedin.com:12913,eat1-qa465.corp.linkedin.com:12913,eat1-qa466.corp.linkedin.com:12913,eat1-qa467.corp.linkedin.com:12913/kafka-samsa", group="main") THREAD START (obj=50000702, id = 200011, name="main-SendThread()", group="main") THREAD START (obj=50000703, id = 200012, name="main-EventThread", group="main") THREAD START (obj=50000142, id = 200013, name="Kafka-consumer-autocommit-0", group="main") THREAD START (obj=500006c9, id = 200014, name="page-key-groups-joiner-dev_criccomi-ld-1345592682946-6515235f_watcher_executor", group="main") THREAD START (obj=500006c9, id = 200015, name="ZkClient-EventThread-22-eat1-qa463.corp.linkedin.com:12913,eat1-qa464.corp.linkedin.com:12913,eat1-qa465.corp.linkedin.com:12913,eat1-qa466.corp.linkedin.com:12913,eat1-qa467.corp.linkedin.com:12913/kafka-samsa", group="main") THREAD START (obj=50000702, id = 200016, name="main-SendThread()", group="main") THREAD START (obj=50000703, id = 200017, name="main-EventThread", group="main") THREAD START (obj=50000142, id = 200018, name="Kafka-consumer-autocommit-0", group="main") THREAD START (obj=500006c9, id = 200019, name="page-key-groups-joiner-dev_criccomi-ld-1345592685391-8507fdfb_watcher_executor", group="main") THREAD START (obj=500006c9, id = 200020, name="ZkClient-EventThread-27-eat1-qa463.corp.linkedin.com:12913,eat1-qa464.corp.linkedin.com:12913,eat1-qa465.corp.linkedin.com:12913,eat1-qa466.corp.linkedin.com:12913,eat1-qa467.corp.linkedin.com:12913/kafka-samsa", group="main") THREAD START (obj=50000702, id = 200021, name="main-SendThread()", group="main") THREAD START (obj=50000703, id = 200022, name="main-EventThread", group="main") THREAD START (obj=50000142, id = 200023, name="Kafka-consumer-autocommit-0", group="main") THREAD START (obj=500006c9, id = 200024, name="page-key-groups-joiner-dev_criccomi-ld-1345592687859-4bf0a3b4_watcher_executor", group="main") THREAD START (obj=500006c9, id = 200025, name="ZkClient-EventThread-32-eat1-qa463.corp.linkedin.com:12913,eat1-qa464.corp.linkedin.com:12913,eat1-qa465.corp.linkedin.com:12913,eat1-qa466.corp.linkedin.com:12913,eat1-qa467.corp.linkedin.com:12913/kafka-samsa", group="main") THREAD START (obj=50000703, id = 200026, name="main-EventThread", group="main") THREAD START (obj=50000702, id = 200027, name="main-SendThread()", group="main") THREAD START (obj=50000142, id = 200028, name="Kafka-consumer-autocommit-0", group="main") THREAD START (obj=500006c9, id = 200029, name="page-key-groups-joiner-dev_criccomi-ld-1345592690390-47fa573b_watcher_executor", group="main") THREAD START (obj=500006c9, id = 200030, name="ZkClient-EventThread-37-eat1-qa463.corp.linkedin.com:12913,eat1-qa464.corp.linkedin.com:12913,eat1-qa465.corp.linkedin.com:12913,eat1-qa466.corp.linkedin.com:12913,eat1-qa467.corp.linkedin.com:12913/kafka-samsa", group="main") THREAD START (obj=50000703, id = 200032, name="main-EventThread", group="main") THREAD START (obj=50000702, id = 200031, name="main-SendThread()", group="main") THREAD START (obj=50000142, id = 200033, name="Kafka-consumer-autocommit-0", group="main") THREAD START (obj=500006c9, id = 200034, name="page-key-groups-joiner-dev_criccomi-ld-1345592692967-4e9ae0b9_watcher_executor", group="main") THREAD START (obj=500006c9, id = 200035, name="ZkClient-EventThread-42-eat1-qa463.corp.linkedin.com:12913,eat1-qa464.corp.linkedin.com:12913,eat1-qa465.corp.linkedin.com:12913,eat1-qa466.corp.linkedin.com:12913,eat1-qa467.corp.linkedin.com:12913/kafka-samsa", group="main") THREAD START (obj=50000702, id = 200036, name="main-SendThread()", group="main") THREAD START (obj=50000703, id = 200037, name="main-EventThread", group="main") THREAD START (obj=50000142, id = 200038, name="Kafka-consumer-autocommit-0", group="main") THREAD START (obj=500006c9, id = 200039, name="page-key-groups-joiner-dev_criccomi-ld-1345592695590-25912f37_watcher_executor", group="main") THREAD START (obj=500006c9, id = 200040, name="ZkClient-EventThread-47-eat1-qa463.corp.linkedin.com:12913,eat1-qa464.corp.linkedin.com:12913,eat1-qa465.corp.linkedin.com:12913,eat1-qa466.corp.linkedin.com:12913,eat1-qa467.corp.linkedin.com:12913/kafka-samsa", group="main") THREAD START (obj=50000702, id = 200041, name="main-SendThread()", group="main") THREAD START (obj=50000703, id = 200042, name="main-EventThread", group="main") THREAD START (obj=50000142, id = 200043, name="Kafka-consumer-autocommit-0", group="main") THREAD START (obj=500006c9, id = 200044, name="page-key-groups-joiner-dev_criccomi-ld-1345592699350-4a00191e_watcher_executor", group="main") THREAD START (obj=500006c9, id = 200045, name="ZkClient-EventThread-52-eat1-qa463.corp.linkedin.com:12913,eat1-qa464.corp.linkedin.com:12913,eat1-qa465.corp.linkedin.com:12913,eat1-qa466.corp.linkedin.com:12913,eat1-qa467.corp.linkedin.com:12913/kafka-samsa", group="main") THREAD START (obj=50000702, id = 200046, name="main-SendThread()", group="main") THREAD START (obj=50000703, id = 200047, name="main-EventThread", group="main") THREAD START (obj=50000142, id = 200048, name="Kafka-consumer-autocommit-0", group="main") THREAD START (obj=500006c9, id = 200049, name="page-key-groups-joiner-dev_criccomi-ld-1345592702078-4bdeff79_watcher_executor", group="main") THREAD START (obj=50000142, id = 200051, name="SIGINT handler", group="system") THREAD START (obj=500006c9, id = 200052, name="Thread-0", group="main") THREAD END (id = 200052) THREAD END (id = 200051) TRACE 300932: sun.nio.ch.EPollArrayWrapper.epollWait(EPollArrayWrapper.java:Unknown line) sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:210) sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:65) sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:69) sun.nio.ch.SelectorImpl.select(SelectorImpl.java:80) org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1066) TRACE 301417: scala.util.parsing.json.Lexer$$anonfun$string$1$$anonfun$apply$13$$anonfun$apply$14.apply(Lexer.scala:45) scala.util.parsing.json.Lexer$$anonfun$string$1$$anonfun$apply$13$$anonfun$apply$14.apply(Lexer.scala:45) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1$$anonfun$apply$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1$$anonfun$apply$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Failure.append(Parsers.scala:162) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$$anonfun$rep1$1.applyp$1(Parsers.scala:582) scala.util.parsing.combinator.Parsers$$anonfun$rep1$1.continue$1(Parsers.scala:587) scala.util.parsing.combinator.Parsers$$anonfun$rep1$1.apply(Parsers.scala:591) scala.util.parsing.combinator.Parsers$$anonfun$rep1$1.apply(Parsers.scala:577) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Success.flatMapWithNext(Parsers.scala:113) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) TRACE 301411: java.lang.Thread.currentThread(Thread.java:Unknown line) java.nio.channels.spi.AbstractInterruptibleChannel.blockedOn(AbstractInterruptibleChannel.java:191) java.nio.channels.spi.AbstractSelector.begin(AbstractSelector.java:196) sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:64) sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:69) sun.nio.ch.SelectorImpl.select(SelectorImpl.java:80) org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1066) TRACE 301433: sun.misc.Unsafe.getInt(Unsafe.java:Unknown line) sun.nio.ch.NativeObject.getInt(NativeObject.java:238) sun.nio.ch.EPollArrayWrapper.getDescriptor(EPollArrayWrapper.java:148) sun.nio.ch.EPollSelectorImpl.updateSelectedKeys(EPollSelectorImpl.java:91) sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:70) sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:69) sun.nio.ch.SelectorImpl.select(SelectorImpl.java:80) org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1066) TRACE 301342: java.lang.Character.toString(Character.java:2135) java.lang.String.valueOf(String.java:2826) scala.collection.mutable.StringBuilder.append(StringBuilder.scala:178) scala.util.parsing.combinator.Parsers$$anonfun$accept$2.apply(Parsers.scala:460) scala.util.parsing.combinator.Parsers$$anonfun$accept$2.apply(Parsers.scala:460) scala.util.parsing.combinator.Parsers$$anonfun$acceptIf$1.apply(Parsers.scala:489) scala.util.parsing.combinator.Parsers$$anonfun$acceptIf$1.apply(Parsers.scala:487) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1$$anonfun$apply$1.apply(Parsers.scala:208) TRACE 301360: java.nio.HeapByteBuffer.(HeapByteBuffer.java:39) java.nio.ByteBuffer.allocate(ByteBuffer.java:312) org.apache.zookeeper.ClientCnxn$SendThread.readLength(ClientCnxn.java:676) org.apache.zookeeper.ClientCnxn$SendThread.doIO(ClientCnxn.java:828) org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1089) TRACE 301412: java.lang.Character.toString(Character.java:2135) java.lang.String.valueOf(String.java:2826) scala.collection.mutable.StringBuilder.append(StringBuilder.scala:178) scala.util.parsing.combinator.Parsers$$anonfun$accept$2.apply(Parsers.scala:460) scala.util.parsing.combinator.Parsers$$anonfun$accept$2.apply(Parsers.scala:460) scala.util.parsing.combinator.Parsers$$anonfun$acceptIf$1.apply(Parsers.scala:489) scala.util.parsing.combinator.Parsers$$anonfun$acceptIf$1.apply(Parsers.scala:487) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) TRACE 301431: java.lang.Integer.toString(Integer.java:308) java.lang.Integer.toString(Integer.java:118) java.lang.String.valueOf(String.java:2931) java.lang.Integer.toString(Integer.java:722) java.lang.String.valueOf(String.java:2826) scala.collection.mutable.StringBuilder.append(StringBuilder.scala:178) kafka.consumer.TopicCount$$anonfun$makeConsumerThreadIdsPerTopic$1$$anonfun$apply$1.apply(TopicCount.scala:39) kafka.consumer.TopicCount$$anonfun$makeConsumerThreadIdsPerTopic$1$$anonfun$apply$1.apply(TopicCount.scala:38) scala.collection.immutable.Range$ByOne$class.foreach(Range.scala:285) scala.collection.immutable.Range$$anon$2.foreach(Range.scala:265) kafka.consumer.TopicCount$$anonfun$makeConsumerThreadIdsPerTopic$1.apply(TopicCount.scala:38) kafka.consumer.TopicCount$$anonfun$makeConsumerThreadIdsPerTopic$1.apply(TopicCount.scala:35) scala.collection.immutable.Map$Map1.foreach(Map.scala:105) kafka.consumer.TopicCount$class.makeConsumerThreadIdsPerTopic(TopicCount.scala:35) kafka.consumer.StaticTopicCount.makeConsumerThreadIdsPerTopic(TopicCount.scala:123) kafka.consumer.StaticTopicCount.getConsumerThreadIdsPerTopic(TopicCount.scala:128) kafka.consumer.StaticTopicCount.getConsumerThreadIdsPerTopic(TopicCount.scala:123) kafka.utils.ZkUtils$$anonfun$getConsumersPerTopic$1.apply(ZkUtils.scala:260) kafka.utils.ZkUtils$$anonfun$getConsumersPerTopic$1.apply(ZkUtils.scala:258) scala.collection.Iterator$class.foreach(Iterator.scala:631) scala.collection.JavaConversions$JIteratorWrapper.foreach(JavaConversions.scala:549) scala.collection.IterableLike$class.foreach(IterableLike.scala:79) scala.collection.JavaConversions$JListWrapper.foreach(JavaConversions.scala:596) kafka.utils.ZkUtils$.getConsumersPerTopic(ZkUtils.scala:258) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance(ZookeeperConsumerConnector.scala:478) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala:449) scala.collection.immutable.Range$ByOne$class.foreach$mVc$sp(Range.scala:282) scala.collection.immutable.Range$$anon$2.foreach$mVc$sp(Range.scala:265) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:444) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anon$1.run(ZookeeperConsumerConnector.scala:401) TRACE 301446: sun.nio.ch.EPollArrayWrapper.interrupt(EPollArrayWrapper.java:Unknown line) sun.nio.ch.EPollArrayWrapper.interrupt(EPollArrayWrapper.java:256) sun.nio.ch.EPollSelectorImpl.wakeup(EPollSelectorImpl.java:175) org.apache.zookeeper.ClientCnxn.queuePacket(ClientCnxn.java:1306) org.apache.zookeeper.ClientCnxn.submitRequest(ClientCnxn.java:1274) org.apache.zookeeper.ZooKeeper.getData(ZooKeeper.java:919) org.apache.zookeeper.ZooKeeper.getData(ZooKeeper.java:950) org.I0Itec.zkclient.ZkConnection.readData(ZkConnection.java:103) org.I0Itec.zkclient.ZkClient$9.call(ZkClient.java:770) org.I0Itec.zkclient.ZkClient$9.call(ZkClient.java:766) org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675) org.I0Itec.zkclient.ZkClient.readData(ZkClient.java:766) org.I0Itec.zkclient.ZkClient.readData(ZkClient.java:761) org.I0Itec.zkclient.ZkClient.readData(ZkClient.java:750) org.I0Itec.zkclient.ZkClient.readData(ZkClient.java:744) kafka.utils.ZkUtils$.readData(ZkUtils.scala:162) kafka.consumer.TopicCount$.constructTopicCount(TopicCount.scala:70) kafka.utils.ZkUtils$$anonfun$getConsumersPerTopic$1.apply(ZkUtils.scala:259) kafka.utils.ZkUtils$$anonfun$getConsumersPerTopic$1.apply(ZkUtils.scala:258) scala.collection.Iterator$class.foreach(Iterator.scala:631) scala.collection.JavaConversions$JIteratorWrapper.foreach(JavaConversions.scala:549) scala.collection.IterableLike$class.foreach(IterableLike.scala:79) scala.collection.JavaConversions$JListWrapper.foreach(JavaConversions.scala:596) kafka.utils.ZkUtils$.getConsumersPerTopic(ZkUtils.scala:258) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance(ZookeeperConsumerConnector.scala:478) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala:449) scala.collection.immutable.Range$ByOne$class.foreach$mVc$sp(Range.scala:282) scala.collection.immutable.Range$$anon$2.foreach$mVc$sp(Range.scala:265) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:444) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anon$1.run(ZookeeperConsumerConnector.scala:401) TRACE 301454: sun.nio.ch.FileDispatcher.write0(FileDispatcher.java:Unknown line) sun.nio.ch.SocketDispatcher.write(SocketDispatcher.java:29) sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:100) sun.nio.ch.IOUtil.write(IOUtil.java:71) sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:334) org.apache.zookeeper.ClientCnxn$SendThread.doIO(ClientCnxn.java:851) org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1089) TRACE 301492: java.lang.Shutdown.halt0(Shutdown.java:Unknown line) java.lang.Shutdown.halt(Shutdown.java:95) java.lang.Shutdown.exit(Shutdown.java:169) java.lang.Terminator$1.handle(Terminator.java:35) sun.misc.Signal$1.run(Signal.java:195) java.lang.Thread.run(Thread.java:619) TRACE 300020: java.util.zip.ZipFile.read(ZipFile.java:Unknown line) java.util.zip.ZipFile.access$1200(ZipFile.java:29) java.util.zip.ZipFile$ZipFileInputStream.read(ZipFile.java:447) java.util.zip.ZipFile$1.fill(ZipFile.java:230) java.util.zip.InflaterInputStream.read(InflaterInputStream.java:141) java.io.DataInputStream.readFully(DataInputStream.java:178) java.util.jar.JarFile.hasClassPathAttribute(JarFile.java:467) java.util.jar.JavaUtilJarAccessImpl.jarFileHasClassPathAttribute(JavaUtilJarAccessImpl.java:21) sun.misc.URLClassPath$JarLoader.getClassPath(URLClassPath.java:903) sun.misc.URLClassPath.getLoader(URLClassPath.java:302) sun.misc.URLClassPath.getResource(URLClassPath.java:168) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) TRACE 300032: java.util.zip.ZipFile.open(ZipFile.java:Unknown line) java.util.zip.ZipFile.(ZipFile.java:114) java.util.jar.JarFile.(JarFile.java:135) java.util.jar.JarFile.(JarFile.java:72) sun.misc.URLClassPath$JarLoader.getJarFile(URLClassPath.java:646) sun.misc.URLClassPath$JarLoader.access$600(URLClassPath.java:540) sun.misc.URLClassPath$JarLoader$1.run(URLClassPath.java:607) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) sun.misc.URLClassPath$JarLoader.ensureOpen(URLClassPath.java:599) sun.misc.URLClassPath$JarLoader.(URLClassPath.java:583) sun.misc.URLClassPath$3.run(URLClassPath.java:333) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) sun.misc.URLClassPath.getLoader(URLClassPath.java:322) sun.misc.URLClassPath.getLoader(URLClassPath.java:299) sun.misc.URLClassPath.getResource(URLClassPath.java:168) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) TRACE 300055: java.util.zip.ZipFile.open(ZipFile.java:Unknown line) java.util.zip.ZipFile.(ZipFile.java:114) java.util.jar.JarFile.(JarFile.java:135) java.util.jar.JarFile.(JarFile.java:72) sun.misc.URLClassPath$JarLoader.getJarFile(URLClassPath.java:646) sun.misc.URLClassPath$JarLoader.access$600(URLClassPath.java:540) sun.misc.URLClassPath$JarLoader$1.run(URLClassPath.java:607) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) sun.misc.URLClassPath$JarLoader.ensureOpen(URLClassPath.java:599) sun.misc.URLClassPath$JarLoader.(URLClassPath.java:583) sun.misc.URLClassPath$3.run(URLClassPath.java:333) java.security.AccessController.doPrivileged(AccessController.java:Unknown line) sun.misc.URLClassPath.getLoader(URLClassPath.java:322) sun.misc.URLClassPath.getLoader(URLClassPath.java:299) sun.misc.URLClassPath.getResource(URLClassPath.java:168) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:632) java.lang.ClassLoader.defineClass(ClassLoader.java:616) 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 300059: 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:999) sun.misc.URLClassPath.getResource(URLClassPath.java:169) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:632) java.lang.ClassLoader.defineClass(ClassLoader.java:616) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) TRACE 300070: java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:632) java.lang.ClassLoader.defineClass(ClassLoader.java:616) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) com.linkedin.samsa.task.JavaTaskRunner$.main(JavaTaskRunner.scala:28) com.linkedin.samsa.task.JavaTaskRunner.main(JavaTaskRunner.scala:Unknown line) TRACE 300075: java.util.zip.ZipFile.getEntry(ZipFile.java:Unknown line) java.util.zip.ZipFile.getEntry(ZipFile.java:149) java.util.jar.JarFile.getEntry(JarFile.java:208) java.util.jar.JarFile.getJarEntry(JarFile.java:191) sun.misc.URLClassPath$JarLoader.getResource(URLClassPath.java:757) sun.misc.URLClassPath.getResource(URLClassPath.java:169) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:632) java.lang.ClassLoader.defineClass(ClassLoader.java:616) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) scala.package$.(package.scala:34) scala.package$.(package.scala:Unknown line) scala.Predef$.(Predef.scala:33) scala.Predef$.(Predef.scala:Unknown line) com.linkedin.samsa.task.JavaTaskRunner$.main(JavaTaskRunner.scala:28) com.linkedin.samsa.task.JavaTaskRunner.main(JavaTaskRunner.scala:Unknown line) TRACE 300087: java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:632) java.lang.ClassLoader.defineClass(ClassLoader.java:616) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) scala.collection.Iterator$$anon$3.(Iterator.scala:27) scala.collection.Iterator$.(Iterator.scala:27) scala.collection.Iterator$.(Iterator.scala:Unknown line) scala.package$.(package.scala:46) scala.package$.(package.scala:Unknown line) scala.Predef$.(Predef.scala:33) scala.Predef$.(Predef.scala:Unknown line) com.linkedin.samsa.task.JavaTaskRunner$.main(JavaTaskRunner.scala:28) com.linkedin.samsa.task.JavaTaskRunner.main(JavaTaskRunner.scala:Unknown line) TRACE 300101: java.lang.String.toCharArray(String.java:2725) sun.net.www.ParseUtil.encodePath(ParseUtil.java:86) sun.misc.URLClassPath$FileLoader.getResource(URLClassPath.java:977) sun.misc.URLClassPath.getResource(URLClassPath.java:169) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) scala.collection.immutable.List.(List.scala:45) scala.collection.immutable.Nil$.(List.scala:383) scala.collection.immutable.Nil$.(List.scala:Unknown line) scala.package$.(package.scala:53) scala.package$.(package.scala:Unknown line) scala.Predef$.(Predef.scala:33) scala.Predef$.(Predef.scala:Unknown line) com.linkedin.samsa.task.JavaTaskRunner$.main(JavaTaskRunner.scala:28) com.linkedin.samsa.task.JavaTaskRunner.main(JavaTaskRunner.scala:Unknown line) TRACE 300119: scala.collection.immutable.Vector$.(Vector.scala:27) scala.collection.immutable.Vector$.(Vector.scala:Unknown line) scala.package$.(package.scala:63) scala.package$.(package.scala:Unknown line) scala.Predef$.(Predef.scala:33) scala.Predef$.(Predef.scala:Unknown line) com.linkedin.samsa.task.JavaTaskRunner$.main(JavaTaskRunner.scala:28) com.linkedin.samsa.task.JavaTaskRunner.main(JavaTaskRunner.scala:Unknown line) TRACE 300147: 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:999) sun.misc.URLClassPath.getResource(URLClassPath.java:169) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) scala.Predef$.(Predef.scala:40) scala.Predef$.(Predef.scala:Unknown line) com.linkedin.samsa.task.JavaTaskRunner$.main(JavaTaskRunner.scala:28) com.linkedin.samsa.task.JavaTaskRunner.main(JavaTaskRunner.scala:Unknown line) TRACE 300177: java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:632) java.lang.ClassLoader.defineClass(ClassLoader.java:616) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) scala.reflect.Manifest$.(Manifest.scala:69) scala.reflect.Manifest$.(Manifest.scala:Unknown line) scala.reflect.ClassManifest$.(ClassManifest.scala:143) scala.reflect.ClassManifest$.(ClassManifest.scala:Unknown line) com.linkedin.samsa.task.JavaTaskRunner$.main(JavaTaskRunner.scala:28) com.linkedin.samsa.task.JavaTaskRunner.main(JavaTaskRunner.scala:Unknown line) TRACE 300201: java.lang.ClassLoader.findBootstrapClass(ClassLoader.java:Unknown line) java.lang.ClassLoader.findBootstrapClassOrNull(ClassLoader.java:927) java.lang.ClassLoader.loadClass(ClassLoader.java:298) java.lang.ClassLoader.loadClass(ClassLoader.java:296) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) scala.collection.mutable.ArrayBuilder.(ArrayBuilder.scala:24) scala.collection.mutable.ArrayBuilder$ofRef.(ArrayBuilder.scala:44) scala.reflect.ClassManifest$class.newArrayBuilder(ClassManifest.scala:121) scala.reflect.ClassManifest$ClassTypeManifest.newArrayBuilder(ClassManifest.scala:197) scala.Array$$anon$2.apply(Array.scala:46) scala.Array$$anon$2.apply(Array.scala:45) scala.collection.TraversableLike$class.map(TraversableLike.scala:204) scala.collection.mutable.ArrayOps.map(ArrayOps.scala:35) com.linkedin.samsa.task.JavaTaskRunner$.main(JavaTaskRunner.scala:28) com.linkedin.samsa.task.JavaTaskRunner.main(JavaTaskRunner.scala:Unknown line) TRACE 300222: java.lang.System.arraycopy(System.java:Unknown line) java.util.jar.Manifest$FastInputStream.readLine(Manifest.java:372) java.util.jar.Manifest$FastInputStream.readLine(Manifest.java:390) java.util.jar.Attributes.read(Attributes.java:359) java.util.jar.Manifest.read(Manifest.java:182) java.util.jar.Manifest.(Manifest.java:52) java.util.jar.JarFile.getManifestFromReference(JarFile.java:162) java.util.jar.JarFile.getManifest(JarFile.java:148) sun.misc.URLClassPath$JarLoader$2.getManifest(URLClassPath.java:696) java.net.URLClassLoader.defineClass(URLClassLoader.java:228) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) com.linkedin.samsa.config.serializers.JsonConfigSerializer$.(JsonConfigSerializer.scala:12) com.linkedin.samsa.config.serializers.JsonConfigSerializer$.(JsonConfigSerializer.scala:Unknown line) com.linkedin.samsa.task.JavaTaskRunner$.main(JavaTaskRunner.scala:33) com.linkedin.samsa.task.JavaTaskRunner.main(JavaTaskRunner.scala:Unknown line) TRACE 300224: java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:632) java.lang.ClassLoader.defineClass(ClassLoader.java:616) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) com.linkedin.samsa.config.serializers.JsonConfigSerializer$.(JsonConfigSerializer.scala:12) com.linkedin.samsa.config.serializers.JsonConfigSerializer$.(JsonConfigSerializer.scala:Unknown line) com.linkedin.samsa.task.JavaTaskRunner$.main(JavaTaskRunner.scala:33) com.linkedin.samsa.task.JavaTaskRunner.main(JavaTaskRunner.scala:Unknown line) TRACE 300234: java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:632) java.lang.ClassLoader.defineClass(ClassLoader.java:616) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) org.codehaus.jackson.map.ObjectMapper.(ObjectMapper.java:196) com.linkedin.samsa.config.serializers.JsonConfigSerializer$.(JsonConfigSerializer.scala:12) com.linkedin.samsa.config.serializers.JsonConfigSerializer$.(JsonConfigSerializer.scala:Unknown line) com.linkedin.samsa.task.JavaTaskRunner$.main(JavaTaskRunner.scala:33) com.linkedin.samsa.task.JavaTaskRunner.main(JavaTaskRunner.scala:Unknown line) TRACE 300286: java.lang.System.arraycopy(System.java:Unknown line) java.io.ByteArrayOutputStream.write(ByteArrayOutputStream.java:96) java.io.DataOutputStream.write(DataOutputStream.java:90) java.io.DataOutputStream.write(DataOutputStream.java:90) java.io.DataOutputStream.writeUTF(DataOutputStream.java:384) java.io.DataOutputStream.writeUTF(DataOutputStream.java:306) sun.misc.ProxyGenerator$ConstantPool$ValueEntry.write(ProxyGenerator.java:1899) sun.misc.ProxyGenerator$ConstantPool.write(ProxyGenerator.java:1806) sun.misc.ProxyGenerator.generateClassFile(ProxyGenerator.java:491) sun.misc.ProxyGenerator.generateProxyClass(ProxyGenerator.java:306) java.lang.reflect.Proxy.getProxyClass(Proxy.java:501) java.lang.reflect.Proxy.newProxyInstance(Proxy.java:581) 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:3070) java.lang.Class.getAnnotation(Class.java:3029) sun.reflect.annotation.AnnotationType.(AnnotationType.java:113) sun.reflect.annotation.AnnotationType.getInstance(AnnotationType.java:66) sun.reflect.annotation.AnnotationParser.parseAnnotation(AnnotationParser.java:202) sun.reflect.annotation.AnnotationParser.parseAnnotations2(AnnotationParser.java:69) sun.reflect.annotation.AnnotationParser.parseAnnotations(AnnotationParser.java:52) java.lang.Class.initAnnotationsIfNecessary(Class.java:3070) java.lang.Class.getAnnotation(Class.java:3029) org.codehaus.jackson.map.introspect.VisibilityChecker$Std.(VisibilityChecker.java:145) org.codehaus.jackson.map.ObjectMapper.(ObjectMapper.java:201) com.linkedin.samsa.config.serializers.JsonConfigSerializer$.(JsonConfigSerializer.scala:12) com.linkedin.samsa.config.serializers.JsonConfigSerializer$.(JsonConfigSerializer.scala:Unknown line) com.linkedin.samsa.task.JavaTaskRunner$.main(JavaTaskRunner.scala:33) TRACE 300302: org.codehaus.jackson.map.ObjectMapper.(ObjectMapper.java:388) org.codehaus.jackson.map.ObjectMapper.(ObjectMapper.java:356) org.codehaus.jackson.map.ObjectMapper.(ObjectMapper.java:326) com.linkedin.samsa.config.serializers.JsonConfigSerializer$.(JsonConfigSerializer.scala:12) com.linkedin.samsa.config.serializers.JsonConfigSerializer$.(JsonConfigSerializer.scala:Unknown line) com.linkedin.samsa.task.JavaTaskRunner$.main(JavaTaskRunner.scala:33) com.linkedin.samsa.task.JavaTaskRunner.main(JavaTaskRunner.scala:Unknown line) TRACE 300355: java.text.SimpleDateFormat.initialize(SimpleDateFormat.java:581) java.text.SimpleDateFormat.(SimpleDateFormat.java:501) java.text.SimpleDateFormat.(SimpleDateFormat.java:476) org.codehaus.jackson.map.util.StdDateFormat.(StdDateFormat.java:79) org.codehaus.jackson.map.MapperConfig.(MapperConfig.java:42) org.codehaus.jackson.map.ObjectMapper.(ObjectMapper.java:389) org.codehaus.jackson.map.ObjectMapper.(ObjectMapper.java:356) org.codehaus.jackson.map.ObjectMapper.(ObjectMapper.java:326) com.linkedin.samsa.config.serializers.JsonConfigSerializer$.(JsonConfigSerializer.scala:12) com.linkedin.samsa.config.serializers.JsonConfigSerializer$.(JsonConfigSerializer.scala:Unknown line) com.linkedin.samsa.task.JavaTaskRunner$.main(JavaTaskRunner.scala:33) com.linkedin.samsa.task.JavaTaskRunner.main(JavaTaskRunner.scala:Unknown line) TRACE 300381: java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:632) java.lang.ClassLoader.defineClass(ClassLoader.java:616) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:632) java.lang.ClassLoader.defineClass(ClassLoader.java:616) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) org.codehaus.jackson.map.ObjectMapper.(ObjectMapper.java:396) org.codehaus.jackson.map.ObjectMapper.(ObjectMapper.java:356) org.codehaus.jackson.map.ObjectMapper.(ObjectMapper.java:326) com.linkedin.samsa.config.serializers.JsonConfigSerializer$.(JsonConfigSerializer.scala:12) com.linkedin.samsa.config.serializers.JsonConfigSerializer$.(JsonConfigSerializer.scala:Unknown line) com.linkedin.samsa.task.JavaTaskRunner$.main(JavaTaskRunner.scala:33) TRACE 300387: java.util.zip.ZipFile.getEntry(ZipFile.java:Unknown line) java.util.zip.ZipFile.getInputStream(ZipFile.java:195) java.util.zip.ZipFile.getInputStream(ZipFile.java:180) java.util.jar.JarFile.getInputStream(JarFile.java:385) sun.misc.URLClassPath$JarLoader$2.getInputStream(URLClassPath.java:692) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) org.codehaus.jackson.map.deser.StdDeserializerProvider.(StdDeserializerProvider.java:84) org.codehaus.jackson.map.ObjectMapper.(ObjectMapper.java:396) org.codehaus.jackson.map.ObjectMapper.(ObjectMapper.java:356) org.codehaus.jackson.map.ObjectMapper.(ObjectMapper.java:326) com.linkedin.samsa.config.serializers.JsonConfigSerializer$.(JsonConfigSerializer.scala:12) com.linkedin.samsa.config.serializers.JsonConfigSerializer$.(JsonConfigSerializer.scala:Unknown line) com.linkedin.samsa.task.JavaTaskRunner$.main(JavaTaskRunner.scala:33) com.linkedin.samsa.task.JavaTaskRunner.main(JavaTaskRunner.scala:Unknown line) TRACE 300399: java.lang.ClassLoader.findBootstrapClass(ClassLoader.java:Unknown line) java.lang.ClassLoader.findBootstrapClassOrNull(ClassLoader.java:927) java.lang.ClassLoader.loadClass(ClassLoader.java:298) java.lang.ClassLoader.loadClass(ClassLoader.java:296) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) org.codehaus.jackson.map.deser.FromStringDeserializer$UUIDDeserializer.(FromStringDeserializer.java:99) org.codehaus.jackson.map.deser.FromStringDeserializer.all(FromStringDeserializer.java:30) org.codehaus.jackson.map.deser.StdDeserializers.(StdDeserializers.java:65) org.codehaus.jackson.map.deser.StdDeserializers.constructAll(StdDeserializers.java:85) org.codehaus.jackson.map.deser.BasicDeserializerFactory.(BasicDeserializerFactory.java:37) org.codehaus.jackson.map.deser.StdDeserializerProvider.(StdDeserializerProvider.java:84) org.codehaus.jackson.map.ObjectMapper.(ObjectMapper.java:396) org.codehaus.jackson.map.ObjectMapper.(ObjectMapper.java:356) org.codehaus.jackson.map.ObjectMapper.(ObjectMapper.java:326) com.linkedin.samsa.config.serializers.JsonConfigSerializer$.(JsonConfigSerializer.scala:12) com.linkedin.samsa.config.serializers.JsonConfigSerializer$.(JsonConfigSerializer.scala:Unknown line) com.linkedin.samsa.task.JavaTaskRunner$.main(JavaTaskRunner.scala:33) com.linkedin.samsa.task.JavaTaskRunner.main(JavaTaskRunner.scala:Unknown line) TRACE 300415: 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:999) sun.misc.URLClassPath.getResource(URLClassPath.java:169) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:632) java.lang.ClassLoader.defineClass(ClassLoader.java:616) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) org.codehaus.jackson.map.deser.BasicDeserializerFactory.(BasicDeserializerFactory.java:94) org.codehaus.jackson.map.deser.StdDeserializerProvider.(StdDeserializerProvider.java:84) org.codehaus.jackson.map.ObjectMapper.(ObjectMapper.java:396) org.codehaus.jackson.map.ObjectMapper.(ObjectMapper.java:356) TRACE 300421: java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:632) java.lang.ClassLoader.defineClass(ClassLoader.java:616) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) org.codehaus.jackson.map.ObjectMapper.(ObjectMapper.java:399) org.codehaus.jackson.map.ObjectMapper.(ObjectMapper.java:356) org.codehaus.jackson.map.ObjectMapper.(ObjectMapper.java:326) com.linkedin.samsa.config.serializers.JsonConfigSerializer$.(JsonConfigSerializer.scala:12) com.linkedin.samsa.config.serializers.JsonConfigSerializer$.(JsonConfigSerializer.scala:Unknown line) com.linkedin.samsa.task.JavaTaskRunner$.main(JavaTaskRunner.scala:33) com.linkedin.samsa.task.JavaTaskRunner.main(JavaTaskRunner.scala:Unknown line) TRACE 300460: org.codehaus.jackson.JsonFactory._createJsonParser(JsonFactory.java:802) org.codehaus.jackson.JsonFactory.createJsonParser(JsonFactory.java:643) org.codehaus.jackson.map.ObjectMapper.readValue(ObjectMapper.java:1602) com.linkedin.samsa.config.serializers.JsonConfigSerializer$.fromJson(JsonConfigSerializer.scala:15) com.linkedin.samsa.task.JavaTaskRunner$.main(JavaTaskRunner.scala:33) com.linkedin.samsa.task.JavaTaskRunner.main(JavaTaskRunner.scala:Unknown line) TRACE 300493: java.lang.Class.getDeclaredConstructors0(Class.java:Unknown line) java.lang.Class.privateGetDeclaredConstructors(Class.java:2389) java.lang.Class.getConstructor0(Class.java:2699) java.lang.Class.getConstructor(Class.java:1657) java.lang.reflect.Proxy.newProxyInstance(Proxy.java:587) 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:3070) java.lang.Class.getDeclaredAnnotations(Class.java:3058) org.codehaus.jackson.map.introspect.AnnotatedClass.resolveClassAnnotations(AnnotatedClass.java:299) org.codehaus.jackson.map.introspect.AnnotatedClass.construct(AnnotatedClass.java:141) org.codehaus.jackson.map.deser.StdDeserializerProvider._createAndCache2(StdDeserializerProvider.java:328) org.codehaus.jackson.map.deser.StdDeserializerProvider._createAndCacheValueDeserializer(StdDeserializerProvider.java:287) org.codehaus.jackson.map.deser.StdDeserializerProvider.findValueDeserializer(StdDeserializerProvider.java:136) org.codehaus.jackson.map.deser.BasicDeserializerFactory.createMapDeserializer(BasicDeserializerFactory.java:367) org.codehaus.jackson.map.deser.StdDeserializerProvider._createDeserializer(StdDeserializerProvider.java:377) org.codehaus.jackson.map.deser.StdDeserializerProvider._createAndCache2(StdDeserializerProvider.java:307) org.codehaus.jackson.map.deser.StdDeserializerProvider._createAndCacheValueDeserializer(StdDeserializerProvider.java:287) org.codehaus.jackson.map.deser.StdDeserializerProvider.findValueDeserializer(StdDeserializerProvider.java:136) org.codehaus.jackson.map.deser.StdDeserializerProvider.findTypedValueDeserializer(StdDeserializerProvider.java:157) org.codehaus.jackson.map.ObjectMapper._findRootDeserializer(ObjectMapper.java:2468) org.codehaus.jackson.map.ObjectMapper._readMapAndClose(ObjectMapper.java:2402) org.codehaus.jackson.map.ObjectMapper.readValue(ObjectMapper.java:1602) com.linkedin.samsa.config.serializers.JsonConfigSerializer$.fromJson(JsonConfigSerializer.scala:15) com.linkedin.samsa.task.JavaTaskRunner$.main(JavaTaskRunner.scala:33) com.linkedin.samsa.task.JavaTaskRunner.main(JavaTaskRunner.scala:Unknown line) TRACE 300511: java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:632) java.lang.ClassLoader.defineClass(ClassLoader.java:616) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:632) java.lang.ClassLoader.defineClass(ClassLoader.java:616) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$3.apply(JavaTaskRunner.scala:51) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$3.apply(JavaTaskRunner.scala:51) scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61) scala.collection.immutable.List.foreach(List.scala:45) TRACE 300525: java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:632) java.lang.ClassLoader.defineClass(ClassLoader.java:616) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) scala.collection.immutable.Map$Map3.updated(Map.scala:144) scala.collection.immutable.Map$Map3.$plus(Map.scala:145) scala.collection.immutable.Map$Map3.$plus(Map.scala:132) scala.collection.mutable.MapBuilder.$plus$eq(MapBuilder.scala:28) scala.collection.mutable.MapBuilder.$plus$eq(MapBuilder.scala:24) scala.collection.TraversableOnce$$anonfun$toMap$1.apply(TraversableOnce.scala:452) scala.collection.TraversableOnce$$anonfun$toMap$1.apply(TraversableOnce.scala:451) scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61) scala.collection.immutable.List.foreach(List.scala:45) scala.collection.TraversableOnce$class.toMap(TraversableOnce.scala:451) scala.collection.immutable.List.toMap(List.scala:45) com.linkedin.samsa.task.JavaTaskRunner.(JavaTaskRunner.scala:51) com.linkedin.samsa.task.JavaTaskRunner$.main(JavaTaskRunner.scala:35) com.linkedin.samsa.task.JavaTaskRunner.main(JavaTaskRunner.scala:Unknown line) TRACE 300562: com.linkedin.samsa.metrics.JvmMetrics.(JvmMetrics.scala:24) com.linkedin.samsa.task.JavaTaskRunner.(JavaTaskRunner.scala:55) com.linkedin.samsa.task.JavaTaskRunner$.main(JavaTaskRunner.scala:35) com.linkedin.samsa.task.JavaTaskRunner.main(JavaTaskRunner.scala:Unknown line) TRACE 300581: java.lang.String.toCharArray(String.java:2725) sun.net.www.ParseUtil.encodePath(ParseUtil.java:86) sun.misc.URLClassPath$JarLoader.checkResource(URLClassPath.java:674) sun.misc.URLClassPath$JarLoader.getResource(URLClassPath.java:759) sun.misc.URLClassPath.getResource(URLClassPath.java:169) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) org.apache.log4j.LogManager.(LogManager.java:83) org.slf4j.impl.Log4jLoggerFactory.getLogger(Log4jLoggerFactory.java:73) org.slf4j.LoggerFactory.getLogger(LoggerFactory.java:253) grizzled.slf4j.Logger$.apply(slf4j.scala:313) grizzled.slf4j.Logger$.apply(slf4j.scala:322) grizzled.slf4j.Logging$class.grizzled$slf4j$Logging$$_logger(slf4j.scala:181) com.linkedin.samsa.metrics.MetricsRegistryMap.grizzled$slf4j$Logging$$_logger(MetricsRegistryMap.scala:9) grizzled.slf4j.Logging$class.logger(slf4j.scala:189) com.linkedin.samsa.metrics.MetricsRegistryMap.logger(MetricsRegistryMap.scala:9) grizzled.slf4j.Logging$class.debug(slf4j.scala:226) com.linkedin.samsa.metrics.MetricsRegistryMap.debug(MetricsRegistryMap.scala:9) com.linkedin.samsa.metrics.MetricsRegistryMap.newGauge(MetricsRegistryMap.scala:26) com.linkedin.samsa.metrics.JvmMetrics.(JvmMetrics.scala:24) com.linkedin.samsa.task.JavaTaskRunner.(JavaTaskRunner.scala:55) com.linkedin.samsa.task.JavaTaskRunner$.main(JavaTaskRunner.scala:35) com.linkedin.samsa.task.JavaTaskRunner.main(JavaTaskRunner.scala:Unknown line) TRACE 300606: 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) org.apache.log4j.PatternLayout.createPatternParser(PatternLayout.java:488) org.apache.log4j.PatternLayout.(PatternLayout.java:438) org.apache.log4j.PatternLayout.(PatternLayout.java:430) 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:355) java.lang.Class.newInstance(Class.java:308) org.apache.log4j.helpers.OptionConverter.instantiateByClassName(OptionConverter.java:336) org.apache.log4j.helpers.OptionConverter.instantiateByKey(OptionConverter.java:123) org.apache.log4j.PropertyConfigurator.parseAppender(PropertyConfigurator.java:764) org.apache.log4j.PropertyConfigurator.parseCategory(PropertyConfigurator.java:735) org.apache.log4j.PropertyConfigurator.configureRootCategory(PropertyConfigurator.java:615) org.apache.log4j.PropertyConfigurator.doConfigure(PropertyConfigurator.java:502) org.apache.log4j.PropertyConfigurator.doConfigure(PropertyConfigurator.java:547) org.apache.log4j.helpers.OptionConverter.selectAndConfigure(OptionConverter.java:483) org.apache.log4j.LogManager.(LogManager.java:127) TRACE 300649: 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:999) sun.misc.URLClassPath.getResource(URLClassPath.java:169) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) org.apache.log4j.Hierarchy.getLogger(Hierarchy.java:266) org.apache.log4j.PropertyConfigurator.parseCatsAndRenderers(PropertyConfigurator.java:637) org.apache.log4j.PropertyConfigurator.doConfigure(PropertyConfigurator.java:504) org.apache.log4j.PropertyConfigurator.doConfigure(PropertyConfigurator.java:547) org.apache.log4j.helpers.OptionConverter.selectAndConfigure(OptionConverter.java:483) org.apache.log4j.LogManager.(LogManager.java:127) org.slf4j.impl.Log4jLoggerFactory.getLogger(Log4jLoggerFactory.java:73) org.slf4j.LoggerFactory.getLogger(LoggerFactory.java:253) grizzled.slf4j.Logger$.apply(slf4j.scala:313) grizzled.slf4j.Logger$.apply(slf4j.scala:322) grizzled.slf4j.Logging$class.grizzled$slf4j$Logging$$_logger(slf4j.scala:181) com.linkedin.samsa.metrics.MetricsRegistryMap.grizzled$slf4j$Logging$$_logger(MetricsRegistryMap.scala:9) grizzled.slf4j.Logging$class.logger(slf4j.scala:189) com.linkedin.samsa.metrics.MetricsRegistryMap.logger(MetricsRegistryMap.scala:9) grizzled.slf4j.Logging$class.debug(slf4j.scala:226) com.linkedin.samsa.metrics.MetricsRegistryMap.debug(MetricsRegistryMap.scala:9) com.linkedin.samsa.metrics.MetricsRegistryMap.newGauge(MetricsRegistryMap.scala:26) com.linkedin.samsa.metrics.JvmMetrics.(JvmMetrics.scala:24) com.linkedin.samsa.task.JavaTaskRunner.(JavaTaskRunner.scala:55) TRACE 300678: java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:632) java.lang.ClassLoader.defineClass(ClassLoader.java:616) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) scala.collection.mutable.IndexedSeq$.newBuilder(IndexedSeq.scala:35) scala.collection.generic.GenericTraversableTemplate$class.genericBuilder(GenericTraversableTemplate.scala:65) scala.collection.mutable.WrappedArray.genericBuilder(WrappedArray.scala:32) scala.collection.generic.TraversableFactory$GenericCanBuildFrom.apply(TraversableFactory.scala:49) scala.collection.generic.TraversableFactory$GenericCanBuildFrom.apply(TraversableFactory.scala:44) scala.collection.TraversableLike$class.map(TraversableLike.scala:204) scala.collection.mutable.WrappedArray.map(WrappedArray.scala:32) scala.collection.immutable.StringLike$class.format(StringLike.scala:252) scala.collection.immutable.StringOps.format(StringOps.scala:31) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$5$$anonfun$apply$1.apply(JavaTaskRunner.scala:66) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$5$$anonfun$apply$1.apply(JavaTaskRunner.scala:66) grizzled.slf4j.Logger.info(slf4j.scala:126) grizzled.slf4j.Logging$class.info(slf4j.scala:266) com.linkedin.samsa.task.JavaTaskRunner.info(JavaTaskRunner.scala:39) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$5.apply(JavaTaskRunner.scala:66) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$5.apply(JavaTaskRunner.scala:65) scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) TRACE 300679: scala.collection.JavaConversions$.asScalaBuffer(JavaConversions.scala:432) com.linkedin.samsa.metrics.JvmMetrics.updateGcUsage(JvmMetrics.scala:67) com.linkedin.samsa.metrics.JvmMetrics.run(JvmMetrics.scala:43) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441) java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java:317) 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:181) java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:205) java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) java.lang.Thread.run(Thread.java:619) TRACE 300720: 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) com.linkedin.samsa.task.GeneratorLifecycleListenerFactory.getLifecyleListener(GeneratorLifecycleListenerFactory.scala:10) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$5.apply(JavaTaskRunner.scala:68) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$5.apply(JavaTaskRunner.scala:65) scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:34) scala.collection.mutable.ArrayOps.foreach(ArrayOps.scala:35) scala.collection.TraversableLike$class.map(TraversableLike.scala:206) scala.collection.mutable.ArrayOps.map(ArrayOps.scala:35) com.linkedin.samsa.task.JavaTaskRunner.(JavaTaskRunner.scala:65) com.linkedin.samsa.task.JavaTaskRunner$.main(JavaTaskRunner.scala:35) com.linkedin.samsa.task.JavaTaskRunner.main(JavaTaskRunner.scala:Unknown line) TRACE 300751: 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) scala.collection.MapLike$class.keySet(MapLike.scala:160) scala.collection.JavaConversions$JMapWrapper.keySet(JavaConversions.scala:772) scala.collection.MapLike$class.keys(MapLike.scala:188) scala.collection.JavaConversions$JMapWrapper.keys(JavaConversions.scala:772) com.linkedin.samsa.config.StreamConfig.getStreamNames(StreamConfig.scala:36) com.linkedin.samsa.config.StreamConfig.getStreamMap(StreamConfig.scala:44) com.linkedin.samsa.task.JavaTaskRunner$$anon$2.(JavaTaskRunner.scala:84) com.linkedin.samsa.task.JavaTaskRunner.(JavaTaskRunner.scala:82) com.linkedin.samsa.task.JavaTaskRunner$.main(JavaTaskRunner.scala:35) com.linkedin.samsa.task.JavaTaskRunner.main(JavaTaskRunner.scala:Unknown line) TRACE 300768: scala.collection.immutable.Set$Set2.$plus(Set.scala:93) scala.collection.immutable.Set$Set2.$plus(Set.scala:87) scala.collection.mutable.AddingBuilder.$plus$eq(AddingBuilder.scala:33) scala.collection.mutable.AddingBuilder.$plus$eq(AddingBuilder.scala:30) scala.collection.TraversableLike$$anonfun$filter$1.apply(TraversableLike.scala:240) scala.collection.MapLike$DefaultKeySet$$anonfun$foreach$2.apply(MapLike.scala:170) scala.collection.MapLike$DefaultKeySet$$anonfun$foreach$2.apply(MapLike.scala:170) scala.collection.Iterator$class.foreach(Iterator.scala:631) scala.collection.JavaConversions$JMapWrapperLike$$anon$2.foreach(JavaConversions.scala:761) scala.collection.IterableLike$class.foreach(IterableLike.scala:79) scala.collection.JavaConversions$JMapWrapper.foreach(JavaConversions.scala:772) scala.collection.MapLike$DefaultKeySet.foreach(MapLike.scala:170) scala.collection.TraversableLike$class.filter(TraversableLike.scala:239) scala.collection.MapLike$DefaultKeySet.filter(MapLike.scala:164) com.linkedin.samsa.config.StreamConfig.getStreamNames(StreamConfig.scala:36) com.linkedin.samsa.config.StreamConfig.getStreamMap(StreamConfig.scala:44) com.linkedin.samsa.task.JavaTaskRunner$$anon$2.(JavaTaskRunner.scala:84) com.linkedin.samsa.task.JavaTaskRunner.(JavaTaskRunner.scala:82) com.linkedin.samsa.task.JavaTaskRunner$.main(JavaTaskRunner.scala:35) com.linkedin.samsa.task.JavaTaskRunner.main(JavaTaskRunner.scala:Unknown line) TRACE 300799: java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:632) java.lang.ClassLoader.defineClass(ClassLoader.java:616) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) java.lang.Class.forName0(Class.java:Unknown line) java.lang.Class.forName(Class.java:169) com.linkedin.samsa.task.CachingStreamManager$class.com$linkedin$samsa$task$CachingStreamManager$$getOrAddConsumerFactory(CachingStreamManager.scala:46) com.linkedin.samsa.task.CachingStreamManager$$anonfun$1.apply(CachingStreamManager.scala:22) com.linkedin.samsa.task.CachingStreamManager$$anonfun$1.apply(CachingStreamManager.scala:22) com.linkedin.samsa.util.ObjectCache.get(ObjectCache.scala:10) com.linkedin.samsa.task.CachingStreamManager$class.com$linkedin$samsa$task$CachingStreamManager$$getOrAddConsumer(CachingStreamManager.scala:36) com.linkedin.samsa.task.CachingStreamManager$$anonfun$3.apply(CachingStreamManager.scala:24) com.linkedin.samsa.task.CachingStreamManager$$anonfun$3.apply(CachingStreamManager.scala:24) com.linkedin.samsa.util.ObjectCache.get(ObjectCache.scala:10) com.linkedin.samsa.task.CachingStreamManager$class.getConsumer(CachingStreamManager.scala:27) com.linkedin.samsa.task.JavaTaskRunner$$anon$1.getConsumer(JavaTaskRunner.scala:77) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$9$$anonfun$apply$2.apply(JavaTaskRunner.scala:107) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$9$$anonfun$apply$2.apply(JavaTaskRunner.scala:104) scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61) scala.collection.immutable.List.foreach(List.scala:45) TRACE 300820: java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:632) java.lang.ClassLoader.defineClass(ClassLoader.java:616) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) kafka.consumer.ZookeeperConsumerConnector.(ZookeeperConsumerConnector.scala:88) kafka.consumer.ZookeeperConsumerConnector.(ZookeeperConsumerConnector.scala:129) kafka.consumer.Consumer$.create(ConsumerConnector.scala:76) com.linkedin.samsa.stream.kafka.KafkaConsumer.connect(KafkaConsumer.scala:87) com.linkedin.samsa.stream.kafka.KafkaConsumer.(KafkaConsumer.scala:17) com.linkedin.samsa.stream.kafka.KafkaConsumerFactory.getConsumer(KafkaConsumerFactory.scala:46) com.linkedin.samsa.stream.kafka.KafkaConsumerFactory.getConsumer(KafkaConsumerFactory.scala:27) com.linkedin.samsa.task.CachingStreamManager$class.com$linkedin$samsa$task$CachingStreamManager$$getOrAddConsumer(CachingStreamManager.scala:36) com.linkedin.samsa.task.CachingStreamManager$$anonfun$3.apply(CachingStreamManager.scala:24) com.linkedin.samsa.task.CachingStreamManager$$anonfun$3.apply(CachingStreamManager.scala:24) com.linkedin.samsa.util.ObjectCache.get(ObjectCache.scala:10) com.linkedin.samsa.task.CachingStreamManager$class.getConsumer(CachingStreamManager.scala:27) com.linkedin.samsa.task.JavaTaskRunner$$anon$1.getConsumer(JavaTaskRunner.scala:77) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$9$$anonfun$apply$2.apply(JavaTaskRunner.scala:107) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$9$$anonfun$apply$2.apply(JavaTaskRunner.scala:104) scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61) TRACE 300862: java.net.Inet6AddressImpl.lookupAllHostAddr(Inet6AddressImpl.java:Unknown line) java.net.InetAddress$1.lookupAllHostAddr(InetAddress.java:850) java.net.InetAddress.getAddressFromNameService(InetAddress.java:1201) java.net.InetAddress.getLocalHost(InetAddress.java:1351) kafka.consumer.ZookeeperConsumerConnector.(ZookeeperConsumerConnector.scala:115) kafka.consumer.ZookeeperConsumerConnector.(ZookeeperConsumerConnector.scala:129) kafka.consumer.Consumer$.create(ConsumerConnector.scala:76) com.linkedin.samsa.stream.kafka.KafkaConsumer.connect(KafkaConsumer.scala:87) com.linkedin.samsa.stream.kafka.KafkaConsumer.(KafkaConsumer.scala:17) com.linkedin.samsa.stream.kafka.KafkaConsumerFactory.getConsumer(KafkaConsumerFactory.scala:46) com.linkedin.samsa.stream.kafka.KafkaConsumerFactory.getConsumer(KafkaConsumerFactory.scala:27) com.linkedin.samsa.task.CachingStreamManager$class.com$linkedin$samsa$task$CachingStreamManager$$getOrAddConsumer(CachingStreamManager.scala:36) com.linkedin.samsa.task.CachingStreamManager$$anonfun$3.apply(CachingStreamManager.scala:24) com.linkedin.samsa.task.CachingStreamManager$$anonfun$3.apply(CachingStreamManager.scala:24) com.linkedin.samsa.util.ObjectCache.get(ObjectCache.scala:10) com.linkedin.samsa.task.CachingStreamManager$class.getConsumer(CachingStreamManager.scala:27) com.linkedin.samsa.task.JavaTaskRunner$$anon$1.getConsumer(JavaTaskRunner.scala:77) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$9$$anonfun$apply$2.apply(JavaTaskRunner.scala:107) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$9$$anonfun$apply$2.apply(JavaTaskRunner.scala:104) scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61) scala.collection.immutable.List.foreach(List.scala:45) scala.collection.TraversableLike$class.map(TraversableLike.scala:206) scala.collection.immutable.List.map(List.scala:45) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$9.apply(JavaTaskRunner.scala:104) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$9.apply(JavaTaskRunner.scala:103) scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61) TRACE 300872: kafka.consumer.ZookeeperConsumerConnector$$anonfun$connectZk$1.(ZookeeperConsumerConnector.scala:Unknown line) kafka.consumer.ZookeeperConsumerConnector.connectZk(ZookeeperConsumerConnector.scala:151) kafka.consumer.ZookeeperConsumerConnector.(ZookeeperConsumerConnector.scala:122) kafka.consumer.ZookeeperConsumerConnector.(ZookeeperConsumerConnector.scala:129) kafka.consumer.Consumer$.create(ConsumerConnector.scala:76) com.linkedin.samsa.stream.kafka.KafkaConsumer.connect(KafkaConsumer.scala:87) com.linkedin.samsa.stream.kafka.KafkaConsumer.(KafkaConsumer.scala:17) com.linkedin.samsa.stream.kafka.KafkaConsumerFactory.getConsumer(KafkaConsumerFactory.scala:46) com.linkedin.samsa.stream.kafka.KafkaConsumerFactory.getConsumer(KafkaConsumerFactory.scala:27) com.linkedin.samsa.task.CachingStreamManager$class.com$linkedin$samsa$task$CachingStreamManager$$getOrAddConsumer(CachingStreamManager.scala:36) com.linkedin.samsa.task.CachingStreamManager$$anonfun$3.apply(CachingStreamManager.scala:24) com.linkedin.samsa.task.CachingStreamManager$$anonfun$3.apply(CachingStreamManager.scala:24) com.linkedin.samsa.util.ObjectCache.get(ObjectCache.scala:10) com.linkedin.samsa.task.CachingStreamManager$class.getConsumer(CachingStreamManager.scala:27) com.linkedin.samsa.task.JavaTaskRunner$$anon$1.getConsumer(JavaTaskRunner.scala:77) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$9$$anonfun$apply$2.apply(JavaTaskRunner.scala:107) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$9$$anonfun$apply$2.apply(JavaTaskRunner.scala:104) scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61) scala.collection.immutable.List.foreach(List.scala:45) scala.collection.TraversableLike$class.map(TraversableLike.scala:206) scala.collection.immutable.List.map(List.scala:45) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$9.apply(JavaTaskRunner.scala:104) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$9.apply(JavaTaskRunner.scala:103) scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61) scala.collection.immutable.List.foreach(List.scala:45) scala.collection.TraversableLike$class.map(TraversableLike.scala:206) TRACE 300884: java.util.zip.ZipFile.getEntry(ZipFile.java:Unknown line) java.util.zip.ZipFile.getEntry(ZipFile.java:149) java.util.jar.JarFile.getEntry(JarFile.java:208) java.util.jar.JarFile.getJarEntry(JarFile.java:191) sun.misc.URLClassPath$JarLoader.getResource(URLClassPath.java:757) sun.misc.URLClassPath.getResource(URLClassPath.java:169) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) org.I0Itec.zkclient.ZkConnection.connect(ZkConnection.java:64) org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:872) org.I0Itec.zkclient.ZkClient.(ZkClient.java:98) org.I0Itec.zkclient.ZkClient.(ZkClient.java:84) kafka.consumer.ZookeeperConsumerConnector.connectZk(ZookeeperConsumerConnector.scala:152) kafka.consumer.ZookeeperConsumerConnector.(ZookeeperConsumerConnector.scala:122) kafka.consumer.ZookeeperConsumerConnector.(ZookeeperConsumerConnector.scala:129) kafka.consumer.Consumer$.create(ConsumerConnector.scala:76) com.linkedin.samsa.stream.kafka.KafkaConsumer.connect(KafkaConsumer.scala:87) com.linkedin.samsa.stream.kafka.KafkaConsumer.(KafkaConsumer.scala:17) com.linkedin.samsa.stream.kafka.KafkaConsumerFactory.getConsumer(KafkaConsumerFactory.scala:46) com.linkedin.samsa.stream.kafka.KafkaConsumerFactory.getConsumer(KafkaConsumerFactory.scala:27) com.linkedin.samsa.task.CachingStreamManager$class.com$linkedin$samsa$task$CachingStreamManager$$getOrAddConsumer(CachingStreamManager.scala:36) com.linkedin.samsa.task.CachingStreamManager$$anonfun$3.apply(CachingStreamManager.scala:24) com.linkedin.samsa.task.CachingStreamManager$$anonfun$3.apply(CachingStreamManager.scala:24) com.linkedin.samsa.util.ObjectCache.get(ObjectCache.scala:10) com.linkedin.samsa.task.CachingStreamManager$class.getConsumer(CachingStreamManager.scala:27) com.linkedin.samsa.task.JavaTaskRunner$$anon$1.getConsumer(JavaTaskRunner.scala:77) TRACE 300909: java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:632) java.lang.ClassLoader.defineClass(ClassLoader.java:616) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) org.apache.zookeeper.ClientCnxn.(ClientCnxn.java:392) org.apache.zookeeper.ClientCnxn.(ClientCnxn.java:328) org.apache.zookeeper.ZooKeeper.(ZooKeeper.java:377) org.I0Itec.zkclient.ZkConnection.connect(ZkConnection.java:64) org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:872) org.I0Itec.zkclient.ZkClient.(ZkClient.java:98) org.I0Itec.zkclient.ZkClient.(ZkClient.java:84) kafka.consumer.ZookeeperConsumerConnector.connectZk(ZookeeperConsumerConnector.scala:152) kafka.consumer.ZookeeperConsumerConnector.(ZookeeperConsumerConnector.scala:122) kafka.consumer.ZookeeperConsumerConnector.(ZookeeperConsumerConnector.scala:129) kafka.consumer.Consumer$.create(ConsumerConnector.scala:76) com.linkedin.samsa.stream.kafka.KafkaConsumer.connect(KafkaConsumer.scala:87) com.linkedin.samsa.stream.kafka.KafkaConsumer.(KafkaConsumer.scala:17) com.linkedin.samsa.stream.kafka.KafkaConsumerFactory.getConsumer(KafkaConsumerFactory.scala:46) com.linkedin.samsa.stream.kafka.KafkaConsumerFactory.getConsumer(KafkaConsumerFactory.scala:27) com.linkedin.samsa.task.CachingStreamManager$class.com$linkedin$samsa$task$CachingStreamManager$$getOrAddConsumer(CachingStreamManager.scala:36) com.linkedin.samsa.task.CachingStreamManager$$anonfun$3.apply(CachingStreamManager.scala:24) com.linkedin.samsa.task.CachingStreamManager$$anonfun$3.apply(CachingStreamManager.scala:24) TRACE 300948: 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) scala.runtime.AbstractFunction0$mcV$sp.(AbstractFunction0.scala:17) kafka.consumer.ZookeeperConsumerConnector$$anonfun$1.(ZookeeperConsumerConnector.scala:126) kafka.consumer.ZookeeperConsumerConnector.(ZookeeperConsumerConnector.scala:126) kafka.consumer.ZookeeperConsumerConnector.(ZookeeperConsumerConnector.scala:129) kafka.consumer.Consumer$.create(ConsumerConnector.scala:76) com.linkedin.samsa.stream.kafka.KafkaConsumer.connect(KafkaConsumer.scala:87) com.linkedin.samsa.stream.kafka.KafkaConsumer.(KafkaConsumer.scala:17) com.linkedin.samsa.stream.kafka.KafkaConsumerFactory.getConsumer(KafkaConsumerFactory.scala:46) com.linkedin.samsa.stream.kafka.KafkaConsumerFactory.getConsumer(KafkaConsumerFactory.scala:27) com.linkedin.samsa.task.CachingStreamManager$class.com$linkedin$samsa$task$CachingStreamManager$$getOrAddConsumer(CachingStreamManager.scala:36) com.linkedin.samsa.task.CachingStreamManager$$anonfun$3.apply(CachingStreamManager.scala:24) com.linkedin.samsa.task.CachingStreamManager$$anonfun$3.apply(CachingStreamManager.scala:24) com.linkedin.samsa.util.ObjectCache.get(ObjectCache.scala:10) com.linkedin.samsa.task.CachingStreamManager$class.getConsumer(CachingStreamManager.scala:27) com.linkedin.samsa.task.JavaTaskRunner$$anon$1.getConsumer(JavaTaskRunner.scala:77) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$9$$anonfun$apply$2.apply(JavaTaskRunner.scala:107) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$9$$anonfun$apply$2.apply(JavaTaskRunner.scala:104) scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) TRACE 301024: sun.management.ManagementFactory.getRuntimeMXBean(ManagementFactory.java:86) sun.management.ManagementFactory.createPlatformMBeanServer(ManagementFactory.java:310) java.lang.management.ManagementFactory.getPlatformMBeanServer(ManagementFactory.java:504) kafka.utils.Utils$.registerMBean(Utils.scala:416) kafka.consumer.Consumer$.create(ConsumerConnector.scala:77) com.linkedin.samsa.stream.kafka.KafkaConsumer.connect(KafkaConsumer.scala:87) com.linkedin.samsa.stream.kafka.KafkaConsumer.(KafkaConsumer.scala:17) com.linkedin.samsa.stream.kafka.KafkaConsumerFactory.getConsumer(KafkaConsumerFactory.scala:46) com.linkedin.samsa.stream.kafka.KafkaConsumerFactory.getConsumer(KafkaConsumerFactory.scala:27) com.linkedin.samsa.task.CachingStreamManager$class.com$linkedin$samsa$task$CachingStreamManager$$getOrAddConsumer(CachingStreamManager.scala:36) com.linkedin.samsa.task.CachingStreamManager$$anonfun$3.apply(CachingStreamManager.scala:24) com.linkedin.samsa.task.CachingStreamManager$$anonfun$3.apply(CachingStreamManager.scala:24) com.linkedin.samsa.util.ObjectCache.get(ObjectCache.scala:10) com.linkedin.samsa.task.CachingStreamManager$class.getConsumer(CachingStreamManager.scala:27) com.linkedin.samsa.task.JavaTaskRunner$$anon$1.getConsumer(JavaTaskRunner.scala:77) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$9$$anonfun$apply$2.apply(JavaTaskRunner.scala:107) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$9$$anonfun$apply$2.apply(JavaTaskRunner.scala:104) scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61) scala.collection.immutable.List.foreach(List.scala:45) scala.collection.TraversableLike$class.map(TraversableLike.scala:206) scala.collection.immutable.List.map(List.scala:45) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$9.apply(JavaTaskRunner.scala:104) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$9.apply(JavaTaskRunner.scala:103) scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61) scala.collection.immutable.List.foreach(List.scala:45) scala.collection.TraversableLike$class.map(TraversableLike.scala:206) TRACE 301057: java.lang.String.concat(String.java:2000) java.net.URLClassLoader.isSealed(URLClassLoader.java:357) java.net.URLClassLoader.defineClass(URLClassLoader.java:241) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) kafka.consumer.ZookeeperConsumerConnector.consume(ZookeeperConsumerConnector.scala:191) kafka.consumer.ZookeeperConsumerConnector.createMessageStreams(ZookeeperConsumerConnector.scala:137) com.linkedin.samsa.stream.kafka.KafkaConsumer.connect(KafkaConsumer.scala:89) com.linkedin.samsa.stream.kafka.KafkaConsumer.(KafkaConsumer.scala:17) com.linkedin.samsa.stream.kafka.KafkaConsumerFactory.getConsumer(KafkaConsumerFactory.scala:46) com.linkedin.samsa.stream.kafka.KafkaConsumerFactory.getConsumer(KafkaConsumerFactory.scala:27) com.linkedin.samsa.task.CachingStreamManager$class.com$linkedin$samsa$task$CachingStreamManager$$getOrAddConsumer(CachingStreamManager.scala:36) com.linkedin.samsa.task.CachingStreamManager$$anonfun$3.apply(CachingStreamManager.scala:24) com.linkedin.samsa.task.CachingStreamManager$$anonfun$3.apply(CachingStreamManager.scala:24) com.linkedin.samsa.util.ObjectCache.get(ObjectCache.scala:10) com.linkedin.samsa.task.CachingStreamManager$class.getConsumer(CachingStreamManager.scala:27) com.linkedin.samsa.task.JavaTaskRunner$$anon$1.getConsumer(JavaTaskRunner.scala:77) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$9$$anonfun$apply$2.apply(JavaTaskRunner.scala:107) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$9$$anonfun$apply$2.apply(JavaTaskRunner.scala:104) scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61) scala.collection.immutable.List.foreach(List.scala:45) scala.collection.TraversableLike$class.map(TraversableLike.scala:206) scala.collection.immutable.List.map(List.scala:45) TRACE 301090: java.lang.String.concat(String.java:2000) java.net.URLClassLoader.isSealed(URLClassLoader.java:357) java.net.URLClassLoader.defineClass(URLClassLoader.java:241) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) scala.collection.mutable.HashMap.(HashMap.scala:39) scala.collection.mutable.HashMap$.empty(HashMap.scala:121) scala.util.parsing.combinator.syntactical.StdTokenParsers$class.$init$(StdTokenParsers.scala:26) scala.util.parsing.json.Parser.(Parser.scala:45) scala.util.parsing.json.JSON$.(JSON.scala:35) scala.util.parsing.json.JSON$.(JSON.scala:Unknown line) kafka.consumer.TopicCount$.(TopicCount.scala:64) kafka.consumer.TopicCount$.(TopicCount.scala:Unknown line) kafka.consumer.ZookeeperConsumerConnector.consume(ZookeeperConsumerConnector.scala:191) kafka.consumer.ZookeeperConsumerConnector.createMessageStreams(ZookeeperConsumerConnector.scala:137) com.linkedin.samsa.stream.kafka.KafkaConsumer.connect(KafkaConsumer.scala:89) com.linkedin.samsa.stream.kafka.KafkaConsumer.(KafkaConsumer.scala:17) com.linkedin.samsa.stream.kafka.KafkaConsumerFactory.getConsumer(KafkaConsumerFactory.scala:46) com.linkedin.samsa.stream.kafka.KafkaConsumerFactory.getConsumer(KafkaConsumerFactory.scala:27) com.linkedin.samsa.task.CachingStreamManager$class.com$linkedin$samsa$task$CachingStreamManager$$getOrAddConsumer(CachingStreamManager.scala:36) com.linkedin.samsa.task.CachingStreamManager$$anonfun$3.apply(CachingStreamManager.scala:24) com.linkedin.samsa.task.CachingStreamManager$$anonfun$3.apply(CachingStreamManager.scala:24) com.linkedin.samsa.util.ObjectCache.get(ObjectCache.scala:10) com.linkedin.samsa.task.CachingStreamManager$class.getConsumer(CachingStreamManager.scala:27) com.linkedin.samsa.task.JavaTaskRunner$$anon$1.getConsumer(JavaTaskRunner.scala:77) TRACE 301107: scala.collection.immutable.HashSet.(HashSet.scala:Unknown line) scala.collection.immutable.Set$Set4.$plus(Set.scala:134) scala.collection.immutable.Set$Set4.$plus(Set.scala:128) scala.collection.generic.Addable$$anonfun$$plus$plus$1.apply(Addable.scala:54) scala.collection.generic.Addable$$anonfun$$plus$plus$1.apply(Addable.scala:54) scala.collection.IndexedSeqOptimized$class.foldl(IndexedSeqOptimized.scala:64) scala.collection.IndexedSeqOptimized$class.foldLeft(IndexedSeqOptimized.scala:73) scala.collection.mutable.ArrayOps.foldLeft(ArrayOps.scala:35) scala.collection.TraversableOnce$class.$div$colon(TraversableOnce.scala:139) scala.collection.mutable.ArrayOps.$div$colon(ArrayOps.scala:35) scala.collection.generic.Addable$class.$plus$plus(Addable.scala:54) scala.collection.immutable.Set$EmptySet$.$plus$plus(Set.scala:47) scala.util.parsing.json.Lexer.(Lexer.scala:80) scala.util.parsing.json.Parser.(Parser.scala:48) scala.util.parsing.json.JSON$.(JSON.scala:35) scala.util.parsing.json.JSON$.(JSON.scala:Unknown line) kafka.consumer.TopicCount$.(TopicCount.scala:64) kafka.consumer.TopicCount$.(TopicCount.scala:Unknown line) kafka.consumer.ZookeeperConsumerConnector.consume(ZookeeperConsumerConnector.scala:191) kafka.consumer.ZookeeperConsumerConnector.createMessageStreams(ZookeeperConsumerConnector.scala:137) com.linkedin.samsa.stream.kafka.KafkaConsumer.connect(KafkaConsumer.scala:89) com.linkedin.samsa.stream.kafka.KafkaConsumer.(KafkaConsumer.scala:17) com.linkedin.samsa.stream.kafka.KafkaConsumerFactory.getConsumer(KafkaConsumerFactory.scala:46) com.linkedin.samsa.stream.kafka.KafkaConsumerFactory.getConsumer(KafkaConsumerFactory.scala:27) com.linkedin.samsa.task.CachingStreamManager$class.com$linkedin$samsa$task$CachingStreamManager$$getOrAddConsumer(CachingStreamManager.scala:36) com.linkedin.samsa.task.CachingStreamManager$$anonfun$3.apply(CachingStreamManager.scala:24) com.linkedin.samsa.task.CachingStreamManager$$anonfun$3.apply(CachingStreamManager.scala:24) com.linkedin.samsa.util.ObjectCache.get(ObjectCache.scala:10) com.linkedin.samsa.task.CachingStreamManager$class.getConsumer(CachingStreamManager.scala:27) com.linkedin.samsa.task.JavaTaskRunner$$anon$1.getConsumer(JavaTaskRunner.scala:77) TRACE 301133: java.lang.Throwable.fillInStackTrace(Throwable.java:Unknown line) java.lang.Throwable.(Throwable.java:218) java.lang.Exception.(Exception.java:59) java.lang.ClassNotFoundException.(ClassNotFoundException.java:65) java.net.URLClassLoader$1.run(URLClassLoader.java:202) 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:307) java.lang.ClassLoader.loadClass(ClassLoader.java:296) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) kafka.consumer.StaticTopicCount.dbString(TopicCount.scala:148) kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$registerConsumerInZK(ZookeeperConsumerConnector.scala:216) kafka.consumer.ZookeeperConsumerConnector.consume(ZookeeperConsumerConnector.scala:206) kafka.consumer.ZookeeperConsumerConnector.createMessageStreams(ZookeeperConsumerConnector.scala:137) com.linkedin.samsa.stream.kafka.KafkaConsumer.connect(KafkaConsumer.scala:89) com.linkedin.samsa.stream.kafka.KafkaConsumer.(KafkaConsumer.scala:17) com.linkedin.samsa.stream.kafka.KafkaConsumerFactory.getConsumer(KafkaConsumerFactory.scala:46) com.linkedin.samsa.stream.kafka.KafkaConsumerFactory.getConsumer(KafkaConsumerFactory.scala:27) com.linkedin.samsa.task.CachingStreamManager$class.com$linkedin$samsa$task$CachingStreamManager$$getOrAddConsumer(CachingStreamManager.scala:36) com.linkedin.samsa.task.CachingStreamManager$$anonfun$3.apply(CachingStreamManager.scala:24) com.linkedin.samsa.task.CachingStreamManager$$anonfun$3.apply(CachingStreamManager.scala:24) com.linkedin.samsa.util.ObjectCache.get(ObjectCache.scala:10) com.linkedin.samsa.task.CachingStreamManager$class.getConsumer(CachingStreamManager.scala:27) com.linkedin.samsa.task.JavaTaskRunner$$anon$1.getConsumer(JavaTaskRunner.scala:77) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$9$$anonfun$apply$2.apply(JavaTaskRunner.scala:107) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$9$$anonfun$apply$2.apply(JavaTaskRunner.scala:104) scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) TRACE 301162: java.lang.ClassLoader.defineClass1(ClassLoader.java:Unknown line) java.lang.ClassLoader.defineClassCond(ClassLoader.java:632) java.lang.ClassLoader.defineClass(ClassLoader.java:616) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) org.I0Itec.zkclient.ZkClient.watchForChilds(ZkClient.java:839) org.I0Itec.zkclient.ZkClient.subscribeChildChanges(ZkClient.java:114) kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$reinitializeConsumer(ZookeeperConsumerConnector.scala:724) kafka.consumer.ZookeeperConsumerConnector.consume(ZookeeperConsumerConnector.scala:207) kafka.consumer.ZookeeperConsumerConnector.createMessageStreams(ZookeeperConsumerConnector.scala:137) com.linkedin.samsa.stream.kafka.KafkaConsumer.connect(KafkaConsumer.scala:89) com.linkedin.samsa.stream.kafka.KafkaConsumer.(KafkaConsumer.scala:17) com.linkedin.samsa.stream.kafka.KafkaConsumerFactory.getConsumer(KafkaConsumerFactory.scala:46) com.linkedin.samsa.stream.kafka.KafkaConsumerFactory.getConsumer(KafkaConsumerFactory.scala:27) com.linkedin.samsa.task.CachingStreamManager$class.com$linkedin$samsa$task$CachingStreamManager$$getOrAddConsumer(CachingStreamManager.scala:36) com.linkedin.samsa.task.CachingStreamManager$$anonfun$3.apply(CachingStreamManager.scala:24) com.linkedin.samsa.task.CachingStreamManager$$anonfun$3.apply(CachingStreamManager.scala:24) com.linkedin.samsa.util.ObjectCache.get(ObjectCache.scala:10) com.linkedin.samsa.task.CachingStreamManager$class.getConsumer(CachingStreamManager.scala:27) com.linkedin.samsa.task.JavaTaskRunner$$anon$1.getConsumer(JavaTaskRunner.scala:77) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$9$$anonfun$apply$2.apply(JavaTaskRunner.scala:107) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$9$$anonfun$apply$2.apply(JavaTaskRunner.scala:104) scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) TRACE 301172: java.lang.ClassLoader.checkCerts(ClassLoader.java:783) java.lang.ClassLoader.preDefineClass(ClassLoader.java:488) java.lang.ClassLoader.defineClassCond(ClassLoader.java:626) java.lang.ClassLoader.defineClass(ClassLoader.java:616) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:444) kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$reinitializeConsumer(ZookeeperConsumerConnector.scala:733) kafka.consumer.ZookeeperConsumerConnector.consume(ZookeeperConsumerConnector.scala:207) kafka.consumer.ZookeeperConsumerConnector.createMessageStreams(ZookeeperConsumerConnector.scala:137) com.linkedin.samsa.stream.kafka.KafkaConsumer.connect(KafkaConsumer.scala:89) com.linkedin.samsa.stream.kafka.KafkaConsumer.(KafkaConsumer.scala:17) com.linkedin.samsa.stream.kafka.KafkaConsumerFactory.getConsumer(KafkaConsumerFactory.scala:46) com.linkedin.samsa.stream.kafka.KafkaConsumerFactory.getConsumer(KafkaConsumerFactory.scala:27) com.linkedin.samsa.task.CachingStreamManager$class.com$linkedin$samsa$task$CachingStreamManager$$getOrAddConsumer(CachingStreamManager.scala:36) com.linkedin.samsa.task.CachingStreamManager$$anonfun$3.apply(CachingStreamManager.scala:24) com.linkedin.samsa.task.CachingStreamManager$$anonfun$3.apply(CachingStreamManager.scala:24) com.linkedin.samsa.util.ObjectCache.get(ObjectCache.scala:10) com.linkedin.samsa.task.CachingStreamManager$class.getConsumer(CachingStreamManager.scala:27) com.linkedin.samsa.task.JavaTaskRunner$$anon$1.getConsumer(JavaTaskRunner.scala:77) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$9$$anonfun$apply$2.apply(JavaTaskRunner.scala:107) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$9$$anonfun$apply$2.apply(JavaTaskRunner.scala:104) scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) TRACE 301184: java.io.ByteArrayOutputStream.(ByteArrayOutputStream.java:60) java.io.ByteArrayOutputStream.(ByteArrayOutputStream.java:45) org.apache.zookeeper.ClientCnxn$Packet.(ClientCnxn.java:272) org.apache.zookeeper.ClientCnxn.queuePacket(ClientCnxn.java:1293) org.apache.zookeeper.ClientCnxn.submitRequest(ClientCnxn.java:1274) org.apache.zookeeper.ZooKeeper.getData(ZooKeeper.java:919) org.apache.zookeeper.ZooKeeper.getData(ZooKeeper.java:950) org.I0Itec.zkclient.ZkConnection.readData(ZkConnection.java:103) org.I0Itec.zkclient.ZkClient$9.call(ZkClient.java:770) org.I0Itec.zkclient.ZkClient$9.call(ZkClient.java:766) org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675) org.I0Itec.zkclient.ZkClient.readData(ZkClient.java:766) org.I0Itec.zkclient.ZkClient.readData(ZkClient.java:761) org.I0Itec.zkclient.ZkClient.readData(ZkClient.java:750) org.I0Itec.zkclient.ZkClient.readData(ZkClient.java:744) kafka.utils.ZkUtils$.readData(ZkUtils.scala:162) kafka.utils.ZkUtils$$anonfun$getCluster$1.apply(ZkUtils.scala:204) kafka.utils.ZkUtils$$anonfun$getCluster$1.apply(ZkUtils.scala:203) scala.collection.Iterator$class.foreach(Iterator.scala:631) scala.collection.JavaConversions$JIteratorWrapper.foreach(JavaConversions.scala:549) scala.collection.IterableLike$class.foreach(IterableLike.scala:79) scala.collection.JavaConversions$JListWrapper.foreach(JavaConversions.scala:596) kafka.utils.ZkUtils$.getCluster(ZkUtils.scala:203) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala:447) scala.collection.immutable.Range$ByOne$class.foreach$mVc$sp(Range.scala:282) scala.collection.immutable.Range$$anon$2.foreach$mVc$sp(Range.scala:265) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:444) kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$reinitializeConsumer(ZookeeperConsumerConnector.scala:733) kafka.consumer.ZookeeperConsumerConnector.consume(ZookeeperConsumerConnector.scala:207) kafka.consumer.ZookeeperConsumerConnector.createMessageStreams(ZookeeperConsumerConnector.scala:137) TRACE 301189: scala.util.parsing.combinator.Parsers$class.Parser(Parsers.scala:182) scala.util.parsing.json.Parser.Parser(Parser.scala:45) scala.util.parsing.combinator.Parsers$class.acceptIf(Parsers.scala:487) scala.util.parsing.json.Parser.acceptIf(Parser.scala:45) scala.util.parsing.combinator.Parsers$class.accept(Parsers.scala:460) scala.util.parsing.json.Parser.accept(Parser.scala:45) scala.util.parsing.combinator.syntactical.StdTokenParsers$$anonfun$keyword$1.apply(StdTokenParsers.scala:35) scala.util.parsing.combinator.syntactical.StdTokenParsers$$anonfun$keyword$1.apply(StdTokenParsers.scala:35) scala.collection.mutable.MapLike$class.getOrElseUpdate(MapLike.scala:182) scala.collection.mutable.HashMap.getOrElseUpdate(HashMap.scala:39) scala.util.parsing.combinator.syntactical.StdTokenParsers$class.keyword(StdTokenParsers.scala:35) scala.util.parsing.json.Parser.keyword(Parser.scala:45) scala.util.parsing.json.Parser.jsonObj(Parser.scala:67) scala.util.parsing.json.Parser.root(Parser.scala:66) scala.util.parsing.json.JSON$.parseRaw(JSON.scala:71) scala.util.parsing.json.JSON$.parseFull(JSON.scala:85) kafka.consumer.TopicCount$.constructTopicCount(TopicCount.scala:97) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance(ZookeeperConsumerConnector.scala:477) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala:449) scala.collection.immutable.Range$ByOne$class.foreach$mVc$sp(Range.scala:282) scala.collection.immutable.Range$$anon$2.foreach$mVc$sp(Range.scala:265) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:444) kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$reinitializeConsumer(ZookeeperConsumerConnector.scala:733) kafka.consumer.ZookeeperConsumerConnector.consume(ZookeeperConsumerConnector.scala:207) kafka.consumer.ZookeeperConsumerConnector.createMessageStreams(ZookeeperConsumerConnector.scala:137) com.linkedin.samsa.stream.kafka.KafkaConsumer.connect(KafkaConsumer.scala:89) com.linkedin.samsa.stream.kafka.KafkaConsumer.(KafkaConsumer.scala:17) com.linkedin.samsa.stream.kafka.KafkaConsumerFactory.getConsumer(KafkaConsumerFactory.scala:46) com.linkedin.samsa.stream.kafka.KafkaConsumerFactory.getConsumer(KafkaConsumerFactory.scala:27) com.linkedin.samsa.task.CachingStreamManager$class.com$linkedin$samsa$task$CachingStreamManager$$getOrAddConsumer(CachingStreamManager.scala:36) TRACE 301219: java.lang.AbstractStringBuilder.(AbstractStringBuilder.java:45) java.lang.StringBuilder.(StringBuilder.java:68) sun.net.www.protocol.jar.Handler.parseContextSpec(Handler.java:120) sun.net.www.protocol.jar.Handler.parseURL(Handler.java:66) java.net.URL.(URL.java:596) java.net.URL.(URL.java:464) sun.misc.URLClassPath$JarLoader.checkResource(URLClassPath.java:674) sun.misc.URLClassPath$JarLoader.getResource(URLClassPath.java:759) sun.misc.URLClassPath.getResource(URLClassPath.java:169) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) scala.util.parsing.json.Lexer.token(Lexer.scala:29) scala.util.parsing.combinator.lexical.Scanners$Scanner.(Scanners.scala:55) scala.util.parsing.combinator.lexical.Scanners$Scanner.(Scanners.scala:52) scala.util.parsing.json.JSON$.parseRaw(JSON.scala:71) scala.util.parsing.json.JSON$.parseFull(JSON.scala:85) kafka.consumer.TopicCount$.constructTopicCount(TopicCount.scala:97) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance(ZookeeperConsumerConnector.scala:477) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala:449) scala.collection.immutable.Range$ByOne$class.foreach$mVc$sp(Range.scala:282) scala.collection.immutable.Range$$anon$2.foreach$mVc$sp(Range.scala:265) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:444) kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$reinitializeConsumer(ZookeeperConsumerConnector.scala:733) kafka.consumer.ZookeeperConsumerConnector.consume(ZookeeperConsumerConnector.scala:207) kafka.consumer.ZookeeperConsumerConnector.createMessageStreams(ZookeeperConsumerConnector.scala:137) com.linkedin.samsa.stream.kafka.KafkaConsumer.connect(KafkaConsumer.scala:89) TRACE 301253: java.lang.Throwable.fillInStackTrace(Throwable.java:Unknown line) java.lang.Throwable.(Throwable.java:218) java.lang.Exception.(Exception.java:59) java.lang.ClassNotFoundException.(ClassNotFoundException.java:65) java.net.URLClassLoader$1.run(URLClassLoader.java:202) 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:307) java.lang.ClassLoader.loadClass(ClassLoader.java:296) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) scala.math.Ordering$String$.(Ordering.scala:205) scala.math.Ordering$String$.(Ordering.scala:Unknown line) scala.util.parsing.combinator.lexical.StdLexical._delim(StdLexical.scala:83) scala.util.parsing.combinator.lexical.StdLexical.delim(StdLexical.scala:86) scala.util.parsing.json.Lexer$$anonfun$token$6.apply(Lexer.scala:31) scala.util.parsing.json.Lexer$$anonfun$token$6.apply(Lexer.scala:31) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1$$anonfun$apply$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1$$anonfun$apply$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Failure.append(Parsers.scala:162) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) TRACE 301293: 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:999) sun.misc.URLClassPath.getResource(URLClassPath.java:169) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) scala.collection.IndexedSeqOptimized$class.forall(IndexedSeqOptimized.scala:38) scala.collection.mutable.WrappedArray.forall(WrappedArray.scala:32) scala.util.parsing.combinator.lexical.Lexical$$anonfun$chrExcept$1.apply(Lexical.scala:38) scala.util.parsing.combinator.lexical.Lexical$$anonfun$chrExcept$1.apply(Lexical.scala:38) scala.util.parsing.combinator.Parsers$$anonfun$acceptIf$1.apply(Parsers.scala:488) scala.util.parsing.combinator.Parsers$$anonfun$acceptIf$1.apply(Parsers.scala:487) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1$$anonfun$apply$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1$$anonfun$apply$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Failure.append(Parsers.scala:162) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$$anonfun$rep1$1.apply(Parsers.scala:590) scala.util.parsing.combinator.Parsers$$anonfun$rep1$1.apply(Parsers.scala:577) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) TRACE 301325: scala.util.parsing.json.Parser.value(Parser.scala:70) scala.util.parsing.json.Parser$$anonfun$objEntry$1$$anonfun$apply$5.apply(Parser.scala:69) scala.util.parsing.json.Parser$$anonfun$objEntry$1$$anonfun$apply$5.apply(Parser.scala:69) scala.util.parsing.combinator.Parsers$Parser$$anonfun$$tilde$greater$1.apply(Parsers.scala:235) scala.util.parsing.combinator.Parsers$Parser$$anonfun$$tilde$greater$1.apply(Parsers.scala:235) scala.util.parsing.combinator.Parsers$Success.flatMapWithNext(Parsers.scala:113) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Success.flatMapWithNext(Parsers.scala:113) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) TRACE 301345: java.lang.Character.toString(Character.java:2135) java.lang.String.valueOf(String.java:2826) scala.collection.mutable.StringBuilder.append(StringBuilder.scala:178) scala.util.parsing.combinator.Parsers$$anonfun$accept$2.apply(Parsers.scala:460) scala.util.parsing.combinator.Parsers$$anonfun$accept$2.apply(Parsers.scala:460) scala.util.parsing.combinator.Parsers$$anonfun$acceptIf$1.apply(Parsers.scala:489) scala.util.parsing.combinator.Parsers$$anonfun$acceptIf$1.apply(Parsers.scala:487) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1$$anonfun$apply$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1$$anonfun$apply$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Failure.append(Parsers.scala:162) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) TRACE 301346: scala.util.parsing.input.CharSequenceReader.offset(CharSequenceReader.scala:29) scala.util.parsing.input.CharSequenceReader.first(CharSequenceReader.scala:40) scala.util.parsing.input.CharSequenceReader.first(CharSequenceReader.scala:28) scala.util.parsing.combinator.Parsers$$anonfun$acceptIf$1.apply(Parsers.scala:488) scala.util.parsing.combinator.Parsers$$anonfun$acceptIf$1.apply(Parsers.scala:487) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$$anonfun$rep1$1.apply(Parsers.scala:590) scala.util.parsing.combinator.Parsers$$anonfun$rep1$1.apply(Parsers.scala:577) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.lexical.Scanners$Scanner.(Scanners.scala:53) scala.util.parsing.combinator.lexical.Scanners$Scanner.rest(Scanners.scala:66) scala.util.parsing.combinator.lexical.Scanners$Scanner.rest(Scanners.scala:50) scala.util.parsing.combinator.Parsers$$anonfun$acceptIf$1.apply(Parsers.scala:488) scala.util.parsing.combinator.Parsers$$anonfun$acceptIf$1.apply(Parsers.scala:487) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) TRACE 301347: java.lang.Character.toString(Character.java:2135) java.lang.String.valueOf(String.java:2826) scala.collection.mutable.StringBuilder.append(StringBuilder.scala:178) scala.util.parsing.combinator.Parsers$$anonfun$accept$2.apply(Parsers.scala:460) scala.util.parsing.combinator.Parsers$$anonfun$accept$2.apply(Parsers.scala:460) scala.util.parsing.combinator.Parsers$$anonfun$acceptIf$1.apply(Parsers.scala:489) scala.util.parsing.combinator.Parsers$$anonfun$acceptIf$1.apply(Parsers.scala:487) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1$$anonfun$apply$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1$$anonfun$apply$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Failure.append(Parsers.scala:162) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) TRACE 301348: scala.util.parsing.combinator.Parsers$$anonfun$accept$1.apply(Parsers.scala:460) scala.util.parsing.combinator.Parsers$$anonfun$accept$1.apply(Parsers.scala:460) scala.util.parsing.combinator.Parsers$$anonfun$acceptIf$1.apply(Parsers.scala:488) scala.util.parsing.combinator.Parsers$$anonfun$acceptIf$1.apply(Parsers.scala:487) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1$$anonfun$apply$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1$$anonfun$apply$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Failure.append(Parsers.scala:162) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$$anonfun$rep1$1.applyp$1(Parsers.scala:582) scala.util.parsing.combinator.Parsers$$anonfun$rep1$1.continue$1(Parsers.scala:587) scala.util.parsing.combinator.Parsers$$anonfun$rep1$1.apply(Parsers.scala:591) scala.util.parsing.combinator.Parsers$$anonfun$rep1$1.apply(Parsers.scala:577) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) TRACE 301372: 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:999) sun.misc.URLClassPath.getResource(URLClassPath.java:169) 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:307) sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) java.lang.ClassLoader.loadClass(ClassLoader.java:248) scala.collection.JavaConversions$.asScalaIterable(JavaConversions.scala:411) scala.collection.JavaConversions$.asIterable(JavaConversions.scala:415) kafka.utils.Pool.values(Pool.scala:47) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$closeFetchersForQueues(ZookeeperConsumerConnector.scala:550) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.closeFetchers(ZookeeperConsumerConnector.scala:573) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance(ZookeeperConsumerConnector.scala:487) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala:449) scala.collection.immutable.Range$ByOne$class.foreach$mVc$sp(Range.scala:282) scala.collection.immutable.Range$$anon$2.foreach$mVc$sp(Range.scala:265) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:444) kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$reinitializeConsumer(ZookeeperConsumerConnector.scala:733) kafka.consumer.ZookeeperConsumerConnector.consume(ZookeeperConsumerConnector.scala:207) kafka.consumer.ZookeeperConsumerConnector.createMessageStreams(ZookeeperConsumerConnector.scala:137) com.linkedin.samsa.stream.kafka.KafkaConsumer.connect(KafkaConsumer.scala:89) com.linkedin.samsa.stream.kafka.KafkaConsumer.(KafkaConsumer.scala:17) com.linkedin.samsa.stream.kafka.KafkaConsumerFactory.getConsumer(KafkaConsumerFactory.scala:46) com.linkedin.samsa.stream.kafka.KafkaConsumerFactory.getConsumer(KafkaConsumerFactory.scala:27) com.linkedin.samsa.task.CachingStreamManager$class.com$linkedin$samsa$task$CachingStreamManager$$getOrAddConsumer(CachingStreamManager.scala:36) com.linkedin.samsa.task.CachingStreamManager$$anonfun$3.apply(CachingStreamManager.scala:24) TRACE 301402: kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$updateFetcher$2.apply(ZookeeperConsumerConnector.scala:583) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$updateFetcher$2.apply(ZookeeperConsumerConnector.scala:582) kafka.utils.Logging$class.info(Logging.scala:58) kafka.consumer.ZookeeperConsumerConnector.info(ZookeeperConsumerConnector.scala:88) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.updateFetcher(ZookeeperConsumerConnector.scala:582) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance(ZookeeperConsumerConnector.scala:540) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala:449) scala.collection.immutable.Range$ByOne$class.foreach$mVc$sp(Range.scala:282) scala.collection.immutable.Range$$anon$2.foreach$mVc$sp(Range.scala:265) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:444) kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$reinitializeConsumer(ZookeeperConsumerConnector.scala:733) kafka.consumer.ZookeeperConsumerConnector.consume(ZookeeperConsumerConnector.scala:207) kafka.consumer.ZookeeperConsumerConnector.createMessageStreams(ZookeeperConsumerConnector.scala:137) com.linkedin.samsa.stream.kafka.KafkaConsumer.connect(KafkaConsumer.scala:89) com.linkedin.samsa.stream.kafka.KafkaConsumer.(KafkaConsumer.scala:17) com.linkedin.samsa.stream.kafka.KafkaConsumerFactory.getConsumer(KafkaConsumerFactory.scala:46) com.linkedin.samsa.stream.kafka.KafkaConsumerFactory.getConsumer(KafkaConsumerFactory.scala:27) com.linkedin.samsa.task.CachingStreamManager$class.com$linkedin$samsa$task$CachingStreamManager$$getOrAddConsumer(CachingStreamManager.scala:36) com.linkedin.samsa.task.CachingStreamManager$$anonfun$3.apply(CachingStreamManager.scala:24) com.linkedin.samsa.task.CachingStreamManager$$anonfun$3.apply(CachingStreamManager.scala:24) com.linkedin.samsa.util.ObjectCache.get(ObjectCache.scala:10) com.linkedin.samsa.task.CachingStreamManager$class.getConsumer(CachingStreamManager.scala:27) com.linkedin.samsa.task.JavaTaskRunner$$anon$1.getConsumer(JavaTaskRunner.scala:77) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$9$$anonfun$apply$2.apply(JavaTaskRunner.scala:107) com.linkedin.samsa.task.JavaTaskRunner$$anonfun$9$$anonfun$apply$2.apply(JavaTaskRunner.scala:104) scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61) scala.collection.immutable.List.foreach(List.scala:45) scala.collection.TraversableLike$class.map(TraversableLike.scala:206) TRACE 301410: org.apache.jute.BinaryInputArchive.readString(BinaryInputArchive.java:81) org.apache.zookeeper.proto.GetChildrenResponse.deserialize(GetChildrenResponse.java:59) org.apache.zookeeper.ClientCnxn$SendThread.readResponse(ClientCnxn.java:793) org.apache.zookeeper.ClientCnxn$SendThread.doIO(ClientCnxn.java:840) org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1089) TRACE 301413: java.lang.System.arraycopy(System.java:Unknown line) java.nio.HeapByteBuffer.get(HeapByteBuffer.java:128) org.apache.zookeeper.server.ByteBufferInputStream.read(ByteBufferInputStream.java:53) java.io.DataInputStream.readFully(DataInputStream.java:178) java.io.DataInputStream.readLong(DataInputStream.java:399) org.apache.jute.BinaryInputArchive.readLong(BinaryInputArchive.java:67) org.apache.zookeeper.data.Stat.deserialize(Stat.java:155) org.apache.jute.BinaryInputArchive.readRecord(BinaryInputArchive.java:108) org.apache.zookeeper.proto.GetDataResponse.deserialize(GetDataResponse.java:57) org.apache.zookeeper.ClientCnxn$SendThread.readResponse(ClientCnxn.java:793) org.apache.zookeeper.ClientCnxn$SendThread.doIO(ClientCnxn.java:840) org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1089) TRACE 301414: scala.util.parsing.combinator.Parsers$$anonfun$accept$1.apply(Parsers.scala:460) scala.util.parsing.combinator.Parsers$$anonfun$accept$1.apply(Parsers.scala:460) scala.util.parsing.combinator.Parsers$$anonfun$acceptIf$1.apply(Parsers.scala:488) scala.util.parsing.combinator.Parsers$$anonfun$acceptIf$1.apply(Parsers.scala:487) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1$$anonfun$apply$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1$$anonfun$apply$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Failure.append(Parsers.scala:162) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) TRACE 301415: scala.util.parsing.combinator.Parsers$$anonfun$acceptIf$1.apply(Parsers.scala:488) scala.util.parsing.combinator.Parsers$$anonfun$acceptIf$1.apply(Parsers.scala:487) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1$$anonfun$apply$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1$$anonfun$apply$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Failure.append(Parsers.scala:162) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$$anonfun$rep1$1.applyp$1(Parsers.scala:582) scala.util.parsing.combinator.Parsers$$anonfun$rep1$1.continue$1(Parsers.scala:587) scala.util.parsing.combinator.Parsers$$anonfun$rep1$1.apply(Parsers.scala:591) scala.util.parsing.combinator.Parsers$$anonfun$rep1$1.apply(Parsers.scala:577) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) TRACE 301416: scala.collection.mutable.ListBuffer.(ListBuffer.scala:43) scala.util.parsing.combinator.Parsers$$anonfun$rep1$1.apply(Parsers.scala:578) scala.util.parsing.combinator.Parsers$$anonfun$rep1$1.apply(Parsers.scala:577) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.lexical.Scanners$Scanner.(Scanners.scala:53) scala.util.parsing.combinator.lexical.Scanners$Scanner.rest(Scanners.scala:66) scala.util.parsing.combinator.lexical.Scanners$Scanner.rest(Scanners.scala:50) scala.util.parsing.combinator.Parsers$$anonfun$acceptMatch$1.apply(Parsers.scala:493) scala.util.parsing.combinator.Parsers$$anonfun$acceptMatch$1.apply(Parsers.scala:492) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) TRACE 301418: java.lang.Thread.currentThread(Thread.java:Unknown line) java.lang.ThreadLocal.set(ThreadLocal.java:161) sun.nio.ch.Util.getTemporaryDirectBuffer(Util.java:51) sun.nio.ch.IOUtil.read(IOUtil.java:209) sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:236) org.apache.zookeeper.ClientCnxn$SendThread.doIO(ClientCnxn.java:817) org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1089) TRACE 301424: scala.collection.JavaConversions$.asScalaSet(JavaConversions.scala:453) scala.collection.JavaConversions$.asSet(JavaConversions.scala:457) kafka.utils.Pool.keys(Pool.scala:44) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$releasePartitionOwnership$2.apply(ZookeeperConsumerConnector.scala:432) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$releasePartitionOwnership$2.apply(ZookeeperConsumerConnector.scala:431) scala.collection.Iterator$class.foreach(Iterator.scala:631) kafka.utils.Pool$$anon$1.foreach(Pool.scala:53) scala.collection.IterableLike$class.foreach(IterableLike.scala:79) kafka.utils.Pool.foreach(Pool.scala:24) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.releasePartitionOwnership(ZookeeperConsumerConnector.scala:431) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance(ZookeeperConsumerConnector.scala:489) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala:449) scala.collection.immutable.Range$ByOne$class.foreach$mVc$sp(Range.scala:282) scala.collection.immutable.Range$$anon$2.foreach$mVc$sp(Range.scala:265) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:444) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anon$1.run(ZookeeperConsumerConnector.scala:401) TRACE 301427: java.lang.System.arraycopy(System.java:Unknown line) java.nio.HeapByteBuffer.get(HeapByteBuffer.java:128) org.apache.zookeeper.server.ByteBufferInputStream.read(ByteBufferInputStream.java:53) java.io.DataInputStream.readFully(DataInputStream.java:178) java.io.DataInputStream.readLong(DataInputStream.java:399) org.apache.jute.BinaryInputArchive.readLong(BinaryInputArchive.java:67) org.apache.zookeeper.data.Stat.deserialize(Stat.java:145) org.apache.jute.BinaryInputArchive.readRecord(BinaryInputArchive.java:108) org.apache.zookeeper.proto.SetDataResponse.deserialize(SetDataResponse.java:46) org.apache.zookeeper.ClientCnxn$SendThread.readResponse(ClientCnxn.java:793) org.apache.zookeeper.ClientCnxn$SendThread.doIO(ClientCnxn.java:840) org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1089) TRACE 301428: java.lang.Character.charValue(Character.java:2097) scala.runtime.BoxesRunTime.unboxToChar(:Unknown line) scala.util.parsing.combinator.lexical.Lexical$$anonfun$whitespaceChar$1.apply(Lexical.scala:41) scala.util.parsing.combinator.Parsers$$anonfun$acceptIf$1.apply(Parsers.scala:488) scala.util.parsing.combinator.Parsers$$anonfun$acceptIf$1.apply(Parsers.scala:487) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$$anonfun$rep1$1.apply(Parsers.scala:590) scala.util.parsing.combinator.Parsers$$anonfun$rep1$1.apply(Parsers.scala:577) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.lexical.Scanners$Scanner.(Scanners.scala:53) scala.util.parsing.combinator.lexical.Scanners$Scanner.rest(Scanners.scala:66) scala.util.parsing.combinator.lexical.Scanners$Scanner.rest(Scanners.scala:50) scala.util.parsing.combinator.Parsers$$anonfun$acceptIf$1.apply(Parsers.scala:488) scala.util.parsing.combinator.Parsers$$anonfun$acceptIf$1.apply(Parsers.scala:487) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Success.flatMapWithNext(Parsers.scala:113) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) TRACE 301429: java.lang.Thread.currentThread(Thread.java:Unknown line) java.lang.ThreadLocal.get(ThreadLocal.java:124) sun.nio.ch.Util.getTemporaryDirectBuffer(Util.java:46) sun.nio.ch.IOUtil.write(IOUtil.java:65) sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:334) org.apache.zookeeper.ClientCnxn$SendThread.doIO(ClientCnxn.java:851) org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1089) TRACE 301430: scala.collection.mutable.HashTable$$anon$1.hasNext(HashTable.scala:166) scala.collection.Iterator$class.foreach(Iterator.scala:631) scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:161) scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:194) scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:39) scala.collection.mutable.HashMap.foreach(HashMap.scala:80) kafka.utils.ZkUtils$$anonfun$getConsumersPerTopic$1.apply(ZkUtils.scala:260) kafka.utils.ZkUtils$$anonfun$getConsumersPerTopic$1.apply(ZkUtils.scala:258) scala.collection.Iterator$class.foreach(Iterator.scala:631) scala.collection.JavaConversions$JIteratorWrapper.foreach(JavaConversions.scala:549) scala.collection.IterableLike$class.foreach(IterableLike.scala:79) scala.collection.JavaConversions$JListWrapper.foreach(JavaConversions.scala:596) kafka.utils.ZkUtils$.getConsumersPerTopic(ZkUtils.scala:258) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance(ZookeeperConsumerConnector.scala:478) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala:449) scala.collection.immutable.Range$ByOne$class.foreach$mVc$sp(Range.scala:282) scala.collection.immutable.Range$$anon$2.foreach$mVc$sp(Range.scala:265) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:444) kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$reinitializeConsumer(ZookeeperConsumerConnector.scala:733) kafka.consumer.ZookeeperConsumerConnector.consume(ZookeeperConsumerConnector.scala:207) kafka.consumer.ZookeeperConsumerConnector.createMessageStreams(ZookeeperConsumerConnector.scala:137) com.linkedin.samsa.stream.kafka.KafkaConsumer.connect(KafkaConsumer.scala:89) com.linkedin.samsa.stream.kafka.KafkaConsumer.(KafkaConsumer.scala:17) com.linkedin.samsa.stream.kafka.KafkaConsumerFactory.getConsumer(KafkaConsumerFactory.scala:46) com.linkedin.samsa.stream.kafka.KafkaConsumerFactory.getConsumer(KafkaConsumerFactory.scala:27) com.linkedin.samsa.task.CachingStreamManager$class.com$linkedin$samsa$task$CachingStreamManager$$getOrAddConsumer(CachingStreamManager.scala:36) com.linkedin.samsa.task.CachingStreamManager$$anonfun$3.apply(CachingStreamManager.scala:24) com.linkedin.samsa.task.CachingStreamManager$$anonfun$3.apply(CachingStreamManager.scala:24) com.linkedin.samsa.util.ObjectCache.get(ObjectCache.scala:10) com.linkedin.samsa.task.CachingStreamManager$class.getConsumer(CachingStreamManager.scala:27) TRACE 301432: java.nio.charset.CoderResult.isOverflow(CoderResult.java:112) java.nio.charset.CharsetDecoder.decode(CharsetDecoder.java:551) java.lang.StringCoding$StringDecoder.decode(StringCoding.java:140) java.lang.StringCoding.decode(StringCoding.java:173) java.lang.String.(String.java:443) java.lang.String.(String.java:515) kafka.utils.ZKStringSerializer$.deserialize(ZkUtils.scala:284) org.I0Itec.zkclient.ZkClient.derializable(ZkClient.java:740) org.I0Itec.zkclient.ZkClient.readData(ZkClient.java:773) org.I0Itec.zkclient.ZkClient.readData(ZkClient.java:761) org.I0Itec.zkclient.ZkClient.readData(ZkClient.java:750) org.I0Itec.zkclient.ZkClient.readData(ZkClient.java:744) kafka.utils.ZkUtils$.readData(ZkUtils.scala:162) kafka.utils.ZkUtils$$anonfun$getPartitionsForTopics$1$$anonfun$apply$2.apply(ZkUtils.scala:216) kafka.utils.ZkUtils$$anonfun$getPartitionsForTopics$1$$anonfun$apply$2.apply(ZkUtils.scala:215) scala.collection.Iterator$class.foreach(Iterator.scala:631) scala.collection.JavaConversions$JIteratorWrapper.foreach(JavaConversions.scala:549) scala.collection.IterableLike$class.foreach(IterableLike.scala:79) scala.collection.JavaConversions$JListWrapper.foreach(JavaConversions.scala:596) kafka.utils.ZkUtils$$anonfun$getPartitionsForTopics$1.apply(ZkUtils.scala:215) kafka.utils.ZkUtils$$anonfun$getPartitionsForTopics$1.apply(ZkUtils.scala:212) scala.collection.Iterator$class.foreach(Iterator.scala:631) scala.collection.mutable.HashMap$$anon$3.foreach(HashMap.scala:93) kafka.utils.ZkUtils$.getPartitionsForTopics(ZkUtils.scala:212) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance(ZookeeperConsumerConnector.scala:479) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala:449) scala.collection.immutable.Range$ByOne$class.foreach$mVc$sp(Range.scala:282) scala.collection.immutable.Range$$anon$2.foreach$mVc$sp(Range.scala:265) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:444) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anon$1.run(ZookeeperConsumerConnector.scala:401) TRACE 301434: java.lang.System.arraycopy(System.java:Unknown line) java.lang.AbstractStringBuilder.append(AbstractStringBuilder.java:488) java.lang.StringBuffer.append(StringBuffer.java:301) org.apache.log4j.helpers.ISO8601DateFormat.format(ISO8601DateFormat.java:134) java.text.DateFormat.format(DateFormat.java:316) org.apache.log4j.helpers.PatternParser$DatePatternConverter.convert(PatternParser.java:443) org.apache.log4j.helpers.PatternConverter.format(PatternConverter.java:65) org.apache.log4j.PatternLayout.format(PatternLayout.java:506) org.apache.log4j.WriterAppender.subAppend(WriterAppender.java:310) org.apache.log4j.WriterAppender.append(WriterAppender.java:162) org.apache.log4j.AppenderSkeleton.doAppend(AppenderSkeleton.java:251) org.apache.log4j.helpers.AppenderAttachableImpl.appendLoopOnAppenders(AppenderAttachableImpl.java:66) org.apache.log4j.Category.callAppenders(Category.java:206) org.apache.log4j.Category.forcedLog(Category.java:391) org.apache.log4j.Category.info(Category.java:666) org.apache.zookeeper.ClientCnxn$SendThread.startConnect(ClientCnxn.java:1000) org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1036) TRACE 301435: java.lang.Thread.currentThread(Thread.java:Unknown line) java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.addConditionWaiter(AbstractQueuedSynchronizer.java:1801) java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:1983) java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:399) org.apache.zookeeper.ClientCnxn$EventThread.run(ClientCnxn.java:477) TRACE 301436: java.lang.Object.clone(Object.java:Unknown line) java.util.Arrays.sort(Arrays.java:1206) scala.collection.SeqLike$class.sorted(SeqLike.scala:828) scala.collection.immutable.List.sorted(List.scala:45) scala.collection.SeqLike$class.sortWith(SeqLike.scala:786) scala.collection.immutable.List.sortWith(List.scala:45) kafka.utils.ZkUtils$$anonfun$getConsumersPerTopic$2.apply(ZkUtils.scala:269) kafka.utils.ZkUtils$$anonfun$getConsumersPerTopic$2.apply(ZkUtils.scala:268) scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:80) scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:80) scala.collection.Iterator$class.foreach(Iterator.scala:631) scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:161) scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:194) scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:39) scala.collection.mutable.HashMap.foreach(HashMap.scala:80) kafka.utils.ZkUtils$.getConsumersPerTopic(ZkUtils.scala:268) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance(ZookeeperConsumerConnector.scala:478) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala:449) scala.collection.immutable.Range$ByOne$class.foreach$mVc$sp(Range.scala:282) scala.collection.immutable.Range$$anon$2.foreach$mVc$sp(Range.scala:265) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:444) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anon$1.run(ZookeeperConsumerConnector.scala:401) TRACE 301437: scala.collection.mutable.HashTable$$anon$1.scan(HashTable.scala:174) scala.collection.mutable.HashTable$$anon$1.next(HashTable.scala:170) scala.collection.mutable.HashTable$$anon$1.next(HashTable.scala:161) scala.collection.Iterator$class.foreach(Iterator.scala:631) scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:161) scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:194) scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:39) scala.collection.mutable.HashMap.foreach(HashMap.scala:80) kafka.utils.ZkUtils$.getConsumersPerTopic(ZkUtils.scala:268) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance(ZookeeperConsumerConnector.scala:478) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala:449) scala.collection.immutable.Range$ByOne$class.foreach$mVc$sp(Range.scala:282) scala.collection.immutable.Range$$anon$2.foreach$mVc$sp(Range.scala:265) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:444) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anon$1.run(ZookeeperConsumerConnector.scala:401) TRACE 301438: 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.SocketChannelImpl.read(SocketChannelImpl.java:164) org.apache.zookeeper.ClientCnxn$SendThread.doIO(ClientCnxn.java:817) org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1089) TRACE 301439: java.lang.Object.getClass(Object.java:Unknown line) scala.Array$.copy(Array.scala:86) scala.collection.mutable.ResizableArray$class.copyToArray(ResizableArray.scala:73) scala.collection.mutable.ArrayBuffer.copyToArray(ArrayBuffer.scala:43) scala.collection.TraversableOnce$class.copyToArray(TraversableOnce.scala:358) scala.collection.mutable.ArrayBuffer.copyToArray(ArrayBuffer.scala:43) scala.collection.TraversableOnce$class.toArray(TraversableOnce.scala:389) scala.collection.mutable.ArrayBuffer.toArray(ArrayBuffer.scala:43) scala.collection.immutable.StringLike$class.format(StringLike.scala:252) scala.collection.immutable.StringOps.format(StringOps.scala:31) kafka.utils.Logging$class.msgWithLogIdent(Logging.scala:28) kafka.utils.Logging$class.info(Logging.scala:58) kafka.consumer.ZookeeperConsumerConnector.info(ZookeeperConsumerConnector.scala:88) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.updateFetcher(ZookeeperConsumerConnector.scala:582) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance(ZookeeperConsumerConnector.scala:540) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala:449) scala.collection.immutable.Range$ByOne$class.foreach$mVc$sp(Range.scala:282) scala.collection.immutable.Range$$anon$2.foreach$mVc$sp(Range.scala:265) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:444) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anon$1.run(ZookeeperConsumerConnector.scala:401) TRACE 301441: java.lang.String.toCharArray(String.java:2725) java.util.Formatter$Flags.parse(Formatter.java:4135) java.util.Formatter$FormatSpecifier.flags(Formatter.java:2555) java.util.Formatter$FormatSpecifier.(Formatter.java:2625) java.util.Formatter.parse(Formatter.java:2480) 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:252) scala.collection.immutable.StringOps.format(StringOps.scala:31) kafka.utils.Logging$class.msgWithLogIdent(Logging.scala:28) kafka.utils.Logging$class.info(Logging.scala:58) kafka.consumer.ZookeeperConsumerConnector.info(ZookeeperConsumerConnector.scala:88) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala:445) scala.collection.immutable.Range$ByOne$class.foreach$mVc$sp(Range.scala:282) scala.collection.immutable.Range$$anon$2.foreach$mVc$sp(Range.scala:265) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:444) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anon$1.run(ZookeeperConsumerConnector.scala:401) TRACE 301442: kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:444) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anon$1.run(ZookeeperConsumerConnector.scala:401) TRACE 301443: scala.util.parsing.combinator.Parsers$Parser$$anonfun$$tilde$greater$1.apply(Parsers.scala:235) scala.util.parsing.combinator.Parsers$Parser$$anonfun$$tilde$greater$1.apply(Parsers.scala:235) scala.util.parsing.combinator.Parsers$Success.flatMapWithNext(Parsers.scala:113) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$$anon$2.apply(Parsers.scala:742) scala.util.parsing.json.JSON$.parseRaw(JSON.scala:71) scala.util.parsing.json.JSON$.parseFull(JSON.scala:85) kafka.consumer.TopicCount$.constructTopicCount(TopicCount.scala:97) kafka.utils.ZkUtils$$anonfun$getConsumersPerTopic$1.apply(ZkUtils.scala:259) kafka.utils.ZkUtils$$anonfun$getConsumersPerTopic$1.apply(ZkUtils.scala:258) scala.collection.Iterator$class.foreach(Iterator.scala:631) scala.collection.JavaConversions$JIteratorWrapper.foreach(JavaConversions.scala:549) scala.collection.IterableLike$class.foreach(IterableLike.scala:79) scala.collection.JavaConversions$JListWrapper.foreach(JavaConversions.scala:596) kafka.utils.ZkUtils$.getConsumersPerTopic(ZkUtils.scala:258) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance(ZookeeperConsumerConnector.scala:478) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala:449) scala.collection.immutable.Range$ByOne$class.foreach$mVc$sp(Range.scala:282) scala.collection.immutable.Range$$anon$2.foreach$mVc$sp(Range.scala:265) TRACE 301444: scala.util.parsing.json.Lexer$$anonfun$charSeq$8.apply(Lexer.scala:77) scala.util.parsing.json.Lexer$$anonfun$charSeq$8.apply(Lexer.scala:77) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1$$anonfun$apply$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1$$anonfun$apply$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Failure.append(Parsers.scala:162) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$$anonfun$rep1$1.applyp$1(Parsers.scala:582) scala.util.parsing.combinator.Parsers$$anonfun$rep1$1.continue$1(Parsers.scala:587) scala.util.parsing.combinator.Parsers$$anonfun$rep1$1.apply(Parsers.scala:591) scala.util.parsing.combinator.Parsers$$anonfun$rep1$1.apply(Parsers.scala:577) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Success.flatMapWithNext(Parsers.scala:113) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) TRACE 301445: java.lang.Thread.currentThread(Thread.java:Unknown line) java.lang.ThreadLocal.get(ThreadLocal.java:124) sun.nio.ch.Util.getTemporaryDirectBuffer(Util.java:46) sun.nio.ch.IOUtil.read(IOUtil.java:209) sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:236) org.apache.zookeeper.ClientCnxn$SendThread.doIO(ClientCnxn.java:817) org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1089) TRACE 301447: java.lang.Object.notifyAll(Object.java:Unknown line) org.apache.zookeeper.ClientCnxn.finishPacket(ClientCnxn.java:598) org.apache.zookeeper.ClientCnxn.access$1300(ClientCnxn.java:80) org.apache.zookeeper.ClientCnxn$SendThread.readResponse(ClientCnxn.java:801) org.apache.zookeeper.ClientCnxn$SendThread.doIO(ClientCnxn.java:840) org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1089) TRACE 301448: java.util.HashMap$HashIterator.hasNext(HashMap.java:788) sun.nio.ch.SelectorImpl.processDeregisterQueue(SelectorImpl.java:128) sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:69) sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:69) sun.nio.ch.SelectorImpl.select(SelectorImpl.java:80) org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1066) TRACE 301449: java.util.Date.getTime(Date.java:866) org.apache.log4j.helpers.ISO8601DateFormat.format(ISO8601DateFormat.java:67) java.text.DateFormat.format(DateFormat.java:316) org.apache.log4j.helpers.PatternParser$DatePatternConverter.convert(PatternParser.java:443) org.apache.log4j.helpers.PatternConverter.format(PatternConverter.java:65) org.apache.log4j.PatternLayout.format(PatternLayout.java:506) org.apache.log4j.WriterAppender.subAppend(WriterAppender.java:310) org.apache.log4j.WriterAppender.append(WriterAppender.java:162) org.apache.log4j.AppenderSkeleton.doAppend(AppenderSkeleton.java:251) org.apache.log4j.helpers.AppenderAttachableImpl.appendLoopOnAppenders(AppenderAttachableImpl.java:66) org.apache.log4j.Category.callAppenders(Category.java:206) org.apache.log4j.Category.forcedLog(Category.java:391) org.apache.log4j.Category.info(Category.java:666) kafka.utils.Logging$class.info(Logging.scala:58) kafka.consumer.ZookeeperConsumerConnector.info(ZookeeperConsumerConnector.scala:88) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala:459) scala.collection.immutable.Range$ByOne$class.foreach$mVc$sp(Range.scala:282) scala.collection.immutable.Range$$anon$2.foreach$mVc$sp(Range.scala:265) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:444) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anon$1.run(ZookeeperConsumerConnector.scala:401) TRACE 301450: scala.runtime.AbstractFunction2.(AbstractFunction2.scala:16) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$updateFetcher$2$$anonfun$apply$16.(ZookeeperConsumerConnector.scala:583) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$updateFetcher$2.apply(ZookeeperConsumerConnector.scala:583) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$updateFetcher$2.apply(ZookeeperConsumerConnector.scala:582) kafka.utils.Logging$class.info(Logging.scala:58) kafka.consumer.ZookeeperConsumerConnector.info(ZookeeperConsumerConnector.scala:88) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.updateFetcher(ZookeeperConsumerConnector.scala:582) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance(ZookeeperConsumerConnector.scala:540) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala:449) scala.collection.immutable.Range$ByOne$class.foreach$mVc$sp(Range.scala:282) scala.collection.immutable.Range$$anon$2.foreach$mVc$sp(Range.scala:265) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:444) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anon$1.run(ZookeeperConsumerConnector.scala:401) TRACE 301451: java.util.Calendar.setTimeInMillis(Calendar.java:1102) java.util.Calendar.setTime(Calendar.java:1075) org.apache.log4j.helpers.ISO8601DateFormat.format(ISO8601DateFormat.java:75) java.text.DateFormat.format(DateFormat.java:316) org.apache.log4j.helpers.PatternParser$DatePatternConverter.convert(PatternParser.java:443) org.apache.log4j.helpers.PatternConverter.format(PatternConverter.java:65) org.apache.log4j.PatternLayout.format(PatternLayout.java:506) org.apache.log4j.WriterAppender.subAppend(WriterAppender.java:310) org.apache.log4j.WriterAppender.append(WriterAppender.java:162) org.apache.log4j.AppenderSkeleton.doAppend(AppenderSkeleton.java:251) org.apache.log4j.helpers.AppenderAttachableImpl.appendLoopOnAppenders(AppenderAttachableImpl.java:66) org.apache.log4j.Category.callAppenders(Category.java:206) org.apache.log4j.Category.forcedLog(Category.java:391) org.apache.log4j.Category.info(Category.java:666) org.apache.zookeeper.ClientCnxn$SendThread.primeConnection(ClientCnxn.java:908) org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1081) TRACE 301452: sun.nio.ch.EPollArrayWrapper.epollCtl(EPollArrayWrapper.java:Unknown line) sun.nio.ch.EPollArrayWrapper.updateRegistrations(EPollArrayWrapper.java:246) sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:209) sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:65) sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:69) sun.nio.ch.SelectorImpl.select(SelectorImpl.java:80) org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1066) TRACE 301453: 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.SocketChannelImpl.write(SocketChannelImpl.java:327) org.apache.zookeeper.ClientCnxn$SendThread.doIO(ClientCnxn.java:851) org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1089) TRACE 301456: java.util.concurrent.ConcurrentHashMap$HashEntry.newArray(ConcurrentHashMap.java:205) java.util.concurrent.ConcurrentHashMap$Segment.(ConcurrentHashMap.java:291) java.util.concurrent.ConcurrentHashMap.(ConcurrentHashMap.java:613) java.util.concurrent.ConcurrentHashMap.(ConcurrentHashMap.java:652) kafka.utils.Pool.(Pool.scala:26) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance$1.apply(ZookeeperConsumerConnector.scala:495) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance$1.apply(ZookeeperConsumerConnector.scala:494) scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:80) scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:80) scala.collection.Iterator$class.foreach(Iterator.scala:631) scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:161) scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:194) scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:39) scala.collection.mutable.HashMap.foreach(HashMap.scala:80) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance(ZookeeperConsumerConnector.scala:494) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala:449) scala.collection.immutable.Range$ByOne$class.foreach$mVc$sp(Range.scala:282) scala.collection.immutable.Range$$anon$2.foreach$mVc$sp(Range.scala:265) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:444) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anon$1.run(ZookeeperConsumerConnector.scala:401) TRACE 301463: java.util.regex.Pattern.compile(Pattern.java:1452) java.util.regex.Pattern.(Pattern.java:1133) java.util.regex.Pattern.compile(Pattern.java:823) java.lang.String.split(String.java:2292) java.lang.String.split(String.java:2334) kafka.cluster.Broker$.createBroker(Broker.scala:27) kafka.utils.ZkUtils$$anonfun$getCluster$1.apply(ZkUtils.scala:205) kafka.utils.ZkUtils$$anonfun$getCluster$1.apply(ZkUtils.scala:203) scala.collection.Iterator$class.foreach(Iterator.scala:631) scala.collection.JavaConversions$JIteratorWrapper.foreach(JavaConversions.scala:549) scala.collection.IterableLike$class.foreach(IterableLike.scala:79) scala.collection.JavaConversions$JListWrapper.foreach(JavaConversions.scala:596) kafka.utils.ZkUtils$.getCluster(ZkUtils.scala:203) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala:447) scala.collection.immutable.Range$ByOne$class.foreach$mVc$sp(Range.scala:282) scala.collection.immutable.Range$$anon$2.foreach$mVc$sp(Range.scala:265) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:444) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anon$1.run(ZookeeperConsumerConnector.scala:401) TRACE 301464: scala.util.parsing.json.JSON$.resolveType(JSON.scala:94) scala.util.parsing.json.JSON$$anonfun$resolveType$1.apply(JSON.scala:96) scala.collection.immutable.MapLike$$anonfun$transform$2.apply(MapLike.scala:121) scala.collection.immutable.MapLike$$anonfun$transform$2.apply(MapLike.scala:121) scala.collection.immutable.Map$Map1.foreach(Map.scala:105) scala.collection.immutable.MapLike$class.transform(MapLike.scala:121) scala.collection.immutable.Map$Map1.transform(Map.scala:93) scala.util.parsing.json.JSON$.resolveType(JSON.scala:95) scala.util.parsing.json.JSON$.parseFull(JSON.scala:86) kafka.consumer.TopicCount$.constructTopicCount(TopicCount.scala:97) kafka.utils.ZkUtils$$anonfun$getConsumersPerTopic$1.apply(ZkUtils.scala:259) kafka.utils.ZkUtils$$anonfun$getConsumersPerTopic$1.apply(ZkUtils.scala:258) scala.collection.Iterator$class.foreach(Iterator.scala:631) scala.collection.JavaConversions$JIteratorWrapper.foreach(JavaConversions.scala:549) scala.collection.IterableLike$class.foreach(IterableLike.scala:79) scala.collection.JavaConversions$JListWrapper.foreach(JavaConversions.scala:596) kafka.utils.ZkUtils$.getConsumersPerTopic(ZkUtils.scala:258) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance(ZookeeperConsumerConnector.scala:478) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala:449) scala.collection.immutable.Range$ByOne$class.foreach$mVc$sp(Range.scala:282) scala.collection.immutable.Range$$anon$2.foreach$mVc$sp(Range.scala:265) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:444) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anon$1.run(ZookeeperConsumerConnector.scala:401) TRACE 301465: scala.util.parsing.json.Parser$$anonfun$jsonObj$1$$anonfun$apply$1.apply(Parser.scala:67) scala.util.parsing.json.Parser$$anonfun$jsonObj$1$$anonfun$apply$1.apply(Parser.scala:67) scala.util.parsing.combinator.Parsers$class.rep1sep(Parsers.scala:634) scala.util.parsing.json.Parser.rep1sep(Parser.scala:45) scala.util.parsing.combinator.Parsers$class.repsep(Parsers.scala:553) scala.util.parsing.json.Parser.repsep(Parser.scala:45) scala.util.parsing.json.Parser$$anonfun$jsonObj$1.apply(Parser.scala:67) scala.util.parsing.json.Parser$$anonfun$jsonObj$1.apply(Parser.scala:67) scala.util.parsing.combinator.Parsers$Parser$$anonfun$$tilde$greater$1.apply(Parsers.scala:235) scala.util.parsing.combinator.Parsers$Parser$$anonfun$$tilde$greater$1.apply(Parsers.scala:235) scala.util.parsing.combinator.Parsers$Success.flatMapWithNext(Parsers.scala:113) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$$anon$2.apply(Parsers.scala:742) scala.util.parsing.json.JSON$.parseRaw(JSON.scala:71) scala.util.parsing.json.JSON$.parseFull(JSON.scala:85) kafka.consumer.TopicCount$.constructTopicCount(TopicCount.scala:97) kafka.utils.ZkUtils$$anonfun$getConsumersPerTopic$1.apply(ZkUtils.scala:259) kafka.utils.ZkUtils$$anonfun$getConsumersPerTopic$1.apply(ZkUtils.scala:258) scala.collection.Iterator$class.foreach(Iterator.scala:631) TRACE 301466: scala.util.parsing.json.Lexer.token(Lexer.scala:26) scala.util.parsing.combinator.lexical.Scanners$Scanner.(Scanners.scala:55) scala.util.parsing.combinator.lexical.Scanners$Scanner.rest(Scanners.scala:66) scala.util.parsing.combinator.lexical.Scanners$Scanner.rest(Scanners.scala:50) scala.util.parsing.combinator.Parsers$$anonfun$acceptMatch$1.apply(Parsers.scala:493) scala.util.parsing.combinator.Parsers$$anonfun$acceptMatch$1.apply(Parsers.scala:492) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1$$anonfun$apply$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1$$anonfun$apply$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Failure.append(Parsers.scala:162) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Success.flatMapWithNext(Parsers.scala:113) TRACE 301467: java.lang.System.arraycopy(System.java:Unknown line) java.nio.HeapByteBuffer.get(HeapByteBuffer.java:128) org.apache.zookeeper.server.ByteBufferInputStream.read(ByteBufferInputStream.java:53) java.io.DataInputStream.readFully(DataInputStream.java:178) java.io.DataInputStream.readLong(DataInputStream.java:399) org.apache.jute.BinaryInputArchive.readLong(BinaryInputArchive.java:67) org.apache.zookeeper.proto.ReplyHeader.deserialize(ReplyHeader.java:66) org.apache.zookeeper.ClientCnxn$SendThread.readResponse(ClientCnxn.java:717) org.apache.zookeeper.ClientCnxn$SendThread.doIO(ClientCnxn.java:840) org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1089) TRACE 301468: java.util.HashMap.(HashMap.java:209) java.util.HashSet.(HashSet.java:86) org.apache.zookeeper.ZooKeeper$ZKWatchManager.materialize(ZooKeeper.java:159) org.apache.zookeeper.ClientCnxn$EventThread.queueEvent(ClientCnxn.java:457) org.apache.zookeeper.ClientCnxn$SendThread.readResponse(ClientCnxn.java:762) org.apache.zookeeper.ClientCnxn$SendThread.doIO(ClientCnxn.java:840) org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1089) TRACE 301469: scala.util.parsing.json.Parser$$anonfun$stringVal$1.isDefinedAt(Parser.scala:71) scala.util.parsing.json.Parser$$anonfun$stringVal$1.isDefinedAt(Parser.scala:71) scala.util.parsing.combinator.Parsers$$anonfun$acceptMatch$1.apply(Parsers.scala:493) scala.util.parsing.combinator.Parsers$$anonfun$acceptMatch$1.apply(Parsers.scala:492) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Success.flatMapWithNext(Parsers.scala:113) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) TRACE 301470: java.lang.Thread.currentThread(Thread.java:Unknown line) org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:670) org.I0Itec.zkclient.ZkClient.readData(ZkClient.java:766) org.I0Itec.zkclient.ZkClient.readData(ZkClient.java:761) org.I0Itec.zkclient.ZkClient.readData(ZkClient.java:750) org.I0Itec.zkclient.ZkClient.readData(ZkClient.java:744) kafka.utils.ZkUtils$.readData(ZkUtils.scala:162) kafka.consumer.TopicCount$.constructTopicCount(TopicCount.scala:70) kafka.utils.ZkUtils$$anonfun$getConsumersPerTopic$1.apply(ZkUtils.scala:259) kafka.utils.ZkUtils$$anonfun$getConsumersPerTopic$1.apply(ZkUtils.scala:258) scala.collection.Iterator$class.foreach(Iterator.scala:631) scala.collection.JavaConversions$JIteratorWrapper.foreach(JavaConversions.scala:549) scala.collection.IterableLike$class.foreach(IterableLike.scala:79) scala.collection.JavaConversions$JListWrapper.foreach(JavaConversions.scala:596) kafka.utils.ZkUtils$.getConsumersPerTopic(ZkUtils.scala:258) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance(ZookeeperConsumerConnector.scala:478) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala:449) scala.collection.immutable.Range$ByOne$class.foreach$mVc$sp(Range.scala:282) scala.collection.immutable.Range$$anon$2.foreach$mVc$sp(Range.scala:265) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:444) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anon$1.run(ZookeeperConsumerConnector.scala:401) TRACE 301471: java.util.AbstractCollection.toArray(AbstractCollection.java:119) java.util.ArrayList.(ArrayList.java:131) kafka.utils.Pool.values(Pool.scala:47) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.updateFetcher(ZookeeperConsumerConnector.scala:579) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance(ZookeeperConsumerConnector.scala:540) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala:449) scala.collection.immutable.Range$ByOne$class.foreach$mVc$sp(Range.scala:282) scala.collection.immutable.Range$$anon$2.foreach$mVc$sp(Range.scala:265) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:444) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anon$1.run(ZookeeperConsumerConnector.scala:401) TRACE 301472: scala.util.parsing.combinator.Parsers$$anonfun$rep1$1.apply(Parsers.scala:577) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Success.flatMapWithNext(Parsers.scala:113) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) TRACE 301473: org.apache.jute.BinaryInputArchive.readBuffer(BinaryInputArchive.java:102) org.apache.zookeeper.proto.GetDataResponse.deserialize(GetDataResponse.java:55) org.apache.zookeeper.ClientCnxn$SendThread.readResponse(ClientCnxn.java:793) org.apache.zookeeper.ClientCnxn$SendThread.doIO(ClientCnxn.java:840) org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1089) TRACE 301474: scala.util.parsing.combinator.lexical.Lexical.whitespaceChar(Lexical.scala:41) scala.util.parsing.json.Lexer$$anonfun$whitespace$1.apply(Lexer.scala:47) scala.util.parsing.json.Lexer$$anonfun$whitespace$1.apply(Lexer.scala:47) scala.util.parsing.combinator.Parsers$$anonfun$rep1$1.apply(Parsers.scala:590) scala.util.parsing.combinator.Parsers$$anonfun$rep1$1.apply(Parsers.scala:577) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.lexical.Scanners$Scanner.(Scanners.scala:53) scala.util.parsing.combinator.lexical.Scanners$Scanner.rest(Scanners.scala:66) scala.util.parsing.combinator.lexical.Scanners$Scanner.rest(Scanners.scala:50) scala.util.parsing.combinator.Parsers$$anonfun$acceptMatch$1.apply(Parsers.scala:493) scala.util.parsing.combinator.Parsers$$anonfun$acceptMatch$1.apply(Parsers.scala:492) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) TRACE 301475: scala.util.parsing.combinator.lexical.StdLexical$$anonfun$_delim$2$$anonfun$apply$27.apply(StdLexical.scala:84) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1$$anonfun$apply$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1$$anonfun$apply$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Failure.append(Parsers.scala:162) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1$$anonfun$apply$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1$$anonfun$apply$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Failure.append(Parsers.scala:162) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.lexical.Scanners$Scanner.(Scanners.scala:55) scala.util.parsing.combinator.lexical.Scanners$Scanner.rest(Scanners.scala:66) scala.util.parsing.combinator.lexical.Scanners$Scanner.rest(Scanners.scala:50) scala.util.parsing.combinator.Parsers$$anonfun$acceptMatch$1.apply(Parsers.scala:493) scala.util.parsing.combinator.Parsers$$anonfun$acceptMatch$1.apply(Parsers.scala:492) TRACE 301476: scala.util.parsing.json.Lexer$$anonfun$token$2.(Lexer.scala:27) scala.util.parsing.json.Lexer.token(Lexer.scala:27) scala.util.parsing.combinator.lexical.Scanners$Scanner.(Scanners.scala:55) scala.util.parsing.combinator.lexical.Scanners$Scanner.rest(Scanners.scala:66) scala.util.parsing.combinator.lexical.Scanners$Scanner.rest(Scanners.scala:50) scala.util.parsing.combinator.Parsers$$anonfun$acceptMatch$1.apply(Parsers.scala:493) scala.util.parsing.combinator.Parsers$$anonfun$acceptMatch$1.apply(Parsers.scala:492) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Success.flatMapWithNext(Parsers.scala:113) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) TRACE 301477: java.util.Arrays.copyOf(Arrays.java:2882) java.lang.StringValue.from(StringValue.java:24) java.lang.String.(String.java:178) java.lang.String.valueOf(String.java:2840) java.lang.Character.toString(Character.java:2136) java.lang.String.valueOf(String.java:2826) scala.collection.mutable.StringBuilder.append(StringBuilder.scala:178) scala.util.parsing.combinator.Parsers$$anonfun$accept$2.apply(Parsers.scala:460) scala.util.parsing.combinator.Parsers$$anonfun$accept$2.apply(Parsers.scala:460) scala.util.parsing.combinator.Parsers$$anonfun$acceptIf$1.apply(Parsers.scala:489) scala.util.parsing.combinator.Parsers$$anonfun$acceptIf$1.apply(Parsers.scala:487) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1$$anonfun$apply$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1$$anonfun$apply$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Failure.append(Parsers.scala:162) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) TRACE 301478: scala.util.parsing.json.Lexer.charSeq(Lexer.scala:70) scala.util.parsing.json.Lexer$$anonfun$string$1$$anonfun$apply$13.apply(Lexer.scala:45) scala.util.parsing.json.Lexer$$anonfun$string$1$$anonfun$apply$13.apply(Lexer.scala:45) scala.util.parsing.combinator.Parsers$$anonfun$rep1$1.apply(Parsers.scala:590) scala.util.parsing.combinator.Parsers$$anonfun$rep1$1.apply(Parsers.scala:577) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Success.flatMapWithNext(Parsers.scala:113) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) TRACE 301479: scala.collection.mutable.FlatHashTable$class.$init$(FlatHashTable.scala:40) scala.collection.mutable.HashSet.(HashSet.scala:38) kafka.consumer.TopicCount$$anonfun$makeConsumerThreadIdsPerTopic$1.apply(TopicCount.scala:36) kafka.consumer.TopicCount$$anonfun$makeConsumerThreadIdsPerTopic$1.apply(TopicCount.scala:35) scala.collection.immutable.Map$Map1.foreach(Map.scala:105) kafka.consumer.TopicCount$class.makeConsumerThreadIdsPerTopic(TopicCount.scala:35) kafka.consumer.StaticTopicCount.makeConsumerThreadIdsPerTopic(TopicCount.scala:123) kafka.consumer.StaticTopicCount.getConsumerThreadIdsPerTopic(TopicCount.scala:128) kafka.consumer.StaticTopicCount.getConsumerThreadIdsPerTopic(TopicCount.scala:123) kafka.utils.ZkUtils$$anonfun$getConsumersPerTopic$1.apply(ZkUtils.scala:260) kafka.utils.ZkUtils$$anonfun$getConsumersPerTopic$1.apply(ZkUtils.scala:258) scala.collection.Iterator$class.foreach(Iterator.scala:631) scala.collection.JavaConversions$JIteratorWrapper.foreach(JavaConversions.scala:549) scala.collection.IterableLike$class.foreach(IterableLike.scala:79) scala.collection.JavaConversions$JListWrapper.foreach(JavaConversions.scala:596) kafka.utils.ZkUtils$.getConsumersPerTopic(ZkUtils.scala:258) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance(ZookeeperConsumerConnector.scala:478) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala:449) scala.collection.immutable.Range$ByOne$class.foreach$mVc$sp(Range.scala:282) scala.collection.immutable.Range$$anon$2.foreach$mVc$sp(Range.scala:265) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:444) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anon$1.run(ZookeeperConsumerConnector.scala:401) TRACE 301480: scala.collection.TraversableOnce$class.addString(TraversableOnce.scala:502) scala.collection.immutable.List.addString(List.scala:45) scala.collection.TraversableOnce$class.mkString(TraversableOnce.scala:470) scala.collection.immutable.List.mkString(List.scala:45) scala.collection.TraversableOnce$class.mkString(TraversableOnce.scala:481) scala.collection.immutable.List.mkString(List.scala:45) scala.util.parsing.json.Lexer$$anonfun$intList$2.apply(Lexer.scala:53) scala.util.parsing.json.Lexer$$anonfun$intList$2.apply(Lexer.scala:53) scala.util.parsing.combinator.Parsers$Success.map(Parsers.scala:107) scala.util.parsing.combinator.Parsers$Success.map(Parsers.scala:106) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1$$anonfun$apply$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1$$anonfun$apply$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Failure.append(Parsers.scala:162) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203) scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200) TRACE 301487: java.io.BufferedReader.readLine(BufferedReader.java:344) java.io.LineNumberReader.readLine(LineNumberReader.java:182) org.apache.log4j.DefaultThrowableRenderer.render(DefaultThrowableRenderer.java:71) org.apache.log4j.spi.ThrowableInformation.getThrowableStrRep(ThrowableInformation.java:87) org.apache.log4j.spi.LoggingEvent.getThrowableStrRep(LoggingEvent.java:413) org.apache.log4j.WriterAppender.subAppend(WriterAppender.java:313) org.apache.log4j.WriterAppender.append(WriterAppender.java:162) org.apache.log4j.AppenderSkeleton.doAppend(AppenderSkeleton.java:251) org.apache.log4j.helpers.AppenderAttachableImpl.appendLoopOnAppenders(AppenderAttachableImpl.java:66) org.apache.log4j.Category.callAppenders(Category.java:206) org.apache.log4j.Category.forcedLog(Category.java:391) org.apache.log4j.Category.error(Category.java:322) kafka.utils.Logging$class.error(Logging.scala:86) kafka.consumer.TopicCount$.error(TopicCount.scala:46) kafka.consumer.TopicCount$.constructTopicCount(TopicCount.scala:104) kafka.utils.ZkUtils$$anonfun$getConsumersPerTopic$1.apply(ZkUtils.scala:259) kafka.utils.ZkUtils$$anonfun$getConsumersPerTopic$1.apply(ZkUtils.scala:258) scala.collection.Iterator$class.foreach(Iterator.scala:631) scala.collection.JavaConversions$JIteratorWrapper.foreach(JavaConversions.scala:549) scala.collection.IterableLike$class.foreach(IterableLike.scala:79) scala.collection.JavaConversions$JListWrapper.foreach(JavaConversions.scala:596) kafka.utils.ZkUtils$.getConsumersPerTopic(ZkUtils.scala:258) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance(ZookeeperConsumerConnector.scala:478) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala:449) scala.collection.immutable.Range$ByOne$class.foreach$mVc$sp(Range.scala:282) scala.collection.immutable.Range$$anon$2.foreach$mVc$sp(Range.scala:265) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:444) kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$reinitializeConsumer(ZookeeperConsumerConnector.scala:733) kafka.consumer.ZookeeperConsumerConnector.consume(ZookeeperConsumerConnector.scala:207) kafka.consumer.ZookeeperConsumerConnector.createMessageStreams(ZookeeperConsumerConnector.scala:137) TRACE 301488: java.lang.StringBuffer.capacity(StringBuffer.java:131) org.apache.log4j.PatternLayout.format(PatternLayout.java:497) org.apache.log4j.WriterAppender.subAppend(WriterAppender.java:310) org.apache.log4j.WriterAppender.append(WriterAppender.java:162) org.apache.log4j.AppenderSkeleton.doAppend(AppenderSkeleton.java:251) org.apache.log4j.helpers.AppenderAttachableImpl.appendLoopOnAppenders(AppenderAttachableImpl.java:66) org.apache.log4j.Category.callAppenders(Category.java:206) org.apache.log4j.Category.forcedLog(Category.java:391) org.apache.log4j.Category.info(Category.java:666) kafka.utils.Logging$class.info(Logging.scala:58) kafka.consumer.ConsumerIterator.info(ConsumerIterator.scala:32) kafka.consumer.ConsumerIterator.clearCurrentChunk(ConsumerIterator.scala:92) kafka.consumer.KafkaStream.clear(KafkaStream.scala:44) kafka.consumer.Fetcher$$anonfun$clearFetcherQueues$3$$anonfun$apply$1.apply(Fetcher.scala:55) kafka.consumer.Fetcher$$anonfun$clearFetcherQueues$3$$anonfun$apply$1.apply(Fetcher.scala:55) scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61) scala.collection.immutable.List.foreach(List.scala:45) kafka.consumer.Fetcher$$anonfun$clearFetcherQueues$3.apply(Fetcher.scala:55) kafka.consumer.Fetcher$$anonfun$clearFetcherQueues$3.apply(Fetcher.scala:55) scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:80) scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:80) scala.collection.Iterator$class.foreach(Iterator.scala:631) scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:161) scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:194) scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:39) scala.collection.mutable.HashMap.foreach(HashMap.scala:80) kafka.consumer.Fetcher.clearFetcherQueues(Fetcher.scala:55) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$closeFetchersForQueues(ZookeeperConsumerConnector.scala:553) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.closeFetchers(ZookeeperConsumerConnector.scala:573) kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance(ZookeeperConsumerConnector.scala:487) CPU SAMPLES BEGIN (total = 6315) Tue Aug 21 16:45:05 2012 rank self accum count trace method 1 97.80% 97.80% 6176 300932 sun.nio.ch.EPollArrayWrapper.epollWait 2 0.08% 97.88% 5 301417 scala.util.parsing.json.Lexer$$anonfun$string$1$$anonfun$apply$13$$anonfun$apply$14.apply 3 0.06% 97.94% 4 301411 java.lang.Thread.currentThread 4 0.05% 97.99% 3 301433 sun.misc.Unsafe.getInt 5 0.03% 98.02% 2 301342 java.lang.Character.toString 6 0.03% 98.05% 2 301360 java.nio.HeapByteBuffer. 7 0.03% 98.08% 2 301412 java.lang.Character.toString 8 0.03% 98.12% 2 301431 java.lang.Integer.toString 9 0.03% 98.15% 2 301446 sun.nio.ch.EPollArrayWrapper.interrupt 10 0.03% 98.18% 2 301454 sun.nio.ch.FileDispatcher.write0 11 0.03% 98.21% 2 301492 java.lang.Shutdown.halt0 12 0.02% 98.23% 1 300020 java.util.zip.ZipFile.read 13 0.02% 98.24% 1 300032 java.util.zip.ZipFile.open 14 0.02% 98.26% 1 300055 java.util.zip.ZipFile.open 15 0.02% 98.27% 1 300059 java.lang.StringCoding$StringEncoder.encode 16 0.02% 98.29% 1 300070 java.lang.ClassLoader.defineClass1 17 0.02% 98.31% 1 300075 java.util.zip.ZipFile.getEntry 18 0.02% 98.32% 1 300087 java.lang.ClassLoader.defineClass1 19 0.02% 98.34% 1 300101 java.lang.String.toCharArray 20 0.02% 98.35% 1 300119 scala.collection.immutable.Vector$. 21 0.02% 98.37% 1 300147 java.io.UnixFileSystem.getBooleanAttributes0 22 0.02% 98.38% 1 300177 java.lang.ClassLoader.defineClass1 23 0.02% 98.40% 1 300201 java.lang.ClassLoader.findBootstrapClass 24 0.02% 98.42% 1 300222 java.lang.System.arraycopy 25 0.02% 98.43% 1 300224 java.lang.ClassLoader.defineClass1 26 0.02% 98.45% 1 300234 java.lang.ClassLoader.defineClass1 27 0.02% 98.46% 1 300286 java.lang.System.arraycopy 28 0.02% 98.48% 1 300302 org.codehaus.jackson.map.ObjectMapper. 29 0.02% 98.50% 1 300355 java.text.SimpleDateFormat.initialize 30 0.02% 98.51% 1 300381 java.lang.ClassLoader.defineClass1 31 0.02% 98.53% 1 300387 java.util.zip.ZipFile.getEntry 32 0.02% 98.54% 1 300399 java.lang.ClassLoader.findBootstrapClass 33 0.02% 98.56% 1 300415 java.lang.StringCoding$StringEncoder.encode 34 0.02% 98.57% 1 300421 java.lang.ClassLoader.defineClass1 35 0.02% 98.59% 1 300460 org.codehaus.jackson.JsonFactory._createJsonParser 36 0.02% 98.61% 1 300493 java.lang.Class.getDeclaredConstructors0 37 0.02% 98.62% 1 300511 java.lang.ClassLoader.defineClass1 38 0.02% 98.64% 1 300525 java.lang.ClassLoader.defineClass1 39 0.02% 98.65% 1 300562 com.linkedin.samsa.metrics.JvmMetrics. 40 0.02% 98.67% 1 300581 java.lang.String.toCharArray 41 0.02% 98.69% 1 300606 java.util.zip.Inflater.inflateBytes 42 0.02% 98.70% 1 300649 java.io.UnixFileSystem.getBooleanAttributes0 43 0.02% 98.72% 1 300678 java.lang.ClassLoader.defineClass1 44 0.02% 98.73% 1 300679 scala.collection.JavaConversions$.asScalaBuffer 45 0.02% 98.75% 1 300720 java.util.zip.Inflater.inflateBytes 46 0.02% 98.76% 1 300751 java.util.zip.Inflater.inflateBytes 47 0.02% 98.78% 1 300768 scala.collection.immutable.Set$Set2.$plus 48 0.02% 98.80% 1 300799 java.lang.ClassLoader.defineClass1 49 0.02% 98.81% 1 300820 java.lang.ClassLoader.defineClass1 50 0.02% 98.83% 1 300862 java.net.Inet6AddressImpl.lookupAllHostAddr 51 0.02% 98.84% 1 300872 kafka.consumer.ZookeeperConsumerConnector$$anonfun$connectZk$1. 52 0.02% 98.86% 1 300884 java.util.zip.ZipFile.getEntry 53 0.02% 98.88% 1 300909 java.lang.ClassLoader.defineClass1 54 0.02% 98.89% 1 300948 java.util.zip.Inflater.inflateBytes 55 0.02% 98.91% 1 301024 sun.management.ManagementFactory.getRuntimeMXBean 56 0.02% 98.92% 1 301057 java.lang.String.concat 57 0.02% 98.94% 1 301090 java.lang.String.concat 58 0.02% 98.95% 1 301107 scala.collection.immutable.HashSet. 59 0.02% 98.97% 1 301133 java.lang.Throwable.fillInStackTrace 60 0.02% 98.99% 1 301162 java.lang.ClassLoader.defineClass1 61 0.02% 99.00% 1 301172 java.lang.ClassLoader.checkCerts 62 0.02% 99.02% 1 301184 java.io.ByteArrayOutputStream. 63 0.02% 99.03% 1 301189 scala.util.parsing.combinator.Parsers$class.Parser 64 0.02% 99.05% 1 301219 java.lang.AbstractStringBuilder. 65 0.02% 99.07% 1 301253 java.lang.Throwable.fillInStackTrace 66 0.02% 99.08% 1 301293 java.io.UnixFileSystem.getBooleanAttributes0 67 0.02% 99.10% 1 301325 scala.util.parsing.json.Parser.value 68 0.02% 99.11% 1 301345 java.lang.Character.toString 69 0.02% 99.13% 1 301346 scala.util.parsing.input.CharSequenceReader.offset 70 0.02% 99.14% 1 301347 java.lang.Character.toString 71 0.02% 99.16% 1 301348 scala.util.parsing.combinator.Parsers$$anonfun$accept$1.apply 72 0.02% 99.18% 1 301372 java.io.UnixFileSystem.getBooleanAttributes0 73 0.02% 99.19% 1 301402 kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$updateFetcher$2.apply 74 0.02% 99.21% 1 301410 org.apache.jute.BinaryInputArchive.readString 75 0.02% 99.22% 1 301413 java.lang.System.arraycopy 76 0.02% 99.24% 1 301414 scala.util.parsing.combinator.Parsers$$anonfun$accept$1.apply 77 0.02% 99.26% 1 301415 scala.util.parsing.combinator.Parsers$$anonfun$acceptIf$1.apply 78 0.02% 99.27% 1 301416 scala.collection.mutable.ListBuffer. 79 0.02% 99.29% 1 301418 java.lang.Thread.currentThread 80 0.02% 99.30% 1 301424 scala.collection.JavaConversions$.asScalaSet 81 0.02% 99.32% 1 301427 java.lang.System.arraycopy 82 0.02% 99.33% 1 301428 java.lang.Character.charValue 83 0.02% 99.35% 1 301429 java.lang.Thread.currentThread 84 0.02% 99.37% 1 301430 scala.collection.mutable.HashTable$$anon$1.hasNext 85 0.02% 99.38% 1 301432 java.nio.charset.CoderResult.isOverflow 86 0.02% 99.40% 1 301434 java.lang.System.arraycopy 87 0.02% 99.41% 1 301435 java.lang.Thread.currentThread 88 0.02% 99.43% 1 301436 java.lang.Object.clone 89 0.02% 99.45% 1 301437 scala.collection.mutable.HashTable$$anon$1.scan 90 0.02% 99.46% 1 301438 java.lang.Thread.currentThread 91 0.02% 99.48% 1 301439 java.lang.Object.getClass 92 0.02% 99.49% 1 301441 java.lang.String.toCharArray 93 0.02% 99.51% 1 301442 kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance 94 0.02% 99.52% 1 301443 scala.util.parsing.combinator.Parsers$Parser$$anonfun$$tilde$greater$1.apply 95 0.02% 99.54% 1 301444 scala.util.parsing.json.Lexer$$anonfun$charSeq$8.apply 96 0.02% 99.56% 1 301445 java.lang.Thread.currentThread 97 0.02% 99.57% 1 301447 java.lang.Object.notifyAll 98 0.02% 99.59% 1 301448 java.util.HashMap$HashIterator.hasNext 99 0.02% 99.60% 1 301449 java.util.Date.getTime 100 0.02% 99.62% 1 301450 scala.runtime.AbstractFunction2. 101 0.02% 99.64% 1 301451 java.util.Calendar.setTimeInMillis 102 0.02% 99.65% 1 301452 sun.nio.ch.EPollArrayWrapper.epollCtl 103 0.02% 99.67% 1 301453 java.lang.Thread.currentThread 104 0.02% 99.68% 1 301456 java.util.concurrent.ConcurrentHashMap$HashEntry.newArray 105 0.02% 99.70% 1 301463 java.util.regex.Pattern.compile 106 0.02% 99.71% 1 301464 scala.util.parsing.json.JSON$.resolveType 107 0.02% 99.73% 1 301465 scala.util.parsing.json.Parser$$anonfun$jsonObj$1$$anonfun$apply$1.apply 108 0.02% 99.75% 1 301466 scala.util.parsing.json.Lexer.token 109 0.02% 99.76% 1 301467 java.lang.System.arraycopy 110 0.02% 99.78% 1 301468 java.util.HashMap. 111 0.02% 99.79% 1 301469 scala.util.parsing.json.Parser$$anonfun$stringVal$1.isDefinedAt 112 0.02% 99.81% 1 301470 java.lang.Thread.currentThread 113 0.02% 99.83% 1 301471 java.util.AbstractCollection.toArray 114 0.02% 99.84% 1 301472 scala.util.parsing.combinator.Parsers$$anonfun$rep1$1.apply 115 0.02% 99.86% 1 301473 org.apache.jute.BinaryInputArchive.readBuffer 116 0.02% 99.87% 1 301474 scala.util.parsing.combinator.lexical.Lexical.whitespaceChar 117 0.02% 99.89% 1 301475 scala.util.parsing.combinator.lexical.StdLexical$$anonfun$_delim$2$$anonfun$apply$27.apply 118 0.02% 99.90% 1 301476 scala.util.parsing.json.Lexer$$anonfun$token$2. 119 0.02% 99.92% 1 301477 java.util.Arrays.copyOf 120 0.02% 99.94% 1 301478 scala.util.parsing.json.Lexer.charSeq 121 0.02% 99.95% 1 301479 scala.collection.mutable.FlatHashTable$class.$init$ 122 0.02% 99.97% 1 301480 scala.collection.TraversableOnce$class.addString 123 0.02% 99.98% 1 301487 java.io.BufferedReader.readLine 124 0.02% 100.00% 1 301488 java.lang.StringBuffer.capacity CPU SAMPLES END