fanxishu opened a new issue, #8081: URL: https://github.com/apache/seatunnel/issues/8081
### Search before asking - [X] I had searched in the [issues](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues. ### What happened When you call the REST API to retrieve job information after the engine has been running for a while, the task information retrieval fails, even though there is a job running in the engine. 在引擎运行一段时间后调用rest接口获取job信息的时候任务信息读取失败，可是引擎上面是有这个任务且运行中 ### SeaTunnel Version 2.3.8 ### SeaTunnel Config ```conf env { "job.mode"=STREAMING "job.name"=实时同步 "checkpoint.interval"="360000" "checkpoint.timeout"="10000" "savemode.execute.location"=CLUSTER } source { MySQL-CDC { format=DEFAULT "snapshot.split.size"="8096" "snapshot.fetch.size"="1024" "incremental.parallelism"="1" "connect.timeout.ms"="30000" "connect.max-retries"="3" "connection.pool.size"="20" "chunk-key.even-distribution.factor.lower-bound"="0.05" "chunk-key.even-distribution.factor.upper-bound"="100.0" "sample-sharding.threshold"="1000" "inverse-sampling.rate"="1000" "startup.mode"=INITIAL "exactly_once"="false" "stop.mode"=NEVER parallelism="1" "result_table_name"=Table15367766757120 "dag-parsing.mode"=MULTIPLEX catalog { factory=Mysql } database-names=[ "test" ] table-names=[ "test.product" ] base-url="jdbc:mysql://127.0.0.1:3380/test?useSSL=false&useUnicode=true&characterEncoding=utf-8&allowMultiQueries=true&allowPublicKeyRetrieval=true&rewriteBatchedStatements=true" username=root password="123456" server-time-zone=UTC driverName="com.mysql.cj.jdbc.Driver" } } transform { } sink { Jdbc { "schema_save_mode"="CREATE_SCHEMA_WHEN_NOT_EXIST" "data_save_mode"="APPEND_DATA" "create_index"="true" "connection_check_timeout_sec"=30 "batch_size"=1000 "is_exactly_once"="false" "max_commit_attempts"=3 "transaction_timeout_sec"=-1 "max_retries"="3" "auto_commit"="true" "support_upsert_by_query_primary_key_exist"="false" "multi_table_sink_replica"=1 "source_table_name"=Table15367766757120 "generate_sink_sql"=true database="eop_conf" table=product url="jdbc:mysql://127.0.0.1:3380/eop_conf?useUnicode=true&characterEncoding=UTF-8&rewriteBatchedStatements=true" password="123456" driver="com.mysql.cj.jdbc.Driver" user=root startup.mode="initial" } } ``` ### Running Command ```shell 911069562043105281 15686439704192_job RUNNING 2024-11-19 09:45:10.625 http://10.19.11.19:5801/hazelcast/rest/maps/thread-dump [{"threadName":"hz.main.event-3","threadId":76,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.internal.util.executor.StripedExecutor$Worker.run(StripedExecutor.java:227)"},{"threadName":"hz.main.event-5","threadId":78,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.internal.util.executor.StripedExecutor$Worker.run(StripedExecutor.java:227)"},{"threadName":"ForkJoinPool.commonPool-worker-0"," threadId":135220,"threadState":"TIMED_WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.ForkJoinPool.awaitWork(ForkJoinPool.java:1824)\njava.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1693)\njava.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:157)"},{"threadName":"hz.main.IO.thread-in-0","threadId":93,"threadState":"RUNNABLE","stackTrace":"sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)\nsun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)\nsun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93)\nsun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)\nsun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)\ncom.hazelcast.internal.networking.nio.NioThread.selectLoop(NioThread.java:292)\ncom.hazelcast.internal.networking.nio.NioThread.executeRun(NioThread.java:249)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"hz.main.schedul ed.thread-","threadId":15,"threadState":"TIMED_WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)\njava.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093)\njava.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)\njava.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)\njava.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)\njava.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\njava.lang.Thread.run(Thread.java:748)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.executeRun(HazelcastManagedThread.java:76)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:1 02)"},{"threadName":"hz.main.generic-operation.thread-40","threadId":63,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:85)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:118)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"hz.main.IO.BalancerThread","threadId":99,"threadState":"TIMED_WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(Abs tractQueuedSynchronizer.java:2078)\njava.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467)\ncom.hazelcast.internal.networking.nio.iobalancer.IOBalancerThread.run(IOBalancerThread.java:65)"},{"threadName":"hz.main.generic-operation.thread-36","threadId":59,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:85)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:118)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"hz.main.generic-operation.thread-2","threadId":25,"threadState":"WAITING" ,"stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:85)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:118)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"hz.main.generic-operation.thread-41","threadId":64,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue .java:442)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:85)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:118)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"main-query-state-checker","threadId":90,"threadState":"TIMED_WAITING","stackTrace":"java.lang.Thread.sleep(Native Method)\ncom.hazelcast.sql.impl.state.QueryStateRegistryUpdater$Worker.run(QueryStateRegistryUpdater.java:114)\njava.lang.Thread.run(Thread.java:748)"},{"threadName":"hz.main.HealthMonitor","threadId":80,"threadState":"TIMED_WAITING","stackTrace":"java.lang.Thread.sleep(Native Method)\njava.lang.Thread.sleep(Thread.java:340)\njava.util.concurrent.TimeUnit.sleep(TimeUnit.java:386)\ncom.hazelcast.internal.diagnostics.HealthMonitor$HealthMonitorThread.run(HealthMonitor.java:163)"},{"threadName":"hz.main.generic-operation.thread-6","threadId":29,"threadSta te":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:85)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:118)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"hz.main.generic-operation.thread-5","threadId":28,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedB lockingQueue.java:442)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:85)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:118)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"hz.main.operation-parker","threadId":79,"threadState":"TIMED_WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)\njava.util.concurrent.DelayQueue.poll(DelayQueue.java:259)\ncom.hazelcast.spi.impl.operationparker.impl.OperationParkerImpl$ExpirationTask.doRun(OperationParkerImpl.java:228)\ncom.hazelcast.spi.impl.operationparker.impl.OperationParkerImpl$ExpirationTask.run(OperationParkerImpl.java:211)\njava.util.concurrent.Executors$RunnableAdapter.call(Execut ors.java:511)\njava.util.concurrent.FutureTask.run(FutureTask.java:266)\njava.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\njava.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\njava.lang.Thread.run(Thread.java:748)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.executeRun(HazelcastManagedThread.java:76)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"hz.main.generic-operation.thread-32","threadId":55,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:85)\ncom.hazelcast.spi.imp l.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:118)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"hz.main.ascii.service.response","threadId":134688,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403)\ncom.hazelcast.internal.ascii.TextCommandServiceImpl$ResponseThreadRunnable.run(TextCommandServiceImpl.java:422)\njava.lang.Thread.run(Thread.java:748)"},{"threadName":"checkpoint-coordinator-1/911074782852677633","threadId":134542,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchron izer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088)\njava.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)\njava.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)\njava.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)\njava.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\njava.lang.Thread.run(Thread.java:748)"},{"threadName":"hz.main.generic-operation.thread-16","threadId":39,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.spi.impl.operat ionexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:85)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:118)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"pool-5-thread-1","threadId":86,"threadState":"TIMED_WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)\njava.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093)\njava.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)\njava.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)\njava.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)\njava.util.concurrent.ThreadP oolExecutor$Worker.run(ThreadPoolExecutor.java:624)\njava.lang.Thread.run(Thread.java:748)"},{"threadName":"hz.main.generic-operation.thread-20","threadId":43,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:85)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:118)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"Finalizer","threadId":3,"threadState":"WAITING","stackTrace":"java.lang.Object.wait(Native Method)\njava.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:144)\njava.lang.ref.ReferenceQueue. remove(ReferenceQueue.java:165)\njava.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:216)"},{"threadName":"seatunnel-coordinator-service-160","threadId":134234,"threadState":"TIMED_WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)\njava.util.concurrent.SynchronousQueue$TransferStack.awaitFulfill(SynchronousQueue.java:460)\njava.util.concurrent.SynchronousQueue$TransferStack.transfer(SynchronousQueue.java:362)\njava.util.concurrent.SynchronousQueue.poll(SynchronousQueue.java:941)\njava.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1073)\njava.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)\njava.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\njava.lang.Thread.run(Thread.java:748)"},{"threadName":"hz.main.generic-operation.thread-11","threadId":34,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\nja va.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:85)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:118)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"mysql-cj-abandoned-connection-cleanup","threadId":192,"threadState":"TIMED_WAITING","stackTrace":"java.lang.Object.wait(Native Method)\njava.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:144)\ncom.mysql.jdbc.AbandonedConnectionCleanupThread.run(AbandonedConnectionCleanupThread.java:80)\njava.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\njava.util.concurrent.ThreadPoolExecutor$Worker.run(Th readPoolExecutor.java:624)\njava.lang.Thread.run(Thread.java:748)"},{"threadName":"hz.main.cached.thread-6","threadId":134936,"threadState":"TIMED_WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)\njava.util.concurrent.SynchronousQueue$TransferStack.awaitFulfill(SynchronousQueue.java:460)\njava.util.concurrent.SynchronousQueue$TransferStack.transfer(SynchronousQueue.java:362)\njava.util.concurrent.SynchronousQueue.poll(SynchronousQueue.java:941)\njava.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1073)\njava.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)\njava.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\njava.lang.Thread.run(Thread.java:748)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.executeRun(HazelcastManagedThread.java:76)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedT hread.java:102)"},{"threadName":"checkpoint-coordinator-3/911074782852677633","threadId":134547,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088)\njava.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)\njava.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)\njava.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)\njava.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\njava.lang.Thread.run(Thread.java:748)"},{"threadName":"seatunnel-coordinator-service-162","threadId":134543,"threadState":"TIMED_WAITING","stackTrace":"sun.misc.Unsafe.park(Native Me thod)\njava.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)\njava.util.concurrent.SynchronousQueue$TransferStack.awaitFulfill(SynchronousQueue.java:460)\njava.util.concurrent.SynchronousQueue$TransferStack.transfer(SynchronousQueue.java:362)\njava.util.concurrent.SynchronousQueue.poll(SynchronousQueue.java:941)\njava.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1073)\njava.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)\njava.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\njava.lang.Thread.run(Thread.java:748)"},{"threadName":"event-forwarder-0","threadId":84,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403)\norg. apache.seatunnel.engine.server.EventService.lambda$initEventForwardService$2(EventService.java:64)\norg.apache.seatunnel.engine.server.EventService$$Lambda$1373/896945135.run(Unknown Source)\njava.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)\njava.util.concurrent.FutureTask.run(FutureTask.java:266)\njava.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\njava.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\njava.lang.Thread.run(Thread.java:748)"},{"threadName":"hz.main.generic-operation.thread-39","threadId":62,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(Op erationQueueImpl.java:85)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:118)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"checkpoint-coordinator-2/911074782852677633","threadId":134541,"threadState":"TIMED_WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)\njava.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093)\njava.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)\njava.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)\njava.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)\njava.util.concurrent.ThreadPoolExecutor $Worker.run(ThreadPoolExecutor.java:624)\njava.lang.Thread.run(Thread.java:748)"},{"threadName":"hz.main.generic-operation.thread-48","threadId":71,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:85)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:118)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"checkpoint-coordinator-3/911074782852677633","threadId":134540,"threadState":"TIMED_WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.parkNanos(LockSuppo rt.java:215)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)\njava.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093)\njava.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)\njava.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)\njava.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)\njava.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\njava.lang.Thread.run(Thread.java:748)"},{"threadName":"hz.main.generic-operation.thread-47","threadId":70,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQue ue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:85)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:118)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"hz.main.MetricsRegistry.thread-1","threadId":82,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088)\njava.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)\njava.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)\njava.util.concurrent.ThreadPoolExecutor. runWorker(ThreadPoolExecutor.java:1134)\njava.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\njava.lang.Thread.run(Thread.java:748)"},{"threadName":"hz.main.generic-operation.thread-37","threadId":60,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:85)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:118)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"hz.main.client.thread-3","threadId":113994,"threadState":"TIMED_WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method) \njava.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)\njava.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467)\njava.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1073)\njava.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)\njava.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\njava.lang.Thread.run(Thread.java:748)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.executeRun(HazelcastManagedThread.java:76)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"hz.main.generic-operation.thread-18","threadId":41,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.Abstract QueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:85)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:118)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"hz.main.response-1","threadId":17,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:304)\ncom.hazelcast.internal.util.concurrent.MPSCQueue.takeAll(MPSCQueue.java:229)\ncom.hazelcast.internal.util.concurrent.MPSCQueue.take(MPSCQueue.java:151)\ncom.hazelcast.spi.impl.operationservice.impl.InboundResponseHandlerSupplier$ResponseThread.doRun(InboundResponseHandlerSupplier.java:295)\ncom.hazelcast.spi.impl.operationservice.impl.InboundRespons eHandlerSupplier$ResponseThread.executeRun(InboundResponseHandlerSupplier.java:284)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"hz.main.cached.thread-10","threadId":134835,"threadState":"RUNNABLE","stackTrace":"java.lang.Thread.dumpThreads(Native Method)\njava.lang.Thread.getAllStackTraces(Thread.java:1610)\norg.apache.seatunnel.engine.server.rest.RestHttpGetCommandProcessor.getThreadDump(RestHttpGetCommandProcessor.java:210)\norg.apache.seatunnel.engine.server.rest.RestHttpGetCommandProcessor.handle(RestHttpGetCommandProcessor.java:149)\norg.apache.seatunnel.engine.server.rest.RestHttpGetCommandProcessor.handle(RestHttpGetCommandProcessor.java:98)\ncom.hazelcast.internal.ascii.TextCommandServiceImpl$CommandExecutor.run(TextCommandServiceImpl.java:402)\ncom.hazelcast.internal.util.executor.CachedExecutorServiceDelegate$Worker.run(CachedExecutorServiceDelegate.java:217)\njava.util.concurrent.ThreadPoolExecutor.run Worker(ThreadPoolExecutor.java:1149)\njava.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\njava.lang.Thread.run(Thread.java:748)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.executeRun(HazelcastManagedThread.java:76)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"hz.main.generic-operation.thread-27","threadId":50,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:85)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:118)\ncom.hazelcast.internal.util.executor. HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"hz.main.generic-operation.thread-14","threadId":37,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:85)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:118)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"hz.main.priority-generic-operation.thread-0","threadId":22,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent. locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:76)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:118)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"checkpoint-coordinator-1/911069562043105281","threadId":134233,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088)\njava.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledTh readPoolExecutor.java:809)\njava.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)\njava.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)\njava.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\njava.lang.Thread.run(Thread.java:748)"},{"threadName":"pool-4-thread-1","threadId":85,"threadState":"TIMED_WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)\njava.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093)\njava.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)\njava.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)\njava.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor. java:1134)\njava.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\njava.lang.Thread.run(Thread.java:748)"},{"threadName":"checkpoint-coordinator-1/911069562043105281","threadId":134226,"threadState":"TIMED_WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)\njava.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093)\njava.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)\njava.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)\njava.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)\njava.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\njava.lang.Thread.run(Thread.java:748)"},{"threadNam e":"hz.main.generic-operation.thread-49","threadId":72,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:85)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:118)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"hz.main.generic-operation.thread-22","threadId":45,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer .java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:85)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:118)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"hz.main.client.thread-2","threadId":109569,"threadState":"TIMED_WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)\njava.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467)\njava.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1073)\njava.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)\njava.util.concurrent.ThreadPoolExecutor$W orker.run(ThreadPoolExecutor.java:624)\njava.lang.Thread.run(Thread.java:748)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.executeRun(HazelcastManagedThread.java:76)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"Signal Dispatcher","threadId":5,"threadState":"RUNNABLE","stackTrace":""},{"threadName":"hz.main.TcpServer.thread-1","threadId":101,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088)\njava.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)\njava.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)\njava.util.c oncurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)\njava.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\njava.lang.Thread.run(Thread.java:748)"},{"threadName":"hz.main.TcpServer.thread-4","threadId":104,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088)\njava.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)\njava.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)\njava.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)\njava.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\njava.lang.Thread.run(Thread.j ava:748)"},{"threadName":"hz.main.generic-operation.thread-17","threadId":40,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:85)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:118)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"hz.main.generic-operation.thread-35","threadId":58,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(Abst ractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:85)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:118)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"hz.main.generic-operation.thread-38","threadId":61,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:85)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread .java:118)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"hz.main.IO.thread-in-1","threadId":94,"threadState":"RUNNABLE","stackTrace":"sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)\nsun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)\nsun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93)\nsun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)\nsun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)\ncom.hazelcast.internal.networking.nio.NioThread.selectLoop(NioThread.java:292)\ncom.hazelcast.internal.networking.nio.NioThread.executeRun(NioThread.java:249)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"hz.main.client.thread-4","threadId":109577,"threadState":"TIMED_WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)\njava.util.concurrent.lo cks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)\njava.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467)\njava.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1073)\njava.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)\njava.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\njava.lang.Thread.run(Thread.java:748)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.executeRun(HazelcastManagedThread.java:76)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"mysql-cj-abandoned-connection-cleanup","threadId":191,"threadState":"TIMED_WAITING","stackTrace":"java.lang.Object.wait(Native Method)\njava.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:144)\ncom.mysql.cj.jdbc.AbandonedConnectionCleanupThread.run(AbandonedConnectionCleanupThread.java:91)\njava.util.concurrent.ThreadPo olExecutor.runWorker(ThreadPoolExecutor.java:1149)\njava.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\njava.lang.Thread.run(Thread.java:748)"},{"threadName":"hz.main.response-0","threadId":16,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:304)\ncom.hazelcast.internal.util.concurrent.MPSCQueue.takeAll(MPSCQueue.java:229)\ncom.hazelcast.internal.util.concurrent.MPSCQueue.take(MPSCQueue.java:151)\ncom.hazelcast.spi.impl.operationservice.impl.InboundResponseHandlerSupplier$ResponseThread.doRun(InboundResponseHandlerSupplier.java:295)\ncom.hazelcast.spi.impl.operationservice.impl.InboundResponseHandlerSupplier$ResponseThread.executeRun(InboundResponseHandlerSupplier.java:284)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"hz.main.InvocationMonitorThread","threadId":89,"threadState":"TIMED_WAITING","stack Trace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)\njava.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093)\njava.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)\njava.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)\njava.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)\njava.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\njava.lang.Thread.run(Thread.java:748)"},{"threadName":"hz.main.event-2","threadId":75,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject. await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.internal.util.executor.StripedExecutor$Worker.run(StripedExecutor.java:227)"},{"threadName":"hz.main.event-1","threadId":74,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.internal.util.executor.StripedExecutor$Worker.run(StripedExecutor.java:227)"},{"threadName":"hz.main.generic-operation.thread-45","threadId":68,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer. java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:85)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:118)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"hz.main.generic-operation.thread-4","threadId":27,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:85)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:118)\ncom.hazelcas t.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"hz.main.IO.thread-out-1","threadId":97,"threadState":"RUNNABLE","stackTrace":"sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)\nsun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)\nsun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93)\nsun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)\nsun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)\ncom.hazelcast.internal.networking.nio.NioThread.selectLoop(NioThread.java:292)\ncom.hazelcast.internal.networking.nio.NioThread.executeRun(NioThread.java:249)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"hz.main.generic-operation.thread-44","threadId":67,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchron izer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:85)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:118)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"checkpoint-coordinator-1/911074782852677633","threadId":134539,"threadState":"TIMED_WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)\njava.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093)\njava.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExec utor.java:809)\njava.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)\njava.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)\njava.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\njava.lang.Thread.run(Thread.java:748)"},{"threadName":"hz.main.generic-operation.thread-21","threadId":44,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:85)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:118)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{" threadName":"hz.main.generic-operation.thread-29","threadId":52,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:85)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:118)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"hz.main.generic-operation.thread-46","threadId":69,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSyn chronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:85)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:118)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"Reference Handler","threadId":2,"threadState":"WAITING","stackTrace":"java.lang.Object.wait(Native Method)\njava.lang.Object.wait(Object.java:502)\njava.lang.ref.Reference.tryHandlePending(Reference.java:191)\njava.lang.ref.Reference$ReferenceHandler.run(Reference.java:153)"},{"threadName":"hz.main.partition-operation.thread-3","threadId":21,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:304)\ncom.hazelcast.internal.util.concurrent.MPSCQueue.takeAll(MPSCQueue.java:229)\ncom.hazelcast.interna l.util.concurrent.MPSCQueue.take(MPSCQueue.java:151)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:85)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:118)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"hz.main.generic-operation.thread-13","threadId":36,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:85)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:118)\ncom.hazelcast.internal.util.executor.Hazelcast ManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"hz.main.IO.thread-out-0","threadId":96,"threadState":"RUNNABLE","stackTrace":"sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)\nsun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)\nsun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93)\nsun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)\nsun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)\ncom.hazelcast.internal.networking.nio.NioThread.selectLoop(NioThread.java:292)\ncom.hazelcast.internal.networking.nio.NioThread.executeRun(NioThread.java:249)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"main-NioNetworking-closeListenerExecutor","threadId":210,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(A bstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\njava.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)\njava.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)\njava.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\njava.lang.Thread.run(Thread.java:748)"},{"threadName":"Log4j2-TF-1-AsyncLogger[AsyncContext@7440e464]-1","threadId":11,"threadState":"TIMED_WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)\ncom.lmax.disruptor.TimeoutBlockingWaitStrategy.waitFor(TimeoutBlockingWaitStrategy.java:38)\ncom.lmax.disruptor.ProcessingSequenceBarrier.waitFor(ProcessingSequenceBarrier.java:56)\ncom.lmax.disruptor.BatchEventProcessor.processEvents(BatchEventProc essor.java:159)\ncom.lmax.disruptor.BatchEventProcessor.run(BatchEventProcessor.java:125)\njava.lang.Thread.run(Thread.java:748)"},{"threadName":"hz.main.IO.thread-in-2","threadId":95,"threadState":"RUNNABLE","stackTrace":"sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)\nsun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)\nsun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93)\nsun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)\nsun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)\ncom.hazelcast.internal.networking.nio.NioThread.selectLoop(NioThread.java:292)\ncom.hazelcast.internal.networking.nio.NioThread.executeRun(NioThread.java:249)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"hz.main.generic-operation.thread-12","threadId":35,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.u til.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:85)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:118)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"org.apache.hadoop.fs.FileSystem$Statistics$StatisticsDataReferenceCleaner","threadId":87,"threadState":"WAITING","stackTrace":"java.lang.Object.wait(Native Method)\njava.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:144)\njava.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:165)\norg.apache.hadoop.fs.FileSystem$Statistics$StatisticsDataReferenceCleaner.run(FileSystem.java:3760)\njava.lang.Thread.run(Thread.java:748)"},{"threadName":"hz.main.TcpServer.thread-3","threadId":103,"threadSta te":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088)\njava.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)\njava.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)\njava.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)\njava.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\njava.lang.Thread.run(Thread.java:748)"},{"threadName":"hz.main.generic-operation.thread-26","threadId":49,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueue dSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:85)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:118)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"hz.main.generic-operation.thread-8","threadId":31,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:85)\ncom.hazelcast.spi.impl.operationexecutor.impl.Ope rationThread.executeRun(OperationThread.java:118)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"hz.main.generic-operation.thread-23","threadId":46,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:85)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:118)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"Log4j2-TF-4-Scheduled-3","threadId":120,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurren t.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088)\njava.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)\njava.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)\njava.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)\njava.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\njava.lang.Thread.run(Thread.java:748)"},{"threadName":"hz.main.generic-operation.thread-3","threadId":26,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)\njava.util. concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl.take(OperationQueueImpl.java:85)\ncom.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:118)\ncom.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)"},{"threadName":"seatunnel-coordinator-service-158","threadId":134224,"threadState":"WAITING","stackTrace":"sun.misc.Unsafe.park(Native Method)\njava.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\njava.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1693)\njava.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3323)\njava.util.concurrent.CompletableFuture.waitingGet(CompletableFuture.java:1729)\njava.util.concurrent.CompletableFuture.join(CompletableFuture.java:1934)\norg.apache.seatunnel.engine.server.master.JobMaster.run(JobMaster.java:357)\norg.apache.seatunnel.engine.server .CoordinatorService.lambda$submitJob$4(CoordinatorService.java:522)\norg.apache.seatunnel.engine.server.CoordinatorService$$Lambda$1622/1503620943.run(Unknown Source)\norg.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:39)\njava.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)\njava.util.concurrent.FutureTask.run(FutureTask.java:266) ``` ### Error Exception ```log http://10.19.11.19:5801/hazelcast/rest/maps/job-info/911069562043105281 {"status":"fail"} http://10.19.11.19:5803/hazelcast/rest/maps/running-jobs {"status":"fail"} http://10.19.11.19:5801/hazelcast/rest/maps/thread-dump ``` ### Zeta or Flink or Spark Version _No response_ ### Java or Scala Version _No response_ ### Screenshots _No response_ ### Are you willing to submit PR? - [ ] Yes I am willing to submit a PR! ### Code of Conduct - [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
