2020-07-31 16:36:16 Full thread dump OpenJDK 64-Bit Server VM (25.222-b10 mixed mode): "Attach Listener" #12 daemon prio=9 os_prio=0 tid=0x00007f8318001000 nid=0x1d2 waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE "Service Thread" #9 daemon prio=9 os_prio=0 tid=0x00007f83643dc800 nid=0x192 runnable [0x0000000000000000] java.lang.Thread.State: RUNNABLE "C1 CompilerThread3" #8 daemon prio=9 os_prio=0 tid=0x00007f83643d5000 nid=0x191 waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE "C2 CompilerThread2" #7 daemon prio=9 os_prio=0 tid=0x00007f83643d3000 nid=0x190 waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE "C2 CompilerThread1" #6 daemon prio=9 os_prio=0 tid=0x00007f83643d1000 nid=0x18f waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE "C2 CompilerThread0" #5 daemon prio=9 os_prio=0 tid=0x00007f83643cf000 nid=0x18e waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE "Signal Dispatcher" #4 daemon prio=9 os_prio=0 tid=0x00007f83643cc800 nid=0x18d runnable [0x0000000000000000] java.lang.Thread.State: RUNNABLE "Finalizer" #3 daemon prio=8 os_prio=0 tid=0x00007f83640fb000 nid=0x18c in Object.wait() [0x00007f8332d47000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(Native Method) - waiting on <0x00000000c001b528> (a java.lang.ref.ReferenceQueue$Lock) at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:144) - locked <0x00000000c001b528> (a java.lang.ref.ReferenceQueue$Lock) at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:165) at java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:216) "Reference Handler" #2 daemon prio=10 os_prio=0 tid=0x00007f83640f6000 nid=0x18b in Object.wait() [0x00007f8332e48000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(Native Method) - waiting on <0x00000000c002a1b8> (a java.lang.ref.Reference$Lock) at java.lang.Object.wait(Object.java:502) at java.lang.ref.Reference.tryHandlePending(Reference.java:191) - locked <0x00000000c002a1b8> (a java.lang.ref.Reference$Lock) at java.lang.ref.Reference$ReferenceHandler.run(Reference.java:153) "main" #1 prio=5 os_prio=0 tid=0x00007f836405a000 nid=0x180 runnable [0x00007f836a7dd000] java.lang.Thread.State: RUNNABLE at java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1718) at org.talend.sdk.component.runtime.manager.util.LazyMap.get(LazyMap.java:32) at org.talend.sdk.component.runtime.manager.service.DefaultServiceProvider.doLookup(DefaultServiceProvider.java:178) at org.talend.sdk.component.runtime.manager.service.DefaultServiceProvider.lookup(DefaultServiceProvider.java:110) at org.talend.sdk.component.runtime.manager.ComponentManager$Updater.lambda$onCreate$2(ComponentManager.java:1212) at org.talend.sdk.component.runtime.manager.ComponentManager$Updater$$Lambda$164/403960809.apply(Unknown Source) at java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1660) - locked <0x00000000f2920c40> (a java.util.concurrent.ConcurrentHashMap$ReservationNode) at org.talend.sdk.component.runtime.manager.util.LazyMap.get(LazyMap.java:32) at org.talend.sdk.component.runtime.manager.ComponentManager$Updater.lambda$onCreate$4(ComponentManager.java:1254) at org.talend.sdk.component.runtime.manager.ComponentManager$Updater$$Lambda$176/2000410491.accept(Unknown Source) at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175) at java.util.stream.DistinctOps$1$2.accept(DistinctOps.java:175) at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193) at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1382) at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482) at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472) at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150) at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173) at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485) at org.talend.sdk.component.runtime.manager.ComponentManager$Updater.onCreate(ComponentManager.java:1252) at org.talend.sdk.component.container.ContainerManager$ContainerBuilder.lambda$null$1(ContainerManager.java:478) at org.talend.sdk.component.container.ContainerManager$ContainerBuilder$$Lambda$159/1532800776.run(Unknown Source) at org.talend.sdk.component.container.ContainerManager.safeInvoke(ContainerManager.java:179) at org.talend.sdk.component.container.ContainerManager.access$1200(ContainerManager.java:66) at org.talend.sdk.component.container.ContainerManager$ContainerBuilder.lambda$create$2(ContainerManager.java:478) at org.talend.sdk.component.container.ContainerManager$ContainerBuilder$$Lambda$158/1075996552.test(Unknown Source) at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:174) at java.util.Spliterators$ArraySpliterator.forEachRemaining(Spliterators.java:948) at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482) at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472) at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708) at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:566) at org.talend.sdk.component.container.ContainerManager$ContainerBuilder.create(ContainerManager.java:479) at org.talend.sdk.component.runtime.manager.ComponentManager.addPlugin(ComponentManager.java:842) at org.talend.datastreams.beam.compiler.util.ComponentsUtil.loadPlugin(ComponentsUtil.java:103) at org.talend.datastreams.beam.compiler.runtimeflow.RuntimeFlowBeamCompiler.compile(RuntimeFlowBeamCompiler.java:73) at org.talend.datastreams.beam.compiler.runtimeflow.RuntimeFlowBeamCompiler.compile(RuntimeFlowBeamCompiler.java:32) at org.talend.datastreams.streamsjob.FullRunJob$.runJob(FullRunJob.scala:118) at org.talend.datastreams.streamsjob.FullRunJob$.main(FullRunJob.scala:47) at org.talend.datastreams.streamsjob.FullRunJob.main(FullRunJob.scala) "VM Thread" os_prio=0 tid=0x00007f83640ec800 nid=0x18a runnable "GC task thread#0 (ParallelGC)" os_prio=0 tid=0x00007f836406c800 nid=0x182 runnable "GC task thread#1 (ParallelGC)" os_prio=0 tid=0x00007f836406e800 nid=0x183 runnable "GC task thread#2 (ParallelGC)" os_prio=0 tid=0x00007f8364070000 nid=0x184 runnable "GC task thread#3 (ParallelGC)" os_prio=0 tid=0x00007f8364072000 nid=0x185 runnable "GC task thread#4 (ParallelGC)" os_prio=0 tid=0x00007f8364074000 nid=0x186 runnable "GC task thread#5 (ParallelGC)" os_prio=0 tid=0x00007f8364075800 nid=0x187 runnable "GC task thread#6 (ParallelGC)" os_prio=0 tid=0x00007f8364077800 nid=0x188 runnable "GC task thread#7 (ParallelGC)" os_prio=0 tid=0x00007f8364079800 nid=0x189 runnable "VM Periodic Task Thread" os_prio=0 tid=0x00007f83643df000 nid=0x193 waiting on condition JNI global references: 593