Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- 2014-03-19 08:41:53
- Full thread dump OpenJDK 64-Bit Server VM (23.7-b01 mixed mode):
- "spark-akka.actor.default-dispatcher-1588" daemon prio=10 tid=0x00000000019c2800 nid=0x6aec waiting on condition [0x00007f0c337e8000]
- java.lang.Thread.State: TIMED_WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbd6f8e8> (a akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinPool)
- at akka.jsr166y.ForkJoinPool.idleAwaitWork(ForkJoinPool.java:1626)
- at akka.jsr166y.ForkJoinPool.scan(ForkJoinPool.java:1579)
- at akka.jsr166y.ForkJoinPool.runWorker(ForkJoinPool.java:1479)
- at akka.jsr166y.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:104)
- "spark-2870" daemon prio=10 tid=0x00007f0c5c8be800 nid=0x6aeb waiting on condition [0x00007f0c3368b000]
- java.lang.Thread.State: TIMED_WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbed7478> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2082)
- at java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "spark-2869" daemon prio=10 tid=0x00007f0c5c8f1800 nid=0x6aea waiting on condition [0x00007f0c33548000]
- java.lang.Thread.State: TIMED_WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbed7478> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2082)
- at java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "sparkExecutor-1522" daemon prio=10 tid=0x00007f0c54218000 nid=0x6ad7 waiting on condition [0x00007f0c6195c000]
- java.lang.Thread.State: TIMED_WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbb31788> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2082)
- at java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "sparkExecutor-1521" daemon prio=10 tid=0x00007f0ce0ce5800 nid=0x6ad6 waiting on condition [0x00007f0c5b5f4000]
- java.lang.Thread.State: TIMED_WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbb31788> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2082)
- at java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "spark-2868" daemon prio=10 tid=0x00007f0c5c54d800 nid=0x6ad2 waiting on condition [0x00007f0c5b8f7000]
- java.lang.Thread.State: TIMED_WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbed7478> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2082)
- at java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "spark-2867" daemon prio=10 tid=0x00007f0c5c675000 nid=0x6ad1 waiting on condition [0x00007f0c3184d000]
- java.lang.Thread.State: TIMED_WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbed7478> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2082)
- at java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "spark-2866" daemon prio=10 tid=0x00007f0c5c8f1000 nid=0x6ac6 waiting on condition [0x00007f0c5b9f8000]
- java.lang.Thread.State: TIMED_WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbed7478> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2082)
- at java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "spark-2865" daemon prio=10 tid=0x00007f0c5c676000 nid=0x6ac5 waiting on condition [0x00007f0c5a5dd000]
- java.lang.Thread.State: TIMED_WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbed7478> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2082)
- at java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "sparkExecutor-1520" daemon prio=10 tid=0x00007f0c5406d000 nid=0x6ac4 waiting on condition [0x00007f0c331a1000]
- java.lang.Thread.State: TIMED_WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbb31788> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2082)
- at java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "sparkExecutor-1519" daemon prio=10 tid=0x00007f0ce0aab800 nid=0x6ac3 waiting on condition [0x00007f0c33409000]
- java.lang.Thread.State: TIMED_WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbb31788> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2082)
- at java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "spark-2864" daemon prio=10 tid=0x00007f0c5c811800 nid=0x6abf waiting on condition [0x00007f0c44001000]
- java.lang.Thread.State: TIMED_WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbed7478> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2082)
- at java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "spark-2863" daemon prio=10 tid=0x00007f0c5c5d4000 nid=0x6abe waiting on condition [0x00007f0c4e7be000]
- java.lang.Thread.State: TIMED_WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbed7478> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2082)
- at java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "Attach Listener" daemon prio=10 tid=0x0000000001674800 nid=0x6ab2 waiting on condition [0x0000000000000000]
- java.lang.Thread.State: RUNNABLE
- "spark-akka.actor.default-dispatcher-1479" daemon prio=10 tid=0x0000000001daf000 nid=0x6892 waiting on condition [0x00007f0c5b4f3000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbd6f8e8> (a akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinPool)
- at akka.jsr166y.ForkJoinPool.scan(ForkJoinPool.java:1594)
- at akka.jsr166y.ForkJoinPool.runWorker(ForkJoinPool.java:1479)
- at akka.jsr166y.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:104)
- "pool-1-thread-20" prio=10 tid=0x00007f0c5425c000 nid=0x4c78 waiting on condition [0x00007f0c4ac98000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbf11ee0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
- at java.util.concurrent.LinkedBlockingDeque.takeFirst(LinkedBlockingDeque.java:489)
- at java.util.concurrent.LinkedBlockingDeque.take(LinkedBlockingDeque.java:678)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "pool-1-thread-19" prio=10 tid=0x00007f0c54087000 nid=0x4c77 waiting on condition [0x00007f0c4ad99000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbf11ee0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
- at java.util.concurrent.LinkedBlockingDeque.takeFirst(LinkedBlockingDeque.java:489)
- at java.util.concurrent.LinkedBlockingDeque.take(LinkedBlockingDeque.java:678)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "pool-1-thread-18" prio=10 tid=0x00007f0c54086000 nid=0x4c76 waiting on condition [0x00007f0c4c12a000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbf11ee0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
- at java.util.concurrent.LinkedBlockingDeque.takeFirst(LinkedBlockingDeque.java:489)
- at java.util.concurrent.LinkedBlockingDeque.take(LinkedBlockingDeque.java:678)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "pool-1-thread-17" prio=10 tid=0x00007f0c542ee000 nid=0x4c75 waiting on condition [0x00007f0c4c22b000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbf11ee0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
- at java.util.concurrent.LinkedBlockingDeque.takeFirst(LinkedBlockingDeque.java:489)
- at java.util.concurrent.LinkedBlockingDeque.take(LinkedBlockingDeque.java:678)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "pool-1-thread-16" prio=10 tid=0x00007f0c54580800 nid=0x4c74 waiting on condition [0x00007f0c4c32c000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbf11ee0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
- at java.util.concurrent.LinkedBlockingDeque.takeFirst(LinkedBlockingDeque.java:489)
- at java.util.concurrent.LinkedBlockingDeque.take(LinkedBlockingDeque.java:678)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "pool-1-thread-15" prio=10 tid=0x00007f0c5c616800 nid=0x4c73 waiting on condition [0x00007f0c4a15e000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbf11ee0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
- at java.util.concurrent.LinkedBlockingDeque.takeFirst(LinkedBlockingDeque.java:489)
- at java.util.concurrent.LinkedBlockingDeque.take(LinkedBlockingDeque.java:678)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "pool-1-thread-14" prio=10 tid=0x00007f0c5cad6000 nid=0x4c72 waiting on condition [0x00007f0c4a293000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbf11ee0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
- at java.util.concurrent.LinkedBlockingDeque.takeFirst(LinkedBlockingDeque.java:489)
- at java.util.concurrent.LinkedBlockingDeque.take(LinkedBlockingDeque.java:678)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "pool-1-thread-13" prio=10 tid=0x00007f0c5caea000 nid=0x4c71 waiting on condition [0x00007f0c4a3b8000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbf11ee0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
- at java.util.concurrent.LinkedBlockingDeque.takeFirst(LinkedBlockingDeque.java:489)
- at java.util.concurrent.LinkedBlockingDeque.take(LinkedBlockingDeque.java:678)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "pool-1-thread-12" prio=10 tid=0x0000000002009000 nid=0x4c70 waiting on condition [0x00007f0c4a4d0000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbf11ee0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
- at java.util.concurrent.LinkedBlockingDeque.takeFirst(LinkedBlockingDeque.java:489)
- at java.util.concurrent.LinkedBlockingDeque.take(LinkedBlockingDeque.java:678)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "pool-1-thread-11" prio=10 tid=0x0000000001761800 nid=0x4c6f waiting on condition [0x00007f0c4a5e3000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbf11ee0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
- at java.util.concurrent.LinkedBlockingDeque.takeFirst(LinkedBlockingDeque.java:489)
- at java.util.concurrent.LinkedBlockingDeque.take(LinkedBlockingDeque.java:678)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "pool-1-thread-10" prio=10 tid=0x0000000001fc2000 nid=0x4c6e waiting on condition [0x00007f0c58997000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbf11ee0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
- at java.util.concurrent.LinkedBlockingDeque.takeFirst(LinkedBlockingDeque.java:489)
- at java.util.concurrent.LinkedBlockingDeque.take(LinkedBlockingDeque.java:678)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "pool-3-thread-1" prio=10 tid=0x00007f0c5c8bb800 nid=0x4c6d waiting on condition [0x00007f0c5bbfa000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbf12590> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
- at java.util.concurrent.LinkedBlockingDeque.takeFirst(LinkedBlockingDeque.java:489)
- at java.util.concurrent.LinkedBlockingDeque.take(LinkedBlockingDeque.java:678)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "pool-1-thread-9" prio=10 tid=0x00000000020bf800 nid=0x4c68 waiting on condition [0x00007f0c53cfb000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbf11ee0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
- at java.util.concurrent.LinkedBlockingDeque.takeFirst(LinkedBlockingDeque.java:489)
- at java.util.concurrent.LinkedBlockingDeque.take(LinkedBlockingDeque.java:678)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "pool-1-thread-8" prio=10 tid=0x00007f0c5cd06000 nid=0x4c67 waiting on condition [0x00007f0c53dfc000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbf11ee0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
- at java.util.concurrent.LinkedBlockingDeque.takeFirst(LinkedBlockingDeque.java:489)
- at java.util.concurrent.LinkedBlockingDeque.take(LinkedBlockingDeque.java:678)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "pool-1-thread-7" prio=10 tid=0x00007f0c5cd04000 nid=0x4c66 waiting on condition [0x00007f0c53efd000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbf11ee0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
- at java.util.concurrent.LinkedBlockingDeque.takeFirst(LinkedBlockingDeque.java:489)
- at java.util.concurrent.LinkedBlockingDeque.take(LinkedBlockingDeque.java:678)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "pool-1-thread-6" prio=10 tid=0x0000000001fec800 nid=0x4c65 waiting on condition [0x00007f0c53ffe000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbf11ee0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
- at java.util.concurrent.LinkedBlockingDeque.takeFirst(LinkedBlockingDeque.java:489)
- at java.util.concurrent.LinkedBlockingDeque.take(LinkedBlockingDeque.java:678)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "pool-1-thread-5" prio=10 tid=0x0000000001feb800 nid=0x4c64 waiting on condition [0x00007f0c5818f000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbf11ee0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
- at java.util.concurrent.LinkedBlockingDeque.takeFirst(LinkedBlockingDeque.java:489)
- at java.util.concurrent.LinkedBlockingDeque.take(LinkedBlockingDeque.java:678)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "pool-1-thread-4" prio=10 tid=0x00007f0c5c3b9000 nid=0x4c63 waiting on condition [0x00007f0c58290000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbf11ee0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
- at java.util.concurrent.LinkedBlockingDeque.takeFirst(LinkedBlockingDeque.java:489)
- at java.util.concurrent.LinkedBlockingDeque.take(LinkedBlockingDeque.java:678)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "pool-1-thread-3" prio=10 tid=0x00007f0c5c3b8000 nid=0x4c62 waiting on condition [0x00007f0c58391000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbf11ee0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
- at java.util.concurrent.LinkedBlockingDeque.takeFirst(LinkedBlockingDeque.java:489)
- at java.util.concurrent.LinkedBlockingDeque.take(LinkedBlockingDeque.java:678)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "pool-1-thread-2" prio=10 tid=0x00007f0c5c3b7800 nid=0x4c61 waiting on condition [0x00007f0c58492000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbf11ee0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
- at java.util.concurrent.LinkedBlockingDeque.takeFirst(LinkedBlockingDeque.java:489)
- at java.util.concurrent.LinkedBlockingDeque.take(LinkedBlockingDeque.java:678)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "pool-1-thread-1" prio=10 tid=0x0000000001d11800 nid=0x4c60 waiting on condition [0x00007f0c60b4a000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbf11ee0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
- at java.util.concurrent.LinkedBlockingDeque.takeFirst(LinkedBlockingDeque.java:489)
- at java.util.concurrent.LinkedBlockingDeque.take(LinkedBlockingDeque.java:678)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "pool-2-thread-4" prio=10 tid=0x0000000002189000 nid=0x4c5f waiting on condition [0x00007f0c5baf9000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbf12238> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
- at java.util.concurrent.LinkedBlockingDeque.takeFirst(LinkedBlockingDeque.java:489)
- at java.util.concurrent.LinkedBlockingDeque.take(LinkedBlockingDeque.java:678)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "pool-2-thread-3" prio=10 tid=0x00000000018d6800 nid=0x4c5e waiting on condition [0x00007f0c58593000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbf12238> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
- at java.util.concurrent.LinkedBlockingDeque.takeFirst(LinkedBlockingDeque.java:489)
- at java.util.concurrent.LinkedBlockingDeque.take(LinkedBlockingDeque.java:678)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "pool-2-thread-2" prio=10 tid=0x0000000001f0c000 nid=0x4c5d waiting on condition [0x00007f0c6185b000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbf12238> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
- at java.util.concurrent.LinkedBlockingDeque.takeFirst(LinkedBlockingDeque.java:489)
- at java.util.concurrent.LinkedBlockingDeque.take(LinkedBlockingDeque.java:678)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "pool-2-thread-1" prio=10 tid=0x00000000019d4800 nid=0x4c5a waiting on condition [0x00007f0c58896000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbf12238> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
- at java.util.concurrent.LinkedBlockingDeque.takeFirst(LinkedBlockingDeque.java:489)
- at java.util.concurrent.LinkedBlockingDeque.take(LinkedBlockingDeque.java:678)
- at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "ResultTask cleanup timer" daemon prio=10 tid=0x00007f0c5c7e8000 nid=0x4c51 in Object.wait() [0x00007f0c58694000]
- java.lang.Thread.State: WAITING (on object monitor)
- at java.lang.Object.wait(Native Method)
- - waiting on <0x00007f0d184f7120> (a java.util.TaskQueue)
- at java.lang.Object.wait(Object.java:503)
- at java.util.TimerThread.mainLoop(Timer.java:526)
- - locked <0x00007f0d184f7120> (a java.util.TaskQueue)
- at java.util.TimerThread.run(Timer.java:505)
- "MultiThreadedHttpConnectionManager cleanup" daemon prio=10 tid=0x00007f0ce0900000 nid=0x4aaa in Object.wait() [0x00007f0c60a49000]
- java.lang.Thread.State: WAITING (on object monitor)
- at java.lang.Object.wait(Native Method)
- - waiting on <0x00007f0cfc1ee3f0> (a java.lang.ref.ReferenceQueue$Lock)
- at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:135)
- - locked <0x00007f0cfc1ee3f0> (a java.lang.ref.ReferenceQueue$Lock)
- at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:151)
- at org.apache.commons.httpclient.MultiThreadedHttpConnectionManager$ReferenceQueueThread.run(MultiThreadedHttpConnectionManager.java:1122)
- "ShuffleMapTask cleanup timer" daemon prio=10 tid=0x00007f0c5c37f000 nid=0x4aa9 in Object.wait() [0x00007f0c5a6de000]
- java.lang.Thread.State: WAITING (on object monitor)
- at java.lang.Object.wait(Native Method)
- - waiting on <0x00007f0cfc39df68> (a java.util.TaskQueue)
- at java.lang.Object.wait(Object.java:503)
- at java.util.TimerThread.mainLoop(Timer.java:526)
- - locked <0x00007f0cfc39df68> (a java.util.TaskQueue)
- at java.util.TimerThread.run(Timer.java:505)
- "Executor task launch worker-7" daemon prio=10 tid=0x00000000015a2800 nid=0x4a9b waiting on condition [0x00007f0c5aae8000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0fb0ff45f8> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
- at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
- at org.apache.spark.storage.BlockFetcherIterator$BasicBlockFetcherIterator.next(BlockFetcherIterator.scala:247)
- at org.apache.spark.storage.BlockFetcherIterator$BasicBlockFetcherIterator.next(BlockFetcherIterator.scala:71)
- at scala.collection.Iterator$$anon$21.hasNext(Iterator.scala:440)
- at org.apache.spark.util.CompletionIterator.hasNext(CompletionIterator.scala:26)
- at org.apache.spark.InterruptibleIterator.hasNext(InterruptibleIterator.scala:27)
- at org.apache.spark.Aggregator.combineValuesByKey(Aggregator.scala:40)
- at org.apache.spark.rdd.PairRDDFunctions$$anonfun$combineByKey$3.apply(PairRDDFunctions.scala:103)
- at org.apache.spark.rdd.PairRDDFunctions$$anonfun$combineByKey$3.apply(PairRDDFunctions.scala:102)
- at org.apache.spark.rdd.RDD$$anonfun$3.apply(RDD.scala:465)
- at org.apache.spark.rdd.RDD$$anonfun$3.apply(RDD.scala:465)
- at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:34)
- at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:237)
- at org.apache.spark.rdd.RDD.iterator(RDD.scala:226)
- at org.apache.spark.rdd.FlatMappedRDD.compute(FlatMappedRDD.scala:32)
- at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:237)
- at org.apache.spark.CacheManager.getOrCompute(CacheManager.scala:71)
- at org.apache.spark.rdd.RDD.iterator(RDD.scala:224)
- at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:107)
- at org.apache.spark.scheduler.Task.run(Task.scala:53)
- at org.apache.spark.executor.Executor$TaskRunner$$anonfun$run$1.apply$mcV$sp(Executor.scala:215)
- at org.apache.spark.deploy.SparkHadoopUtil$$anon$1.run(SparkHadoopUtil.scala:47)
- at org.apache.spark.deploy.SparkHadoopUtil$$anon$1.run(SparkHadoopUtil.scala:46)
- at java.security.AccessController.doPrivileged(Native Method)
- at javax.security.auth.Subject.doAs(Subject.java:415)
- at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1121)
- at org.apache.spark.deploy.SparkHadoopUtil.runAsUser(SparkHadoopUtil.scala:46)
- at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:182)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "Executor task launch worker-6" daemon prio=10 tid=0x00000000015a0000 nid=0x4a9a waiting on condition [0x00007f0c5abe9000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0faa72f510> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
- at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
- at org.apache.spark.storage.BlockFetcherIterator$BasicBlockFetcherIterator.next(BlockFetcherIterator.scala:247)
- at org.apache.spark.storage.BlockFetcherIterator$BasicBlockFetcherIterator.next(BlockFetcherIterator.scala:71)
- at scala.collection.Iterator$$anon$21.hasNext(Iterator.scala:440)
- at org.apache.spark.util.CompletionIterator.hasNext(CompletionIterator.scala:26)
- at org.apache.spark.InterruptibleIterator.hasNext(InterruptibleIterator.scala:27)
- at org.apache.spark.Aggregator.combineValuesByKey(Aggregator.scala:40)
- at org.apache.spark.rdd.PairRDDFunctions$$anonfun$combineByKey$3.apply(PairRDDFunctions.scala:103)
- at org.apache.spark.rdd.PairRDDFunctions$$anonfun$combineByKey$3.apply(PairRDDFunctions.scala:102)
- at org.apache.spark.rdd.RDD$$anonfun$3.apply(RDD.scala:465)
- at org.apache.spark.rdd.RDD$$anonfun$3.apply(RDD.scala:465)
- at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:34)
- at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:237)
- at org.apache.spark.rdd.RDD.iterator(RDD.scala:226)
- at org.apache.spark.rdd.FlatMappedRDD.compute(FlatMappedRDD.scala:32)
- at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:237)
- at org.apache.spark.CacheManager.getOrCompute(CacheManager.scala:71)
- at org.apache.spark.rdd.RDD.iterator(RDD.scala:224)
- at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:107)
- at org.apache.spark.scheduler.Task.run(Task.scala:53)
- at org.apache.spark.executor.Executor$TaskRunner$$anonfun$run$1.apply$mcV$sp(Executor.scala:215)
- at org.apache.spark.deploy.SparkHadoopUtil$$anon$1.run(SparkHadoopUtil.scala:47)
- at org.apache.spark.deploy.SparkHadoopUtil$$anon$1.run(SparkHadoopUtil.scala:46)
- at java.security.AccessController.doPrivileged(Native Method)
- at javax.security.auth.Subject.doAs(Subject.java:415)
- at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1121)
- at org.apache.spark.deploy.SparkHadoopUtil.runAsUser(SparkHadoopUtil.scala:46)
- at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:182)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "Executor task launch worker-5" daemon prio=10 tid=0x00000000016f2800 nid=0x4a99 waiting on condition [0x00007f0c60745000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0fad74f0f0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
- at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
- at org.apache.spark.storage.BlockFetcherIterator$BasicBlockFetcherIterator.next(BlockFetcherIterator.scala:247)
- at org.apache.spark.storage.BlockFetcherIterator$BasicBlockFetcherIterator.next(BlockFetcherIterator.scala:71)
- at scala.collection.Iterator$$anon$21.hasNext(Iterator.scala:440)
- at org.apache.spark.util.CompletionIterator.hasNext(CompletionIterator.scala:26)
- at org.apache.spark.InterruptibleIterator.hasNext(InterruptibleIterator.scala:27)
- at org.apache.spark.Aggregator.combineValuesByKey(Aggregator.scala:40)
- at org.apache.spark.rdd.PairRDDFunctions$$anonfun$combineByKey$3.apply(PairRDDFunctions.scala:103)
- at org.apache.spark.rdd.PairRDDFunctions$$anonfun$combineByKey$3.apply(PairRDDFunctions.scala:102)
- at org.apache.spark.rdd.RDD$$anonfun$3.apply(RDD.scala:465)
- at org.apache.spark.rdd.RDD$$anonfun$3.apply(RDD.scala:465)
- at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:34)
- at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:237)
- at org.apache.spark.rdd.RDD.iterator(RDD.scala:226)
- at org.apache.spark.rdd.FlatMappedRDD.compute(FlatMappedRDD.scala:32)
- at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:237)
- at org.apache.spark.CacheManager.getOrCompute(CacheManager.scala:71)
- at org.apache.spark.rdd.RDD.iterator(RDD.scala:224)
- at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:107)
- at org.apache.spark.scheduler.Task.run(Task.scala:53)
- at org.apache.spark.executor.Executor$TaskRunner$$anonfun$run$1.apply$mcV$sp(Executor.scala:215)
- at org.apache.spark.deploy.SparkHadoopUtil$$anon$1.run(SparkHadoopUtil.scala:47)
- at org.apache.spark.deploy.SparkHadoopUtil$$anon$1.run(SparkHadoopUtil.scala:46)
- at java.security.AccessController.doPrivileged(Native Method)
- at javax.security.auth.Subject.doAs(Subject.java:415)
- at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1121)
- at org.apache.spark.deploy.SparkHadoopUtil.runAsUser(SparkHadoopUtil.scala:46)
- at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:182)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "Executor task launch worker-4" daemon prio=10 tid=0x00000000016f1000 nid=0x4a98 waiting on condition [0x00007f0c6114f000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0fad1ebc28> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
- at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
- at org.apache.spark.storage.BlockFetcherIterator$BasicBlockFetcherIterator.next(BlockFetcherIterator.scala:247)
- at org.apache.spark.storage.BlockFetcherIterator$BasicBlockFetcherIterator.next(BlockFetcherIterator.scala:71)
- at scala.collection.Iterator$$anon$21.hasNext(Iterator.scala:440)
- at org.apache.spark.util.CompletionIterator.hasNext(CompletionIterator.scala:26)
- at org.apache.spark.InterruptibleIterator.hasNext(InterruptibleIterator.scala:27)
- at org.apache.spark.Aggregator.combineValuesByKey(Aggregator.scala:40)
- at org.apache.spark.rdd.PairRDDFunctions$$anonfun$combineByKey$3.apply(PairRDDFunctions.scala:103)
- at org.apache.spark.rdd.PairRDDFunctions$$anonfun$combineByKey$3.apply(PairRDDFunctions.scala:102)
- at org.apache.spark.rdd.RDD$$anonfun$3.apply(RDD.scala:465)
- at org.apache.spark.rdd.RDD$$anonfun$3.apply(RDD.scala:465)
- at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:34)
- at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:237)
- at org.apache.spark.rdd.RDD.iterator(RDD.scala:226)
- at org.apache.spark.rdd.FlatMappedRDD.compute(FlatMappedRDD.scala:32)
- at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:237)
- at org.apache.spark.CacheManager.getOrCompute(CacheManager.scala:71)
- at org.apache.spark.rdd.RDD.iterator(RDD.scala:224)
- at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:107)
- at org.apache.spark.scheduler.Task.run(Task.scala:53)
- at org.apache.spark.executor.Executor$TaskRunner$$anonfun$run$1.apply$mcV$sp(Executor.scala:215)
- at org.apache.spark.deploy.SparkHadoopUtil$$anon$1.run(SparkHadoopUtil.scala:47)
- at org.apache.spark.deploy.SparkHadoopUtil$$anon$1.run(SparkHadoopUtil.scala:46)
- at java.security.AccessController.doPrivileged(Native Method)
- at javax.security.auth.Subject.doAs(Subject.java:415)
- at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1121)
- at org.apache.spark.deploy.SparkHadoopUtil.runAsUser(SparkHadoopUtil.scala:46)
- at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:182)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "Executor task launch worker-3" daemon prio=10 tid=0x00000000016ef800 nid=0x4a97 waiting on condition [0x00007f0c60d4b000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0fac577d80> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
- at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
- at org.apache.spark.storage.BlockFetcherIterator$BasicBlockFetcherIterator.next(BlockFetcherIterator.scala:247)
- at org.apache.spark.storage.BlockFetcherIterator$BasicBlockFetcherIterator.next(BlockFetcherIterator.scala:71)
- at scala.collection.Iterator$$anon$21.hasNext(Iterator.scala:440)
- at org.apache.spark.util.CompletionIterator.hasNext(CompletionIterator.scala:26)
- at org.apache.spark.InterruptibleIterator.hasNext(InterruptibleIterator.scala:27)
- at org.apache.spark.Aggregator.combineValuesByKey(Aggregator.scala:40)
- at org.apache.spark.rdd.PairRDDFunctions$$anonfun$combineByKey$3.apply(PairRDDFunctions.scala:103)
- at org.apache.spark.rdd.PairRDDFunctions$$anonfun$combineByKey$3.apply(PairRDDFunctions.scala:102)
- at org.apache.spark.rdd.RDD$$anonfun$3.apply(RDD.scala:465)
- at org.apache.spark.rdd.RDD$$anonfun$3.apply(RDD.scala:465)
- at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:34)
- at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:237)
- at org.apache.spark.rdd.RDD.iterator(RDD.scala:226)
- at org.apache.spark.rdd.FlatMappedRDD.compute(FlatMappedRDD.scala:32)
- at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:237)
- at org.apache.spark.CacheManager.getOrCompute(CacheManager.scala:71)
- at org.apache.spark.rdd.RDD.iterator(RDD.scala:224)
- at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:107)
- at org.apache.spark.scheduler.Task.run(Task.scala:53)
- at org.apache.spark.executor.Executor$TaskRunner$$anonfun$run$1.apply$mcV$sp(Executor.scala:215)
- at org.apache.spark.deploy.SparkHadoopUtil$$anon$1.run(SparkHadoopUtil.scala:47)
- at org.apache.spark.deploy.SparkHadoopUtil$$anon$1.run(SparkHadoopUtil.scala:46)
- at java.security.AccessController.doPrivileged(Native Method)
- at javax.security.auth.Subject.doAs(Subject.java:415)
- at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1121)
- at org.apache.spark.deploy.SparkHadoopUtil.runAsUser(SparkHadoopUtil.scala:46)
- at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:182)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "Executor task launch worker-2" daemon prio=10 tid=0x00000000016ee800 nid=0x4a96 waiting on condition [0x00007f0c60e4c000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0fae130758> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
- at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
- at org.apache.spark.storage.BlockFetcherIterator$BasicBlockFetcherIterator.next(BlockFetcherIterator.scala:247)
- at org.apache.spark.storage.BlockFetcherIterator$BasicBlockFetcherIterator.next(BlockFetcherIterator.scala:71)
- at scala.collection.Iterator$$anon$21.hasNext(Iterator.scala:440)
- at org.apache.spark.util.CompletionIterator.hasNext(CompletionIterator.scala:26)
- at org.apache.spark.InterruptibleIterator.hasNext(InterruptibleIterator.scala:27)
- at org.apache.spark.Aggregator.combineValuesByKey(Aggregator.scala:40)
- at org.apache.spark.rdd.PairRDDFunctions$$anonfun$combineByKey$3.apply(PairRDDFunctions.scala:103)
- at org.apache.spark.rdd.PairRDDFunctions$$anonfun$combineByKey$3.apply(PairRDDFunctions.scala:102)
- at org.apache.spark.rdd.RDD$$anonfun$3.apply(RDD.scala:465)
- at org.apache.spark.rdd.RDD$$anonfun$3.apply(RDD.scala:465)
- at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:34)
- at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:237)
- at org.apache.spark.rdd.RDD.iterator(RDD.scala:226)
- at org.apache.spark.rdd.FlatMappedRDD.compute(FlatMappedRDD.scala:32)
- at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:237)
- at org.apache.spark.CacheManager.getOrCompute(CacheManager.scala:71)
- at org.apache.spark.rdd.RDD.iterator(RDD.scala:224)
- at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:107)
- at org.apache.spark.scheduler.Task.run(Task.scala:53)
- at org.apache.spark.executor.Executor$TaskRunner$$anonfun$run$1.apply$mcV$sp(Executor.scala:215)
- at org.apache.spark.deploy.SparkHadoopUtil$$anon$1.run(SparkHadoopUtil.scala:47)
- at org.apache.spark.deploy.SparkHadoopUtil$$anon$1.run(SparkHadoopUtil.scala:46)
- at java.security.AccessController.doPrivileged(Native Method)
- at javax.security.auth.Subject.doAs(Subject.java:415)
- at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1121)
- at org.apache.spark.deploy.SparkHadoopUtil.runAsUser(SparkHadoopUtil.scala:46)
- at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:182)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "Executor task launch worker-1" daemon prio=10 tid=0x00000000016ed800 nid=0x4a95 waiting on condition [0x00007f0c6104e000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0fb327ace8> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
- at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
- at org.apache.spark.storage.BlockFetcherIterator$BasicBlockFetcherIterator.next(BlockFetcherIterator.scala:247)
- at org.apache.spark.storage.BlockFetcherIterator$BasicBlockFetcherIterator.next(BlockFetcherIterator.scala:71)
- at scala.collection.Iterator$$anon$21.hasNext(Iterator.scala:440)
- at org.apache.spark.util.CompletionIterator.hasNext(CompletionIterator.scala:26)
- at org.apache.spark.InterruptibleIterator.hasNext(InterruptibleIterator.scala:27)
- at org.apache.spark.Aggregator.combineValuesByKey(Aggregator.scala:40)
- at org.apache.spark.rdd.PairRDDFunctions$$anonfun$combineByKey$3.apply(PairRDDFunctions.scala:103)
- at org.apache.spark.rdd.PairRDDFunctions$$anonfun$combineByKey$3.apply(PairRDDFunctions.scala:102)
- at org.apache.spark.rdd.RDD$$anonfun$3.apply(RDD.scala:465)
- at org.apache.spark.rdd.RDD$$anonfun$3.apply(RDD.scala:465)
- at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:34)
- at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:237)
- at org.apache.spark.rdd.RDD.iterator(RDD.scala:226)
- at org.apache.spark.rdd.FlatMappedRDD.compute(FlatMappedRDD.scala:32)
- at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:237)
- at org.apache.spark.CacheManager.getOrCompute(CacheManager.scala:71)
- at org.apache.spark.rdd.RDD.iterator(RDD.scala:224)
- at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:107)
- at org.apache.spark.scheduler.Task.run(Task.scala:53)
- at org.apache.spark.executor.Executor$TaskRunner$$anonfun$run$1.apply$mcV$sp(Executor.scala:215)
- at org.apache.spark.deploy.SparkHadoopUtil$$anon$1.run(SparkHadoopUtil.scala:47)
- at org.apache.spark.deploy.SparkHadoopUtil$$anon$1.run(SparkHadoopUtil.scala:46)
- at java.security.AccessController.doPrivileged(Native Method)
- at javax.security.auth.Subject.doAs(Subject.java:415)
- at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1121)
- at org.apache.spark.deploy.SparkHadoopUtil.runAsUser(SparkHadoopUtil.scala:46)
- at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:182)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "Executor task launch worker-0" daemon prio=10 tid=0x0000000001951800 nid=0x4a94 waiting on condition [0x00007f0c60c4a000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0faead0b90> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
- at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
- at org.apache.spark.storage.BlockFetcherIterator$BasicBlockFetcherIterator.next(BlockFetcherIterator.scala:247)
- at org.apache.spark.storage.BlockFetcherIterator$BasicBlockFetcherIterator.next(BlockFetcherIterator.scala:71)
- at scala.collection.Iterator$$anon$21.hasNext(Iterator.scala:440)
- at org.apache.spark.util.CompletionIterator.hasNext(CompletionIterator.scala:26)
- at org.apache.spark.InterruptibleIterator.hasNext(InterruptibleIterator.scala:27)
- at org.apache.spark.Aggregator.combineValuesByKey(Aggregator.scala:40)
- at org.apache.spark.rdd.PairRDDFunctions$$anonfun$combineByKey$3.apply(PairRDDFunctions.scala:103)
- at org.apache.spark.rdd.PairRDDFunctions$$anonfun$combineByKey$3.apply(PairRDDFunctions.scala:102)
- at org.apache.spark.rdd.RDD$$anonfun$3.apply(RDD.scala:465)
- at org.apache.spark.rdd.RDD$$anonfun$3.apply(RDD.scala:465)
- at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:34)
- at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:237)
- at org.apache.spark.rdd.RDD.iterator(RDD.scala:226)
- at org.apache.spark.rdd.FlatMappedRDD.compute(FlatMappedRDD.scala:32)
- at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:237)
- at org.apache.spark.CacheManager.getOrCompute(CacheManager.scala:71)
- at org.apache.spark.rdd.RDD.iterator(RDD.scala:224)
- at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:107)
- at org.apache.spark.scheduler.Task.run(Task.scala:53)
- at org.apache.spark.executor.Executor$TaskRunner$$anonfun$run$1.apply$mcV$sp(Executor.scala:215)
- at org.apache.spark.deploy.SparkHadoopUtil$$anon$1.run(SparkHadoopUtil.scala:47)
- at org.apache.spark.deploy.SparkHadoopUtil$$anon$1.run(SparkHadoopUtil.scala:46)
- at java.security.AccessController.doPrivileged(Native Method)
- at javax.security.auth.Subject.doAs(Subject.java:415)
- at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1121)
- at org.apache.spark.deploy.SparkHadoopUtil.runAsUser(SparkHadoopUtil.scala:46)
- at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:182)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "qtp758550709-53" daemon prio=10 tid=0x00007f0ce012e800 nid=0x4a79 waiting on condition [0x00007f0c5aceb000]
- java.lang.Thread.State: TIMED_WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbf13f20> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2082)
- at org.eclipse.jetty.util.BlockingArrayQueue.poll(BlockingArrayQueue.java:342)
- at org.eclipse.jetty.util.thread.QueuedThreadPool.idleJobPoll(QueuedThreadPool.java:526)
- at org.eclipse.jetty.util.thread.QueuedThreadPool.access$600(QueuedThreadPool.java:44)
- at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:572)
- at java.lang.Thread.run(Thread.java:724)
- "qtp758550709-52" daemon prio=10 tid=0x00007f0ce012c800 nid=0x4a78 waiting on condition [0x00007f0c5adec000]
- java.lang.Thread.State: TIMED_WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbf13f20> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2082)
- at org.eclipse.jetty.util.BlockingArrayQueue.poll(BlockingArrayQueue.java:342)
- at org.eclipse.jetty.util.thread.QueuedThreadPool.idleJobPoll(QueuedThreadPool.java:526)
- at org.eclipse.jetty.util.thread.QueuedThreadPool.access$600(QueuedThreadPool.java:44)
- at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:572)
- at java.lang.Thread.run(Thread.java:724)
- "qtp758550709-51" daemon prio=10 tid=0x00007f0ce0473000 nid=0x4a77 waiting on condition [0x00007f0c5aeed000]
- java.lang.Thread.State: TIMED_WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbf13f20> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2082)
- at org.eclipse.jetty.util.BlockingArrayQueue.poll(BlockingArrayQueue.java:342)
- at org.eclipse.jetty.util.thread.QueuedThreadPool.idleJobPoll(QueuedThreadPool.java:526)
- at org.eclipse.jetty.util.thread.QueuedThreadPool.access$600(QueuedThreadPool.java:44)
- at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:572)
- at java.lang.Thread.run(Thread.java:724)
- "qtp758550709-50" daemon prio=10 tid=0x00007f0ce0471000 nid=0x4a76 waiting on condition [0x00007f0c5afee000]
- java.lang.Thread.State: TIMED_WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbf13f20> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2082)
- at org.eclipse.jetty.util.BlockingArrayQueue.poll(BlockingArrayQueue.java:342)
- at org.eclipse.jetty.util.thread.QueuedThreadPool.idleJobPoll(QueuedThreadPool.java:526)
- at org.eclipse.jetty.util.thread.QueuedThreadPool.access$600(QueuedThreadPool.java:44)
- at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:572)
- at java.lang.Thread.run(Thread.java:724)
- "qtp758550709-49" daemon prio=10 tid=0x00007f0ce046e000 nid=0x4a75 waiting on condition [0x00007f0c5b0ef000]
- java.lang.Thread.State: TIMED_WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbf13f20> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2082)
- at org.eclipse.jetty.util.BlockingArrayQueue.poll(BlockingArrayQueue.java:342)
- at org.eclipse.jetty.util.thread.QueuedThreadPool.idleJobPoll(QueuedThreadPool.java:526)
- at org.eclipse.jetty.util.thread.QueuedThreadPool.access$600(QueuedThreadPool.java:44)
- at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:572)
- at java.lang.Thread.run(Thread.java:724)
- "qtp758550709-48" daemon prio=10 tid=0x00007f0ce046c800 nid=0x4a74 waiting on condition [0x00007f0c5b1f0000]
- java.lang.Thread.State: TIMED_WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbf13f20> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2082)
- at org.eclipse.jetty.util.BlockingArrayQueue.poll(BlockingArrayQueue.java:342)
- at org.eclipse.jetty.util.thread.QueuedThreadPool.idleJobPoll(QueuedThreadPool.java:526)
- at org.eclipse.jetty.util.thread.QueuedThreadPool.access$600(QueuedThreadPool.java:44)
- at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:572)
- at java.lang.Thread.run(Thread.java:724)
- "qtp758550709-47" daemon prio=10 tid=0x00007f0ce0065000 nid=0x4a73 waiting on condition [0x00007f0c5b2f1000]
- java.lang.Thread.State: TIMED_WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfbf13f20> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
- at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2082)
- at org.eclipse.jetty.util.BlockingArrayQueue.poll(BlockingArrayQueue.java:342)
- at org.eclipse.jetty.util.thread.QueuedThreadPool.idleJobPoll(QueuedThreadPool.java:526)
- at org.eclipse.jetty.util.thread.QueuedThreadPool.access$600(QueuedThreadPool.java:44)
- at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:572)
- at java.lang.Thread.run(Thread.java:724)
- "qtp758550709-46 Acceptor0 [email protected]:56470" daemon prio=10 tid=0x00007f0ce0476000 nid=0x4a72 runnable [0x00007f0c5b3f2000]
- java.lang.Thread.State: RUNNABLE
- at java.net.PlainSocketImpl.socketAccept(Native Method)
- at java.net.AbstractPlainSocketImpl.accept(AbstractPlainSocketImpl.java:398)
- at java.net.ServerSocket.implAccept(ServerSocket.java:530)
- at java.net.ServerSocket.accept(ServerSocket.java:498)
- at org.eclipse.jetty.server.bio.SocketConnector.accept(SocketConnector.java:117)
- at org.eclipse.jetty.server.AbstractConnector$Acceptor.run(AbstractConnector.java:938)
- at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:608)
- at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:543)
- at java.lang.Thread.run(Thread.java:724)
- "MapOutputTracker cleanup timer" daemon prio=10 tid=0x00007f0ce06f7000 nid=0x4a6f in Object.wait() [0x00007f0c5b6f5000]
- java.lang.Thread.State: WAITING (on object monitor)
- at java.lang.Object.wait(Native Method)
- - waiting on <0x00007f0cfbf0c910> (a java.util.TaskQueue)
- at java.lang.Object.wait(Object.java:503)
- at java.util.TimerThread.mainLoop(Timer.java:526)
- - locked <0x00007f0cfbf0c910> (a java.util.TaskQueue)
- at java.util.TimerThread.run(Timer.java:505)
- "HttpBroadcast cleanup timer" daemon prio=10 tid=0x00007f0ce071c800 nid=0x4a6e in Object.wait() [0x00007f0c5b7f6000]
- java.lang.Thread.State: WAITING (on object monitor)
- at java.lang.Object.wait(Native Method)
- - waiting on <0x00007f0cfc39e1f8> (a java.util.TaskQueue)
- at java.lang.Object.wait(Object.java:503)
- at java.util.TimerThread.mainLoop(Timer.java:526)
- - locked <0x00007f0cfc39e1f8> (a java.util.TaskQueue)
- at java.util.TimerThread.run(Timer.java:505)
- "New I/O worker #33" daemon prio=10 tid=0x000000000188d000 nid=0x4a69 runnable [0x00007f0c5bcfb000]
- java.lang.Thread.State: RUNNABLE
- at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
- at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:228)
- at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:81)
- at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:87)
- - locked <0x00007f0cfbecd7c8> (a sun.nio.ch.Util$2)
- - locked <0x00007f0cfbecd7b0> (a java.util.Collections$UnmodifiableSet)
- - locked <0x00007f0cfbecd110> (a sun.nio.ch.EPollSelectorImpl)
- at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:98)
- at org.jboss.netty.channel.socket.nio.SelectorUtil.select(SelectorUtil.java:52)
- at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:223)
- at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:35)
- at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:102)
- at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "Hashed wheel timer #2" daemon prio=10 tid=0x00007f0ce0712000 nid=0x4a66 waiting on condition [0x00007f0c5bffe000]
- java.lang.Thread.State: TIMED_WAITING (sleeping)
- at java.lang.Thread.sleep(Native Method)
- at org.jboss.netty.util.HashedWheelTimer$Worker.waitForNextTick(HashedWheelTimer.java:464)
- at org.jboss.netty.util.HashedWheelTimer$Worker.run(HashedWheelTimer.java:373)
- at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:102)
- at java.lang.Thread.run(Thread.java:724)
- "BroadcastVars cleanup timer" daemon prio=10 tid=0x00007f0ce0711000 nid=0x4a65 in Object.wait() [0x00007f0c60140000]
- java.lang.Thread.State: WAITING (on object monitor)
- at java.lang.Object.wait(Native Method)
- - waiting on <0x00007f0cfc39e8a0> (a java.util.TaskQueue)
- at java.lang.Object.wait(Object.java:503)
- at java.util.TimerThread.mainLoop(Timer.java:526)
- - locked <0x00007f0cfc39e8a0> (a java.util.TaskQueue)
- at java.util.TimerThread.run(Timer.java:505)
- "BlockManager cleanup timer" daemon prio=10 tid=0x00007f0ce0704000 nid=0x4a64 in Object.wait() [0x00007f0c60241000]
- java.lang.Thread.State: WAITING (on object monitor)
- at java.lang.Object.wait(Native Method)
- - waiting on <0x00007f0cfc39ef48> (a java.util.TaskQueue)
- at java.lang.Object.wait(Object.java:503)
- at java.util.TimerThread.mainLoop(Timer.java:526)
- - locked <0x00007f0cfc39ef48> (a java.util.TaskQueue)
- at java.util.TimerThread.run(Timer.java:505)
- "connection-manager-thread" daemon prio=10 tid=0x00007f0ce0723000 nid=0x4a63 runnable [0x00007f0c60342000]
- java.lang.Thread.State: RUNNABLE
- at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
- at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:228)
- at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:81)
- at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:87)
- - locked <0x00007f0cfbf11b10> (a sun.nio.ch.Util$2)
- - locked <0x00007f0cfbf11af8> (a java.util.Collections$UnmodifiableSet)
- - locked <0x00007f0cfbf0d1f0> (a sun.nio.ch.EPollSelectorImpl)
- at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:98)
- at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:102)
- at org.apache.spark.network.ConnectionManager.run(ConnectionManager.scala:283)
- at org.apache.spark.network.ConnectionManager$$anon$3.run(ConnectionManager.scala:98)
- "DiskBlockManager cleanup timer" daemon prio=10 tid=0x00007f0ce0709000 nid=0x4a61 in Object.wait() [0x00007f0c60443000]
- java.lang.Thread.State: WAITING (on object monitor)
- at java.lang.Object.wait(Native Method)
- - waiting on <0x00007f0cfc39f5f8> (a java.util.TaskQueue)
- at java.lang.Object.wait(Object.java:503)
- at java.util.TimerThread.mainLoop(Timer.java:526)
- - locked <0x00007f0cfc39f5f8> (a java.util.TaskQueue)
- at java.util.TimerThread.run(Timer.java:505)
- "New I/O server boss #2 ([id: 0x319117be, /10.45.168.151:36351])" daemon prio=10 tid=0x00007f0ce04a8000 nid=0x4a60 runnable [0x00007f0c60544000]
- java.lang.Thread.State: RUNNABLE
- at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
- at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:228)
- at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:81)
- at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:87)
- - locked <0x00007f0cfbefa460> (a sun.nio.ch.Util$2)
- - locked <0x00007f0cfbefa448> (a java.util.Collections$UnmodifiableSet)
- - locked <0x00007f0cfbef9d70> (a sun.nio.ch.EPollSelectorImpl)
- at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:98)
- at org.jboss.netty.channel.socket.nio.NioServerSocketPipelineSink$Boss.run(NioServerSocketPipelineSink.java:229)
- at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:102)
- at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "spark-scheduler-5" daemon prio=10 tid=0x00007f0ce04a5800 nid=0x4a5f waiting on condition [0x00007f0c60645000]
- java.lang.Thread.State: TIMED_WAITING (sleeping)
- at java.lang.Thread.sleep(Native Method)
- at org.jboss.netty.akka.util.HashedWheelTimer$Worker.waitForNextTick(HashedWheelTimer.java:418)
- at org.jboss.netty.akka.util.HashedWheelTimer$Worker.run(HashedWheelTimer.java:318)
- at java.lang.Thread.run(Thread.java:724)
- "New I/O worker #1" daemon prio=10 tid=0x000000000193b000 nid=0x4a56 runnable [0x00007f0c60f4e000]
- java.lang.Thread.State: RUNNABLE
- at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
- at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:228)
- at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:81)
- at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:87)
- - locked <0x00007f0cfbc00d68> (a sun.nio.ch.Util$2)
- - locked <0x00007f0cfbc00d50> (a java.util.Collections$UnmodifiableSet)
- - locked <0x00007f0cfbc005f0> (a sun.nio.ch.EPollSelectorImpl)
- at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:98)
- at org.jboss.netty.channel.socket.nio.SelectorUtil.select(SelectorUtil.java:52)
- at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:223)
- at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:35)
- at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:102)
- at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "Hashed wheel timer #1" daemon prio=10 tid=0x00007f0c5c2b9800 nid=0x4a53 waiting on condition [0x00007f0c61251000]
- java.lang.Thread.State: TIMED_WAITING (sleeping)
- at java.lang.Thread.sleep(Native Method)
- at org.jboss.netty.util.HashedWheelTimer$Worker.waitForNextTick(HashedWheelTimer.java:464)
- at org.jboss.netty.util.HashedWheelTimer$Worker.run(HashedWheelTimer.java:373)
- at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:102)
- at java.lang.Thread.run(Thread.java:724)
- "New I/O server boss #1 ([id: 0x0afdd280, /10.45.168.151:40445])" daemon prio=10 tid=0x00007f0c5c290800 nid=0x4a52 runnable [0x00007f0c61352000]
- java.lang.Thread.State: RUNNABLE
- at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
- at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:228)
- at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:81)
- at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:87)
- - locked <0x00007f0cfbc9a3a8> (a sun.nio.ch.Util$2)
- - locked <0x00007f0cfbc9a390> (a java.util.Collections$UnmodifiableSet)
- - locked <0x00007f0cfbc99cb8> (a sun.nio.ch.EPollSelectorImpl)
- at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:98)
- at org.jboss.netty.channel.socket.nio.NioServerSocketPipelineSink$Boss.run(NioServerSocketPipelineSink.java:229)
- at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:102)
- at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
- at java.lang.Thread.run(Thread.java:724)
- "sparkExecutor-scheduler-2" daemon prio=10 tid=0x00007f0c5c004000 nid=0x4a51 waiting on condition [0x00007f0c61659000]
- java.lang.Thread.State: TIMED_WAITING (sleeping)
- at java.lang.Thread.sleep(Native Method)
- at org.jboss.netty.akka.util.HashedWheelTimer$Worker.waitForNextTick(HashedWheelTimer.java:418)
- at org.jboss.netty.akka.util.HashedWheelTimer$Worker.run(HashedWheelTimer.java:318)
- at java.lang.Thread.run(Thread.java:724)
- "sparkExecutor-akka.actor.default-dispatcher-5" daemon prio=10 tid=0x00007f0ce03e4800 nid=0x4a50 waiting on condition [0x00007f0c6175a000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfc282dd0> (a akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinPool)
- at akka.jsr166y.ForkJoinPool.scan(ForkJoinPool.java:1594)
- at akka.jsr166y.ForkJoinPool.runWorker(ForkJoinPool.java:1479)
- at akka.jsr166y.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:104)
- "Service Thread" daemon prio=10 tid=0x00007f0ce0060800 nid=0x4a4c runnable [0x0000000000000000]
- java.lang.Thread.State: RUNNABLE
- "C2 CompilerThread1" daemon prio=10 tid=0x00007f0ce005e000 nid=0x4a4b waiting on condition [0x0000000000000000]
- java.lang.Thread.State: RUNNABLE
- "C2 CompilerThread0" daemon prio=10 tid=0x00007f0ce005b000 nid=0x4a4a waiting on condition [0x0000000000000000]
- java.lang.Thread.State: RUNNABLE
- "Signal Dispatcher" daemon prio=10 tid=0x00007f0ce0058800 nid=0x4a49 runnable [0x0000000000000000]
- java.lang.Thread.State: RUNNABLE
- "Finalizer" daemon prio=10 tid=0x00007f0ce0001000 nid=0x4a48 in Object.wait() [0x00007f0ce459a000]
- java.lang.Thread.State: WAITING (on object monitor)
- at java.lang.Object.wait(Native Method)
- - waiting on <0x00007f0cfb886868> (a java.lang.ref.ReferenceQueue$Lock)
- at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:135)
- - locked <0x00007f0cfb886868> (a java.lang.ref.ReferenceQueue$Lock)
- at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:151)
- at java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:189)
- "Reference Handler" daemon prio=10 tid=0x0000000001596000 nid=0x4a47 in Object.wait() [0x00007f0ce469b000]
- java.lang.Thread.State: WAITING (on object monitor)
- at java.lang.Object.wait(Native Method)
- - waiting on <0x00007f0cfd06b2b0> (a java.lang.ref.Reference$Lock)
- at java.lang.Object.wait(Object.java:503)
- at java.lang.ref.Reference$ReferenceHandler.run(Reference.java:133)
- - locked <0x00007f0cfd06b2b0> (a java.lang.ref.Reference$Lock)
- "main" prio=10 tid=0x00000000014e6800 nid=0x4a3d waiting on condition [0x00007f1941ac3000]
- java.lang.Thread.State: WAITING (parking)
- at sun.misc.Unsafe.park(Native Method)
- - parking to wait for <0x00007f0cfc286080> (a java.util.concurrent.CountDownLatch$Sync)
- at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:834)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedInterruptibly(AbstractQueuedSynchronizer.java:994)
- at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1303)
- at java.util.concurrent.CountDownLatch.await(CountDownLatch.java:236)
- at akka.actor.ActorSystemImpl$TerminationCallbacks.ready(ActorSystem.scala:736)
- at akka.actor.ActorSystemImpl$TerminationCallbacks.ready(ActorSystem.scala:705)
- at akka.dispatch.Await$.ready(Future.scala:64)
- at akka.actor.ActorSystemImpl.awaitTermination(ActorSystem.scala:604)
- at akka.actor.ActorSystemImpl.awaitTermination(ActorSystem.scala:605)
- at org.apache.spark.executor.CoarseGrainedExecutorBackend$.run(CoarseGrainedExecutorBackend.scala:109)
- at org.apache.spark.executor.CoarseGrainedExecutorBackend$.main(CoarseGrainedExecutorBackend.scala:120)
- at org.apache.spark.executor.CoarseGrainedExecutorBackend.main(CoarseGrainedExecutorBackend.scala)
- "VM Thread" prio=10 tid=0x000000000158d800 nid=0x4a46 runnable
- "GC task thread#0 (ParallelGC)" prio=10 tid=0x00000000014f4800 nid=0x4a3e runnable
- "GC task thread#1 (ParallelGC)" prio=10 tid=0x00000000014f6000 nid=0x4a3f runnable
- "GC task thread#2 (ParallelGC)" prio=10 tid=0x00000000014f8000 nid=0x4a40 runnable
- "GC task thread#3 (ParallelGC)" prio=10 tid=0x00000000014fa000 nid=0x4a41 runnable
- "GC task thread#4 (ParallelGC)" prio=10 tid=0x00000000014fb800 nid=0x4a42 runnable
- "GC task thread#5 (ParallelGC)" prio=10 tid=0x00000000014fd800 nid=0x4a43 runnable
- "GC task thread#6 (ParallelGC)" prio=10 tid=0x00000000014ff800 nid=0x4a44 runnable
- "GC task thread#7 (ParallelGC)" prio=10 tid=0x0000000001501800 nid=0x4a45 runnable
- "VM Periodic Task Thread" prio=10 tid=0x00007f0ce006b000 nid=0x4a4d waiting on condition
- JNI global references: 279
Add Comment
Please, Sign In to add comment