API tools faq
paste
Guest User

Untitled

a guest
Sep 26th, 2016
84
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 23.12 KB | None | 0 0
raw download clone embed print report
  1. jstack 29343
  2. 2016-09-26 15:32:08
  3. Full thread dump Java HotSpot(TM) 64-Bit Server VM (25.77-b03 mixed mode):
  4.  
  5. "Attach Listener" #24 daemon prio=9 os_prio=0 tid=0x00007fd19c001000 nid=0x72d6 waiting on condition [0x0000000000000000]
  6.    java.lang.Thread.State: RUNNABLE
  7.  
  8. "New I/O server boss #6" #23 daemon prio=5 os_prio=0 tid=0x00007fd168105800 nid=0x72be runnable [0x00007fd1bb0e4000]
  9.    java.lang.Thread.State: RUNNABLE
  10.     at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
  11.     at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
  12.     at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93)
  13.     at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)
  14.     - locked <0x00000006c6e23c18> (a sun.nio.ch.Util$2)
  15.     - locked <0x00000006c6e23c28> (a java.util.Collections$UnmodifiableSet)
  16.     - locked <0x00000006c6e23bd0> (a sun.nio.ch.EPollSelectorImpl)
  17.     at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)
  18.     at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:101)
  19.     at org.jboss.netty.channel.socket.nio.NioServerBoss.select(NioServerBoss.java:163)
  20.     at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:212)
  21.     at org.jboss.netty.channel.socket.nio.NioServerBoss.run(NioServerBoss.java:42)
  22.     at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
  23.     at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
  24.     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
  25.     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
  26.     at java.lang.Thread.run(Thread.java:745)
  27.  
  28. "New I/O worker #5" #22 daemon prio=5 os_prio=0 tid=0x00007fd168091000 nid=0x72bd runnable [0x00007fd1bb1e5000]
  29.    java.lang.Thread.State: RUNNABLE
  30.     at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
  31.     at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
  32.     at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93)
  33.     at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)
  34.     - locked <0x00000006c6e2bbd8> (a sun.nio.ch.Util$2)
  35.     - locked <0x00000006c6e2bbe8> (a java.util.Collections$UnmodifiableSet)
  36.     - locked <0x00000006c6e2bb90> (a sun.nio.ch.EPollSelectorImpl)
  37.     at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)
  38.     at org.jboss.netty.channel.socket.nio.SelectorUtil.select(SelectorUtil.java:68)
  39.     at org.jboss.netty.channel.socket.nio.AbstractNioSelector.select(AbstractNioSelector.java:415)
  40.     at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:212)
  41.     at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
  42.     at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
  43.     at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
  44.     at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
  45.     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
  46.     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
  47.     at java.lang.Thread.run(Thread.java:745)
  48.  
  49. "New I/O worker #4" #21 daemon prio=5 os_prio=0 tid=0x00007fd16808d000 nid=0x72bc runnable [0x00007fd1bb2e6000]
  50.    java.lang.Thread.State: RUNNABLE
  51.     at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
  52.     at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
  53.     at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93)
  54.     at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)
  55.     - locked <0x00000006c6e33688> (a sun.nio.ch.Util$2)
  56.     - locked <0x00000006c6e33698> (a java.util.Collections$UnmodifiableSet)
  57.     - locked <0x00000006c6e33640> (a sun.nio.ch.EPollSelectorImpl)
  58.     at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)
  59.     at org.jboss.netty.channel.socket.nio.SelectorUtil.select(SelectorUtil.java:68)
  60.     at org.jboss.netty.channel.socket.nio.AbstractNioSelector.select(AbstractNioSelector.java:415)
  61.     at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:212)
  62.     at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
  63.     at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
  64.     at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
  65.     at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
  66.     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
  67.     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
  68.     at java.lang.Thread.run(Thread.java:745)
  69.  
  70. "New I/O boss #3" #20 daemon prio=5 os_prio=0 tid=0x00007fd16808b000 nid=0x72bb runnable [0x00007fd1bb3e7000]
  71.    java.lang.Thread.State: RUNNABLE
  72.     at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
  73.     at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
  74.     at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93)
  75.     at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)
  76.     - locked <0x00000006c6e3b590> (a sun.nio.ch.Util$2)
  77.     - locked <0x00000006c6e3b5a0> (a java.util.Collections$UnmodifiableSet)
  78.     - locked <0x00000006c6e3b548> (a sun.nio.ch.EPollSelectorImpl)
  79.     at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)
  80.     at org.jboss.netty.channel.socket.nio.SelectorUtil.select(SelectorUtil.java:68)
  81.     at org.jboss.netty.channel.socket.nio.AbstractNioSelector.select(AbstractNioSelector.java:415)
  82.     at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:212)
  83.     at org.jboss.netty.channel.socket.nio.NioClientBoss.run(NioClientBoss.java:42)
  84.     at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
  85.     at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
  86.     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
  87.     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
  88.     at java.lang.Thread.run(Thread.java:745)
  89.  
  90. "New I/O worker #2" #18 daemon prio=5 os_prio=0 tid=0x00007fd16802e800 nid=0x72ba runnable [0x00007fd1bb4e7000]
  91.    java.lang.Thread.State: RUNNABLE
  92.     at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
  93.     at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
  94.     at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93)
  95.     at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)
  96.     - locked <0x00000006c6e42778> (a sun.nio.ch.Util$2)
  97.     - locked <0x00000006c6e42788> (a java.util.Collections$UnmodifiableSet)
  98.     - locked <0x00000006c6e42730> (a sun.nio.ch.EPollSelectorImpl)
  99.     at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)
  100.     at org.jboss.netty.channel.socket.nio.SelectorUtil.select(SelectorUtil.java:68)
  101.     at org.jboss.netty.channel.socket.nio.AbstractNioSelector.select(AbstractNioSelector.java:415)
  102.     at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:212)
  103.     at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
  104.     at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
  105.     at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
  106.     at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
  107.     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
  108.     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
  109.     at java.lang.Thread.run(Thread.java:745)
  110.  
  111. "New I/O worker #1" #17 daemon prio=5 os_prio=0 tid=0x00007fd168032800 nid=0x72b9 runnable [0x00007fd1bb5e8000]
  112.    java.lang.Thread.State: RUNNABLE
  113.     at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
  114.     at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
  115.     at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93)
  116.     at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)
  117.     - locked <0x00000006c6e1f150> (a sun.nio.ch.Util$2)
  118.     - locked <0x00000006c6e1f160> (a java.util.Collections$UnmodifiableSet)
  119.     - locked <0x00000006c6e1f108> (a sun.nio.ch.EPollSelectorImpl)
  120.     at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)
  121.     at org.jboss.netty.channel.socket.nio.SelectorUtil.select(SelectorUtil.java:68)
  122.     at org.jboss.netty.channel.socket.nio.AbstractNioSelector.select(AbstractNioSelector.java:415)
  123.     at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:212)
  124.     at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
  125.     at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
  126.     at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
  127.     at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
  128.     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
  129.     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
  130.     at java.lang.Thread.run(Thread.java:745)
  131.  
  132. "flink-akka.remote.default-remote-dispatcher-6" #16 daemon prio=5 os_prio=0 tid=0x00007fd1e8685000 nid=0x72b8 waiting on condition [0x00007fd1bbafb000]
  133.    java.lang.Thread.State: WAITING (parking)
  134.     at sun.misc.Unsafe.park(Native Method)
  135.     - parking to wait for  <0x00000006c6e4a6c8> (a akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinPool)
  136.     at scala.concurrent.forkjoin.ForkJoinPool.scan(ForkJoinPool.java:2075)
  137.     at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
  138.     at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
  139.  
  140. "flink-akka.remote.default-remote-dispatcher-5" #15 daemon prio=5 os_prio=0 tid=0x00007fd17c016000 nid=0x72b7 waiting on condition [0x00007fd1bbbfc000]
  141.    java.lang.Thread.State: TIMED_WAITING (parking)
  142.     at sun.misc.Unsafe.park(Native Method)
  143.     - parking to wait for  <0x00000006c6e4a6c8> (a akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinPool)
  144.     at scala.concurrent.forkjoin.ForkJoinPool.idleAwaitWork(ForkJoinPool.java:2135)
  145.     at scala.concurrent.forkjoin.ForkJoinPool.scan(ForkJoinPool.java:2067)
  146.     at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
  147.     at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
  148.  
  149. "flink-akka.actor.default-dispatcher-4" #14 daemon prio=5 os_prio=0 tid=0x00007fd170001000 nid=0x72b6 waiting on condition [0x00007fd1bbcfd000]
  150.    java.lang.Thread.State: TIMED_WAITING (parking)
  151.     at sun.misc.Unsafe.park(Native Method)
  152.     - parking to wait for  <0x00000006c6e4ac08> (a akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinPool)
  153.     at scala.concurrent.forkjoin.ForkJoinPool.idleAwaitWork(ForkJoinPool.java:2135)
  154.     at scala.concurrent.forkjoin.ForkJoinPool.scan(ForkJoinPool.java:2067)
  155.     at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
  156.     at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
  157.  
  158. "flink-akka.actor.default-dispatcher-3" #13 daemon prio=5 os_prio=0 tid=0x00007fd1e8653800 nid=0x72b5 waiting on condition [0x00007fd1bbdfe000]
  159.    java.lang.Thread.State: WAITING (parking)
  160.     at sun.misc.Unsafe.park(Native Method)
  161.     - parking to wait for  <0x00000006c6e4ac08> (a akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinPool)
  162.     at scala.concurrent.forkjoin.ForkJoinPool.scan(ForkJoinPool.java:2075)
  163.     at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
  164.     at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
  165.  
  166. "flink-scheduler-1" #11 daemon prio=5 os_prio=0 tid=0x00007fd1e85a6000 nid=0x72b3 waiting on condition [0x00007fd1c02d2000]
  167.    java.lang.Thread.State: TIMED_WAITING (sleeping)
  168.     at java.lang.Thread.sleep(Native Method)
  169.     at akka.actor.LightArrayRevolverScheduler.waitNanos(Scheduler.scala:226)
  170.     at akka.actor.LightArrayRevolverScheduler$$anon$8.nextTick(Scheduler.scala:405)
  171.     at akka.actor.LightArrayRevolverScheduler$$anon$8.run(Scheduler.scala:375)
  172.     at java.lang.Thread.run(Thread.java:745)
  173.  
  174. "Service Thread" #9 daemon prio=9 os_prio=0 tid=0x00007fd1e80e5000 nid=0x72b1 runnable [0x0000000000000000]
  175.    java.lang.Thread.State: RUNNABLE
  176.  
  177. "C1 CompilerThread3" #8 daemon prio=9 os_prio=0 tid=0x00007fd1e80c8000 nid=0x72b0 waiting on condition [0x0000000000000000]
  178.    java.lang.Thread.State: RUNNABLE
  179.  
  180. "C2 CompilerThread2" #7 daemon prio=9 os_prio=0 tid=0x00007fd1e80c6000 nid=0x72af waiting on condition [0x0000000000000000]
  181.    java.lang.Thread.State: RUNNABLE
  182.  
  183. "C2 CompilerThread1" #6 daemon prio=9 os_prio=0 tid=0x00007fd1e80c4000 nid=0x72ae waiting on condition [0x0000000000000000]
  184.    java.lang.Thread.State: RUNNABLE
  185.  
  186. "C2 CompilerThread0" #5 daemon prio=9 os_prio=0 tid=0x00007fd1e80c1000 nid=0x72ad waiting on condition [0x0000000000000000]
  187.    java.lang.Thread.State: RUNNABLE
  188.  
  189. "Signal Dispatcher" #4 daemon prio=9 os_prio=0 tid=0x00007fd1e80bf800 nid=0x72ac runnable [0x0000000000000000]
  190.    java.lang.Thread.State: RUNNABLE
  191.  
  192. "Finalizer" #3 daemon prio=8 os_prio=0 tid=0x00007fd1e808c800 nid=0x72ab in Object.wait() [0x00007fd1c233d000]
  193.    java.lang.Thread.State: WAITING (on object monitor)
  194.     at java.lang.Object.wait(Native Method)
  195.     - waiting on <0x00000006c6e13860> (a java.lang.ref.ReferenceQueue$Lock)
  196.     at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:143)
  197.     - locked <0x00000006c6e13860> (a java.lang.ref.ReferenceQueue$Lock)
  198.     at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:164)
  199.     at java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:209)
  200.  
  201. "Reference Handler" #2 daemon prio=10 os_prio=0 tid=0x00007fd1e8088000 nid=0x72aa in Object.wait() [0x00007fd1c243e000]
  202.    java.lang.Thread.State: WAITING (on object monitor)
  203.     at java.lang.Object.wait(Native Method)
  204.     - waiting on <0x00000006c6e4b5a0> (a java.lang.ref.Reference$Lock)
  205.     at java.lang.Object.wait(Object.java:502)
  206.     at java.lang.ref.Reference.tryHandlePending(Reference.java:191)
  207.     - locked <0x00000006c6e4b5a0> (a java.lang.ref.Reference$Lock)
  208.     at java.lang.ref.Reference$ReferenceHandler.run(Reference.java:153)
  209.  
  210. "main" #1 prio=5 os_prio=0 tid=0x00007fd1e800a000 nid=0x72a0 runnable [0x00007fd1f0c24000]
  211.    java.lang.Thread.State: RUNNABLE
  212.     at java.util.ArrayList.iterator(ArrayList.java:834)
  213.     at org.apache.flink.api.java.typeutils.runtime.kryo.Serializers.recursivelyRegisterType(Serializers.java:71)
  214.     at org.apache.flink.api.java.ExecutionEnvironment$1.preVisit(ExecutionEnvironment.java:1010)
  215.     at org.apache.flink.api.java.ExecutionEnvironment$1.preVisit(ExecutionEnvironment.java:1003)
  216.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:198)
  217.     at org.apache.flink.api.common.operators.DualInputOperator.accept(DualInputOperator.java:281)
  218.     at org.apache.flink.api.common.operators.DualInputOperator.accept(DualInputOperator.java:282)
  219.     at org.apache.flink.api.common.operators.DualInputOperator.accept(DualInputOperator.java:281)
  220.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  221.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  222.     at org.apache.flink.api.common.operators.DualInputOperator.accept(DualInputOperator.java:282)
  223.     at org.apache.flink.api.common.operators.DualInputOperator.accept(DualInputOperator.java:281)
  224.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  225.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  226.     at org.apache.flink.api.common.operators.DualInputOperator.accept(DualInputOperator.java:281)
  227.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  228.     at org.apache.flink.api.common.operators.DualInputOperator.accept(DualInputOperator.java:282)
  229.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  230.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  231.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  232.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  233.     at org.apache.flink.api.common.operators.DualInputOperator.accept(DualInputOperator.java:282)
  234.     at org.apache.flink.api.common.operators.DualInputOperator.accept(DualInputOperator.java:281)
  235.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  236.     at org.apache.flink.api.common.operators.DualInputOperator.accept(DualInputOperator.java:282)
  237.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  238.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  239.     at org.apache.flink.api.common.operators.DualInputOperator.accept(DualInputOperator.java:281)
  240.     at org.apache.flink.api.common.operators.DualInputOperator.accept(DualInputOperator.java:282)
  241.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  242.     at org.apache.flink.api.common.operators.DualInputOperator.accept(DualInputOperator.java:281)
  243.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  244.     at org.apache.flink.api.common.operators.DualInputOperator.accept(DualInputOperator.java:282)
  245.     at org.apache.flink.api.common.operators.DualInputOperator.accept(DualInputOperator.java:281)
  246.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  247.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  248.     at org.apache.flink.api.common.operators.DualInputOperator.accept(DualInputOperator.java:281)
  249.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  250.     at org.apache.flink.api.common.operators.DualInputOperator.accept(DualInputOperator.java:282)
  251.     at org.apache.flink.api.common.operators.DualInputOperator.accept(DualInputOperator.java:282)
  252.     at org.apache.flink.api.common.operators.DualInputOperator.accept(DualInputOperator.java:282)
  253.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  254.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  255.     at org.apache.flink.api.common.operators.DualInputOperator.accept(DualInputOperator.java:281)
  256.     at org.apache.flink.api.common.operators.DualInputOperator.accept(DualInputOperator.java:281)
  257.     at org.apache.flink.api.common.operators.DualInputOperator.accept(DualInputOperator.java:282)
  258.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  259.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  260.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  261.     at org.apache.flink.api.common.operators.DualInputOperator.accept(DualInputOperator.java:282)
  262.     at org.apache.flink.api.common.operators.DualInputOperator.accept(DualInputOperator.java:282)
  263.     at org.apache.flink.api.common.operators.DualInputOperator.accept(DualInputOperator.java:282)
  264.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  265.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  266.     at org.apache.flink.api.common.operators.DualInputOperator.accept(DualInputOperator.java:282)
  267.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  268.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  269.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  270.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  271.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  272.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  273.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  274.     at org.apache.flink.api.common.operators.DualInputOperator.accept(DualInputOperator.java:281)
  275.     at org.apache.flink.api.common.operators.DualInputOperator.accept(DualInputOperator.java:281)
  276.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  277.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  278.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  279.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  280.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  281.     at org.apache.flink.api.common.operators.DualInputOperator.accept(DualInputOperator.java:282)
  282.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  283.     at org.apache.flink.api.common.operators.SingleInputOperator.accept(SingleInputOperator.java:199)
  284.     at org.apache.flink.api.common.operators.GenericDataSinkBase.accept(GenericDataSinkBase.java:223)
  285.     at org.apache.flink.api.common.Plan.accept(Plan.java:348)
  286.     at org.apache.flink.api.java.ExecutionEnvironment.createProgramPlan(ExecutionEnvironment.java:1003)
  287.     at org.apache.flink.api.java.ExecutionEnvironment.createProgramPlan(ExecutionEnvironment.java:961)
  288.     at org.apache.flink.client.program.ContextEnvironment.execute(ContextEnvironment.java:57)
  289.     at org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:855)
  290.     at org.mappinganalysis.MappingAnalysisExample.main(MappingAnalysisExample.java:111)
  291.     at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  292.     at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  293.     at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  294.     at java.lang.reflect.Method.invoke(Method.java:498)
  295.     at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:505)
  296.     at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:403)
  297.     at org.apache.flink.client.program.Client.runBlocking(Client.java:248)
  298.     at org.apache.flink.client.CliFrontend.executeProgramBlocking(CliFrontend.java:866)
  299.     at org.apache.flink.client.CliFrontend.run(CliFrontend.java:333)
  300.     at org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:1192)
  301.     at org.apache.flink.client.CliFrontend.main(CliFrontend.java:1243)
  302.  
  303. "VM Thread" os_prio=0 tid=0x00007fd1e8080000 nid=0x72a9 runnable
  304.  
  305. "GC task thread#0 (ParallelGC)" os_prio=0 tid=0x00007fd1e801f800 nid=0x72a1 runnable
  306.  
  307. "GC task thread#1 (ParallelGC)" os_prio=0 tid=0x00007fd1e8021000 nid=0x72a2 runnable
  308.  
  309. "GC task thread#2 (ParallelGC)" os_prio=0 tid=0x00007fd1e8023000 nid=0x72a3 runnable
  310.  
  311. "GC task thread#3 (ParallelGC)" os_prio=0 tid=0x00007fd1e8024800 nid=0x72a4 runnable
  312.  
  313. "GC task thread#4 (ParallelGC)" os_prio=0 tid=0x00007fd1e8026800 nid=0x72a5 runnable
  314.  
  315. "GC task thread#5 (ParallelGC)" os_prio=0 tid=0x00007fd1e8028000 nid=0x72a6 runnable
  316.  
  317. "GC task thread#6 (ParallelGC)" os_prio=0 tid=0x00007fd1e802a000 nid=0x72a7 runnable
  318.  
  319. "GC task thread#7 (ParallelGC)" os_prio=0 tid=0x00007fd1e802b800 nid=0x72a8 runnable
  320.  
  321. "VM Periodic Task Thread" os_prio=0 tid=0x00007fd1e80e8000 nid=0x72b2 waiting on condition
  322.  
  323. JNI global references: 262
Add Comment
Please, Sign In to add comment
Public Pastes
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!