Hello I have a spark streaming app which consume kafka messages using kafka 0.9 directStream and EsSpark saveToES.
almost every time after submit it, it ran fine then after several hours one of the jobs just stuck and keep running. Has anybody seen the same/similar issue? The stack trace is 2017-06-02 14:28:13 Full thread dump OpenJDK 64-Bit Server VM (25.131-b11 mixed mode): "Attach Listener" #1031 daemon prio=9 os_prio=0 tid=0x00007f97987f6000 nid=0x989 waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE Locked ownable synchronizers: - None "Thread-904" #1023 daemon prio=5 os_prio=0 tid=0x000000000334c000 nid=0x5db1 runnable [0x0000000000000000] java.lang.Thread.State: RUNNABLE Locked ownable synchronizers: - None "Thread-903" #1024 daemon prio=5 os_prio=0 tid=0x00007f97b64b3000 nid=0x5daf runnable [0x0000000000000000] java.lang.Thread.State: RUNNABLE Locked ownable synchronizers: - None "Thread-902" #1022 daemon prio=5 os_prio=0 tid=0x00007f97b64ae000 nid=0x5dac runnable [0x0000000000000000] java.lang.Thread.State: RUNNABLE Locked ownable synchronizers: - None "Thread-901" #1021 daemon prio=5 os_prio=0 tid=0x00007f97a04b8800 nid=0x5daa runnable [0x0000000000000000] java.lang.Thread.State: RUNNABLE Locked ownable synchronizers: - None . . . . "Thread-52" #138 daemon prio=5 os_prio=0 tid=0x00007f97b4121800 nid=0x3df5 runnable [0x0000000000000000] java.lang.Thread.State: RUNNABLE Locked ownable synchronizers: - None "Thread-51" #137 daemon prio=5 os_prio=0 tid=0x00007f97a00ee000 nid=0x3df4 runnable [0x0000000000000000] java.lang.Thread.State: RUNNABLE Locked ownable synchronizers: - None . . . "Thread-3" #86 daemon prio=5 os_prio=0 tid=0x00007f9798222800 nid=0x3e1c runnable [0x0000000000000000] java.lang.Thread.State: RUNNABLE Locked ownable synchronizers: - None "shuffle-client-5-1" #75 daemon prio=5 os_prio=0 tid=0x00007f97a0024800 nid=0x3dcc runnable [0x00007f9786488000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method) at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269) at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93) at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86) - locked <0x0000000702c84460> (a io.netty.channel.nio.SelectedSelectionKeySet) - locked <0x0000000702c84480> (a java.util.Collections$UnmodifiableSet) - locked <0x0000000702c84418> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97) at io.netty.channel.nio.NioEventLoop.select(NioEventLoop.java:760) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:401) at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:140) at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:144) at java.lang.Thread.run(Thread.java:748) Locked ownable synchronizers: - None "Executor task launch worker-0" #83 daemon prio=5 os_prio=0 tid=0x00007f97b5a96800 nid=0x3dc9 runnable [0x00007f9786fa0000] java.lang.Thread.State: RUNNABLE at com.mapr.fs.jni.MarlinJniListener.Poll(Native Method) at com.mapr.streams.impl.listener.MarlinListenerImpl.poll(MarlinListenerImpl.java:271) at com.mapr.streams.impl.listener.MarlinListener.poll(MarlinListener.java:100) at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1118) at org.apache.spark.streaming.kafka09.CachedKafkaConsumer.poll(CachedKafkaConsumer.scala:104) at org.apache.spark.streaming.kafka09.CachedKafkaConsumer.get(CachedKafkaConsumer.scala:71) at org.apache.spark.streaming.kafka09.KafkaRDD$KafkaRDDIterator.skipGapsAndGetNext$1(KafkaRDD.scala:233) at org.apache.spark.streaming.kafka09.KafkaRDD$KafkaRDDIterator.getNext(KafkaRDD.scala:248) at org.apache.spark.streaming.kafka09.KafkaRDD$KafkaRDDIterator.getNext(KafkaRDD.scala:197) at org.apache.spark.util.NextIterator.hasNext(NextIterator.scala:73) at org.apache.spark.util.Utils$.getIteratorSize(Utils.scala:1760) at org.apache.spark.rdd.RDD$$anonfun$count$1.apply(RDD.scala:1157) at org.apache.spark.rdd.RDD$$anonfun$count$1.apply(RDD.scala:1157) at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1944) at org.apache.spark.SparkContext$$anonfun$runJob$5.apply(SparkContext.scala:1944) at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:87) at org.apache.spark.scheduler.Task.run(Task.scala:99) at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:282) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:748) Locked ownable synchronizers: - <0x0000000702c84cd8> (a java.util.concurrent.ThreadPoolExecutor$Worker) "driver-heartbeater" #81 daemon prio=5 os_prio=0 tid=0x00007f97982b0800 nid=0x3c2a waiting on condition [0x00007f978357b000] java.lang.Thread.State: TIMED_WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x0000000702c31b20> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1067) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1127) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:748) Locked ownable synchronizers: - None "shuffle-server-6-1" #78 daemon prio=5 os_prio=0 tid=0x00007f97982a7000 nid=0x3c29 runnable [0x00007f978367c000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method) at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269) at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93) at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86) - locked <0x0000000702c8b330> (a io.netty.channel.nio.SelectedSelectionKeySet) - locked <0x0000000702ca9ba0> (a java.util.Collections$UnmodifiableSet) - locked <0x0000000702c8b298> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97) at io.netty.channel.nio.NioEventLoop.select(NioEventLoop.java:760) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:401) at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:140) at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:144) at java.lang.Thread.run(Thread.java:748) Locked ownable synchronizers: - None "shuffle-client-4-1" #64 daemon prio=5 os_prio=0 tid=0x00007f97a044b800 nid=0x3c28 runnable [0x00007f9784b7e000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method) at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269) at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93) at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86) - locked <0x0000000702bfad78> (a io.netty.channel.nio.SelectedSelectionKeySet) - locked <0x0000000702bfad98> (a java.util.Collections$UnmodifiableSet) - locked <0x0000000702bfad30> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97) at io.netty.channel.nio.NioEventLoop.select(NioEventLoop.java:760) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:401) at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:140) at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:144) at java.lang.Thread.run(Thread.java:748) Locked ownable synchronizers: - None "netty-rpc-env-timeout" #73 daemon prio=5 os_prio=0 tid=0x00007f97b5c38000 nid=0x3c27 waiting on condition [0x00007f9784c7f000] java.lang.Thread.State: TIMED_WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x0000000702c80ae8> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1067) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1127) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:748) Locked ownable synchronizers: - None "dispatcher-event-loop-15" #63 daemon prio=5 os_prio=0 tid=0x00007f97b5537000 nid=0x3c25 waiting on condition [0x00007f9784e81000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x0000000702c32a68> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at org.apache.spark.rpc.netty.Dispatcher$MessageLoop.run(Dispatcher.scala:207) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:748) Locked ownable synchronizers: - <0x0000000702c32b48> (a java.util.concurrent.ThreadPoolExecutor$Worker) "dispatcher-event-loop-14" #62 daemon prio=5 os_prio=0 tid=0x00007f97b5535800 nid=0x3c24 waiting on condition [0x00007f9784f82000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x0000000702c32a68> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at org.apache.spark.rpc.netty.Dispatcher$MessageLoop.run(Dispatcher.scala:207) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:748) Locked ownable synchronizers: - <0x0000000702c820f0> (a java.util.concurrent.ThreadPoolExecutor$Worker) "dispatcher-event-loop-13" #61 daemon prio=5 os_prio=0 tid=0x00007f97b5533800 nid=0x3c23 waiting on condition [0x00007f9785083000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x0000000702c32a68> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at org.apache.spark.rpc.netty.Dispatcher$MessageLoop.run(Dispatcher.scala:207) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:748) Locked ownable synchronizers: - <0x0000000702c32ff0> (a java.util.concurrent.ThreadPoolExecutor$Worker) "dispatcher-event-loop-12" #60 daemon prio=5 os_prio=0 tid=0x00007f97b5532000 nid=0x3c22 waiting on condition [0x00007f9785184000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x0000000702c32a68> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at org.apache.spark.rpc.netty.Dispatcher$MessageLoop.run(Dispatcher.scala:207) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:748) Locked ownable synchronizers: - <0x0000000702c33e20> (a java.util.concurrent.ThreadPoolExecutor$Worker) "dispatcher-event-loop-11" #59 daemon prio=5 os_prio=0 tid=0x00007f97b4f00000 nid=0x3c21 waiting on condition [0x00007f9785285000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x0000000702c32a68> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at org.apache.spark.rpc.netty.Dispatcher$MessageLoop.run(Dispatcher.scala:207) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:748) Locked ownable synchronizers: - <0x0000000702c823e0> (a java.util.concurrent.ThreadPoolExecutor$Worker) "dispatcher-event-loop-10" #58 daemon prio=5 os_prio=0 tid=0x00007f97b4eff000 nid=0x3c20 waiting on condition [0x00007f9786789000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x0000000702c32a68> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at org.apache.spark.rpc.netty.Dispatcher$MessageLoop.run(Dispatcher.scala:207) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:748) Locked ownable synchronizers: - <0x0000000702c346e0> (a java.util.concurrent.ThreadPoolExecutor$Worker) "dispatcher-event-loop-9" #57 daemon prio=5 os_prio=0 tid=0x00007f97b4efe000 nid=0x3c1f waiting on condition [0x00007f978b149000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x0000000702c32a68> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at org.apache.spark.rpc.netty.Dispatcher$MessageLoop.run(Dispatcher.scala:207) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:748) Locked ownable synchronizers: - <0x0000000702c34f80> (a java.util.concurrent.ThreadPoolExecutor$Worker) "dispatcher-event-loop-8" #56 daemon prio=5 os_prio=0 tid=0x00007f97b4efd000 nid=0x3c1e waiting on condition [0x00007f9787bac000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x0000000702c32a68> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at org.apache.spark.rpc.netty.Dispatcher$MessageLoop.run(Dispatcher.scala:207) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:748) Locked ownable synchronizers: - <0x0000000702c32d70> (a java.util.concurrent.ThreadPoolExecutor$Worker) "dispatcher-event-loop-7" #55 daemon prio=5 os_prio=0 tid=0x00007f97b4efc000 nid=0x3c1d waiting on condition [0x00007f9787aab000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x0000000702c32a68> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at org.apache.spark.rpc.netty.Dispatcher$MessageLoop.run(Dispatcher.scala:207) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:748) Locked ownable synchronizers: - <0x0000000702c82930> (a java.util.concurrent.ThreadPoolExecutor$Worker) "dispatcher-event-loop-6" #54 daemon prio=5 os_prio=0 tid=0x00007f97b4efb000 nid=0x3c1c waiting on condition [0x00007f97874a5000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x0000000702c32a68> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at org.apache.spark.rpc.netty.Dispatcher$MessageLoop.run(Dispatcher.scala:207) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:748) Locked ownable synchronizers: - <0x0000000702c34460> (a java.util.concurrent.ThreadPoolExecutor$Worker) "dispatcher-event-loop-5" #53 daemon prio=5 os_prio=0 tid=0x00007f97b4efa000 nid=0x3c1b waiting on condition [0x00007f97872a3000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x0000000702c32a68> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at org.apache.spark.rpc.netty.Dispatcher$MessageLoop.run(Dispatcher.scala:207) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:748) Locked ownable synchronizers: - <0x0000000702c34be0> (a java.util.concurrent.ThreadPoolExecutor$Worker) "dispatcher-event-loop-4" #52 daemon prio=5 os_prio=0 tid=0x00007f97b4ef9000 nid=0x3c1a waiting on condition [0x00007f97878a9000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x0000000702c32a68> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at org.apache.spark.rpc.netty.Dispatcher$MessageLoop.run(Dispatcher.scala:207) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:748) Locked ownable synchronizers: - <0x0000000702c34960> (a java.util.concurrent.ThreadPoolExecutor$Worker) "dispatcher-event-loop-3" #51 daemon prio=5 os_prio=0 tid=0x00007f97b4ef8000 nid=0x3c19 waiting on condition [0x00007f97873a4000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x0000000702c32a68> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at org.apache.spark.rpc.netty.Dispatcher$MessageLoop.run(Dispatcher.scala:207) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:748) Locked ownable synchronizers: - <0x0000000702c82c70> (a java.util.concurrent.ThreadPoolExecutor$Worker) "dispatcher-event-loop-2" #50 daemon prio=5 os_prio=0 tid=0x00007f97b5b1a800 nid=0x3c18 waiting on condition [0x00007f97879aa000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x0000000702c32a68> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at org.apache.spark.rpc.netty.Dispatcher$MessageLoop.run(Dispatcher.scala:207) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:748) Locked ownable synchronizers: - <0x0000000702c340c0> (a java.util.concurrent.ThreadPoolExecutor$Worker) "dispatcher-event-loop-1" #49 daemon prio=5 os_prio=0 tid=0x00007f97b5b19800 nid=0x3c17 waiting on condition [0x00007f97877a8000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x0000000702c32a68> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at org.apache.spark.rpc.netty.Dispatcher$MessageLoop.run(Dispatcher.scala:207) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:748) Locked ownable synchronizers: - <0x0000000702c33270> (a java.util.concurrent.ThreadPoolExecutor$Worker) "dispatcher-event-loop-0" #48 daemon prio=5 os_prio=0 tid=0x00007f97b5b0f800 nid=0x3c16 waiting on condition [0x00007f978688a000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x0000000702c32a68> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at org.apache.spark.rpc.netty.Dispatcher$MessageLoop.run(Dispatcher.scala:207) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:748) Locked ownable synchronizers: - <0x0000000702c83e70> (a java.util.concurrent.ThreadPoolExecutor$Worker) "threadDeathWatcher-3-1" #47 daemon prio=1 os_prio=0 tid=0x00007f979824a800 nid=0x3c0e waiting on condition [0x00007f9786387000] java.lang.Thread.State: TIMED_WAITING (sleeping) at java.lang.Thread.sleep(Native Method) at io.netty.util.ThreadDeathWatcher$Watcher.run(ThreadDeathWatcher.java:150) at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:144) at java.lang.Thread.run(Thread.java:748) Locked ownable synchronizers: - None "Service Thread" #17 daemon prio=9 os_prio=0 tid=0x00007f97b4136800 nid=0x3bf4 runnable [0x0000000000000000] java.lang.Thread.State: RUNNABLE Locked ownable synchronizers: - None "C1 CompilerThread11" #16 daemon prio=9 os_prio=0 tid=0x00007f97b4131800 nid=0x3bf3 waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE Locked ownable synchronizers: - None "C1 CompilerThread10" #15 daemon prio=9 os_prio=0 tid=0x00007f97b412f800 nid=0x3bf2 waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE Locked ownable synchronizers: - None "C1 CompilerThread9" #14 daemon prio=9 os_prio=0 tid=0x00007f97b412d000 nid=0x3bf1 waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE Locked ownable synchronizers: - None "C1 CompilerThread8" #13 daemon prio=9 os_prio=0 tid=0x00007f97b412b000 nid=0x3bf0 waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE Locked ownable synchronizers: - None "C2 CompilerThread7" #12 daemon prio=9 os_prio=0 tid=0x00007f97b4128800 nid=0x3bef waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE Locked ownable synchronizers: - None "C2 CompilerThread6" #11 daemon prio=9 os_prio=0 tid=0x00007f97b411e000 nid=0x3bee waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE Locked ownable synchronizers: - None "C2 CompilerThread5" #10 daemon prio=9 os_prio=0 tid=0x00007f97b411c000 nid=0x3bed waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE Locked ownable synchronizers: - None "C2 CompilerThread4" #9 daemon prio=9 os_prio=0 tid=0x00007f97b4111800 nid=0x3bec waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE Locked ownable synchronizers: - None "C2 CompilerThread3" #8 daemon prio=9 os_prio=0 tid=0x00007f97b4107800 nid=0x3beb waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE Locked ownable synchronizers: - None "C2 CompilerThread2" #7 daemon prio=9 os_prio=0 tid=0x00007f97b4105000 nid=0x3bea waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE Locked ownable synchronizers: - None "C2 CompilerThread1" #6 daemon prio=9 os_prio=0 tid=0x00007f97b4103000 nid=0x3be9 waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE Locked ownable synchronizers: - None "C2 CompilerThread0" #5 daemon prio=9 os_prio=0 tid=0x00007f97b40f6000 nid=0x3be8 waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE Locked ownable synchronizers: - None "Signal Dispatcher" #4 daemon prio=9 os_prio=0 tid=0x00007f97b40f3800 nid=0x3be7 runnable [0x0000000000000000] java.lang.Thread.State: RUNNABLE Locked ownable synchronizers: - None "Finalizer" #3 daemon prio=8 os_prio=0 tid=0x00007f97b40ca000 nid=0x3be6 in Object.wait() [0x00007f979e480000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(Native Method) at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:143) - locked <0x000000070002bdd8> (a java.lang.ref.ReferenceQueue$Lock) at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:164) at java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:209) Locked ownable synchronizers: - None "Reference Handler" #2 daemon prio=10 os_prio=0 tid=0x00007f97b40bf800 nid=0x3be5 in Object.wait() [0x00007f979e581000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(Native Method) at java.lang.Object.wait(Object.java:502) at java.lang.ref.Reference.tryHandlePending(Reference.java:191) - locked <0x000000070001da70> (a java.lang.ref.Reference$Lock) at java.lang.ref.Reference$ReferenceHandler.run(Reference.java:153) Locked ownable synchronizers: - None "main" #1 prio=5 os_prio=0 tid=0x00007f97b4027000 nid=0x3bd6 waiting on condition [0x00007f97bdd6e000] java.lang.Thread.State: TIMED_WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x0000000702b6fb68> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) at java.util.concurrent.ThreadPoolExecutor.awaitTermination(ThreadPoolExecutor.java:1465) at org.apache.spark.rpc.netty.Dispatcher.awaitTermination(Dispatcher.scala:180) at org.apache.spark.rpc.netty.NettyRpcEnv.awaitTermination(NettyRpcEnv.scala:273) at org.apache.spark.executor.CoarseGrainedExecutorBackend$$anonfun$run$1.apply$mcV$sp(CoarseGrainedExecutorBackend.scala:231) at org.apache.spark.deploy.SparkHadoopUtil$$anon$1.run(SparkHadoopUtil.scala:67) at org.apache.spark.deploy.SparkHadoopUtil$$anon$1.run(SparkHadoopUtil.scala:66) at java.security.AccessController.doPrivileged(Native Method) at javax.security.auth.Subject.doAs(Subject.java:422) at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1595) at org.apache.spark.deploy.SparkHadoopUtil.runAsSparkUser(SparkHadoopUtil.scala:66) at org.apache.spark.executor.CoarseGrainedExecutorBackend$.run(CoarseGrainedExecutorBackend.scala:188) at org.apache.spark.executor.CoarseGrainedExecutorBackend$.main(CoarseGrainedExecutorBackend.scala:284) at org.apache.spark.executor.CoarseGrainedExecutorBackend.main(CoarseGrainedExecutorBackend.scala) Locked ownable synchronizers: - None "VM Thread" os_prio=0 tid=0x00007f97b40b5800 nid=0x3be4 runnable "GC task thread#0 (ParallelGC)" os_prio=0 tid=0x00007f97b403c000 nid=0x3bd7 runnable "GC task thread#1 (ParallelGC)" os_prio=0 tid=0x00007f97b403e000 nid=0x3bd8 runnable "GC task thread#2 (ParallelGC)" os_prio=0 tid=0x00007f97b4040000 nid=0x3bd9 runnable "GC task thread#3 (ParallelGC)" os_prio=0 tid=0x00007f97b4041800 nid=0x3bda runnable "GC task thread#4 (ParallelGC)" os_prio=0 tid=0x00007f97b4043800 nid=0x3bdb runnable "GC task thread#5 (ParallelGC)" os_prio=0 tid=0x00007f97b4045000 nid=0x3bdc runnable "GC task thread#6 (ParallelGC)" os_prio=0 tid=0x00007f97b4047000 nid=0x3bdd runnable "GC task thread#7 (ParallelGC)" os_prio=0 tid=0x00007f97b4049000 nid=0x3bde runnable "GC task thread#8 (ParallelGC)" os_prio=0 tid=0x00007f97b404a800 nid=0x3bdf runnable "GC task thread#9 (ParallelGC)" os_prio=0 tid=0x00007f97b404c800 nid=0x3be0 runnable "GC task thread#10 (ParallelGC)" os_prio=0 tid=0x00007f97b404e800 nid=0x3be1 runnable "GC task thread#11 (ParallelGC)" os_prio=0 tid=0x00007f97b4050000 nid=0x3be2 runnable "GC task thread#12 (ParallelGC)" os_prio=0 tid=0x00007f97b4052000 nid=0x3be3 runnable "VM Periodic Task Thread" os_prio=0 tid=0x00007f97b4139000 nid=0x3bf5 waiting on condition JNI global references: 295 -- View this message in context: http://apache-spark-developers-list.1001551.n3.nabble.com/stuck-on-one-of-the-jobs-in-spark-streaming-app-tp21668.html Sent from the Apache Spark Developers List mailing list archive at Nabble.com. --------------------------------------------------------------------- To unsubscribe e-mail: dev-unsubscr...@spark.apache.org