xxyykkxx opened a new issue, #8168: URL: https://github.com/apache/seatunnel/issues/8168
### 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 an exception occurs in a job,the job status is running,then when cancel the job,the job status while always canceling ### SeaTunnel Version 2.3.8 ### SeaTunnel Config ```conf { "env": { "job.mode": "BATCH", "checkpoint.interval": 8000 }, "source": [ { "plugin_name": "Elasticsearch", "result_table_name": "public_es_source", "hosts": [ "10.xxx.xxx.xxx:9200" ], "username": "", "password": "", "index": "basicdata-gis-log", "scroll_size": 800, "schema": { "columns": [ { "name": "threadName", "type": "string" }, { "name": "logLevel", "type": "string" }, { "name": "@version", "type": "string" }, { "name": "logAppenderTime", "type": "string" }, { "name": "message", "type": "string" }, { "name": "captainWorkerNo", "type": "string" }, { "name": "captainEmail", "type": "string" }, { "name": "captainName", "type": "string" }, { "name": "packageName", "type": "string" }, { "name": "appId", "type": "string" }, { "name": "hostName", "type": "string" }, { "name": "@timestamp", "type": "timestamp" }, { "name": "captainMobilePhone", "type": "string" } ] } } ], "sink": [ { "plugin_name": "Doris", "source_table_name": "public_es_sink", "fenodes": "10.xxx.xx.xx:8035", "database": "test", "table": "ods_basicdata_gis_log", "password": "", "username": "", "doris.batch.size": 524288, "sink.buffer-size": 524288, "doris.config": { "format": "json", "read_json_by_line": "true" } } ] } ``` ### Running Command ```shell bin/seatunnel.sh -can ${jobId} ``` ### Error Exception ```log 2024-11-25 20:34:48,758 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-23] - [10.117.233.186]:5802 [seatunnel-cluster] [5.1] received deploying task executionId [913407264055230465] 2024-11-25 20:34:48,758 INFO [.c.c.DefaultClassLoaderService] [hz.main.generic-operation.thread-23] - Create classloader for job 913407264055099393 with jars [file:/opt/seatunnel/connectors/connector-elasticsearch-2.3.8-SNAPSHOT.jar, file:/opt/seatunnel/connectors/seatunnel-transforms-v2-2.3.8-SNAPSHOT.jar] 2024-11-25 20:34:48,772 INFO [.c.c.DefaultClassLoaderService] [hz.main.generic-operation.thread-23] - Create classloader for job 913407264055099393 with jars [file:/opt/seatunnel/connectors/connector-doris-2.3.8-SNAPSHOT.jar] 2024-11-25 20:34:48,779 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-23] - [10.117.233.186]:5802 [seatunnel-cluster] [5.1] deploying task TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}, executionId [913407264055230465] 2024-11-25 20:34:48,779 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-23] - [10.117.233.186]:5802 [seatunnel-cluster] [5.1] deploying TaskGroup TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000} init success 2024-11-25 20:34:48,780 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-23] - [10.117.233.186]:5802 [seatunnel-cluster] [5.1] deploying TaskGroup TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000} success 2024-11-25 20:34:48,787 INFO [.a.s.e.s.t.SourceSeaTunnelTask] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - starting seatunnel source task, index 0 2024-11-25 20:34:48,838 INFO [s.e.s.t.TransformSeaTunnelTask] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - starting seatunnel transform task, index 0 2024-11-25 20:34:49,069 INFO [o.a.s.c.d.s.w.DorisSinkWriter ] [hz.main.seaTunnel.task.thread-1] - restore checkpointId 0 2024-11-25 20:34:49,069 INFO [o.a.s.c.d.s.w.DorisSinkWriter ] [hz.main.seaTunnel.task.thread-1] - labelPrefix public_es_sink 2024-11-25 20:34:49,083 INFO [o.a.s.c.d.s.w.RecordBuffer ] [hz.main.seaTunnel.task.thread-1] - init RecordBuffer capacity 262144, count 1 2024-11-25 20:34:50,782 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-32] - [10.117.233.186]:5802 [seatunnel-cluster] [5.1] Task (TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}) need cancel. 2024-11-25 20:34:50,782 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - [10.117.233.186]:5802 [seatunnel-cluster] [5.1] Interrupted task 50000 - org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask@7e58b94 2024-11-25 20:34:50,782 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - [10.117.233.186]:5802 [seatunnel-cluster] [5.1] taskDone, taskId = 50000, taskGroup = TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000} 2024-11-25 20:34:50,782 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - [10.117.233.186]:5802 [seatunnel-cluster] [5.1] Interrupted task 40000 - org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask@4b8e6a68 2024-11-25 20:34:50,782 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - [10.117.233.186]:5802 [seatunnel-cluster] [5.1] taskDone, taskId = 40000, taskGroup = TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000} 2024-11-25 20:34:50,782 INFO [.c.c.DefaultClassLoaderService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - Release classloader for job 913407264055099393 with jars [file:/opt/seatunnel/connectors/connector-elasticsearch-2.3.8-SNAPSHOT.jar, file:/opt/seatunnel/connectors/seatunnel-transforms-v2-2.3.8-SNAPSHOT.jar] 2024-11-25 20:34:50,785 INFO [.c.c.DefaultClassLoaderService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - recycle classloader for thread pool-17-thread-1 2024-11-25 20:34:50,785 INFO [.c.c.DefaultClassLoaderService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - recycle classloader for thread BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000} 2024-11-25 20:34:50,785 INFO [.c.c.DefaultClassLoaderService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - recycle classloader for thread I/O dispatcher 1 2024-11-25 20:34:50,785 INFO [.c.c.DefaultClassLoaderService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - Release classloader for job 913407264055099393 with jars [file:/opt/seatunnel/connectors/connector-doris-2.3.8-SNAPSHOT.jar] 2024-11-25 20:34:50,787 INFO [.c.c.DefaultClassLoaderService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - recycle classloader for thread hz.main.seaTunnel.task.thread-2 2024-11-25 20:34:50,787 INFO [.c.c.DefaultClassLoaderService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - recycle classloader for thread ForkJoinPool.commonPool-worker-0 2024-11-25 20:34:50,800 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - [10.117.233.186]:5802 [seatunnel-cluster] [5.1] taskGroup TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000} complete with CANCELED 2024-11-25 20:34:50,800 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.seaTunnel.task.thread-2] - [10.117.233.186]:5802 [seatunnel-cluster] [5.1] Task TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000} complete with state CANCELED 2024-11-25 20:34:50,802 INFO [a.s.e.s.s.s.DefaultSlotService] [hz.main.generic-operation.thread-33] - received slot release request, jobID: 913407264055099393, slot: SlotProfile{worker=[10.117.233.186]:5802, slotID=5, ownerJobID=913407264055099393, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='ed123ee6-9449-4296-aa56-f1f957e53d19'} 2024-11-25 20:34:53,815 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-39] - [10.117.233.186]:5802 [seatunnel-cluster] [5.1] received deploying task executionId [913407264055296001] 2024-11-25 20:34:53,815 INFO [.c.c.DefaultClassLoaderService] [hz.main.generic-operation.thread-39] - Create classloader for job 913407264055099393 with jars [file:/opt/seatunnel/connectors/connector-elasticsearch-2.3.8-SNAPSHOT.jar] 2024-11-25 20:34:53,822 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-39] - [10.117.233.186]:5802 [seatunnel-cluster] [5.1] deploying task TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=1}, executionId [913407264055296001] 2024-11-25 20:34:53,822 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-39] - [10.117.233.186]:5802 [seatunnel-cluster] [5.1] deploying TaskGroup TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=1} init success 2024-11-25 20:34:53,823 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-39] - [10.117.233.186]:5802 [seatunnel-cluster] [5.1] deploying TaskGroup TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=1} success 2024-11-25 20:34:53,824 INFO [.s.t.SourceSplitEnumeratorTask] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=1}] - starting seatunnel source split enumerator task, source name: pipeline-1 [Source[0]-Elasticsearch] 2024-11-25 20:34:53,826 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-41] - [10.117.233.186]:5802 [seatunnel-cluster] [5.1] received deploying task executionId [913407264055361537] 2024-11-25 20:34:53,827 INFO [.c.c.DefaultClassLoaderService] [hz.main.generic-operation.thread-41] - Create classloader for job 913407264055099393 with jars [file:/opt/seatunnel/connectors/connector-elasticsearch-2.3.8-SNAPSHOT.jar, file:/opt/seatunnel/connectors/seatunnel-transforms-v2-2.3.8-SNAPSHOT.jar] 2024-11-25 20:34:53,840 INFO [.c.c.DefaultClassLoaderService] [hz.main.generic-operation.thread-41] - Create classloader for job 913407264055099393 with jars [file:/opt/seatunnel/connectors/connector-doris-2.3.8-SNAPSHOT.jar] 2024-11-25 20:34:53,846 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-41] - [10.117.233.186]:5802 [seatunnel-cluster] [5.1] deploying task TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}, executionId [913407264055361537] 2024-11-25 20:34:53,846 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-41] - [10.117.233.186]:5802 [seatunnel-cluster] [5.1] deploying TaskGroup TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000} init success 2024-11-25 20:34:53,846 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-41] - [10.117.233.186]:5802 [seatunnel-cluster] [5.1] deploying TaskGroup TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000} success 2024-11-25 20:34:53,858 INFO [.a.s.e.s.t.SourceSeaTunnelTask] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - starting seatunnel source task, index 0 2024-11-25 20:34:53,921 INFO [s.e.s.t.TransformSeaTunnelTask] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - starting seatunnel transform task, index 0 2024-11-25 20:34:54,094 INFO [.s.t.SourceSplitEnumeratorTask] [hz.main.seaTunnel.task.thread-5] - received reader register, readerID: TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}, taskID=40000, index=0} 2024-11-25 20:34:54,146 INFO [o.a.s.c.d.s.w.DorisSinkWriter ] [hz.main.seaTunnel.task.thread-4] - restore checkpointId 0 2024-11-25 20:34:54,146 INFO [o.a.s.c.d.s.w.DorisSinkWriter ] [hz.main.seaTunnel.task.thread-4] - labelPrefix public_es_sink 2024-11-25 20:34:54,160 INFO [o.a.s.c.d.s.w.RecordBuffer ] [hz.main.seaTunnel.task.thread-4] - init RecordBuffer capacity 262144, count 1 2024-11-25 20:35:29,363 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-32] - [10.117.233.186]:5802 [seatunnel-cluster] [5.1] Task (TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=1}) need cancel. 2024-11-25 20:35:29,364 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=1}] - [10.117.233.186]:5802 [seatunnel-cluster] [5.1] Interrupted task 20000 - org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask@202889cc 2024-11-25 20:35:29,364 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=1}] - [10.117.233.186]:5802 [seatunnel-cluster] [5.1] taskDone, taskId = 20000, taskGroup = TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=1} 2024-11-25 20:35:29,364 INFO [.c.c.DefaultClassLoaderService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=1}] - Release classloader for job 913407264055099393 with jars [file:/opt/seatunnel/connectors/connector-elasticsearch-2.3.8-SNAPSHOT.jar] 2024-11-25 20:35:29,368 INFO [.c.c.DefaultClassLoaderService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=1}] - recycle classloader for thread BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=1} 2024-11-25 20:35:29,379 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-37] - [10.117.233.186]:5802 [seatunnel-cluster] [5.1] Task (TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}) need cancel. 2024-11-25 20:35:29,379 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - [10.117.233.186]:5802 [seatunnel-cluster] [5.1] Interrupted task 50000 - org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask@5383daa2 2024-11-25 20:35:29,379 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - [10.117.233.186]:5802 [seatunnel-cluster] [5.1] taskDone, taskId = 50000, taskGroup = TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000} 2024-11-25 20:35:29,380 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - [10.117.233.186]:5802 [seatunnel-cluster] [5.1] Interrupted task 40000 - org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask@248ee7ed 2024-11-25 20:35:29,380 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - [10.117.233.186]:5802 [seatunnel-cluster] [5.1] taskDone, taskId = 40000, taskGroup = TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000} 2024-11-25 20:35:29,380 INFO [.c.c.DefaultClassLoaderService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - Release classloader for job 913407264055099393 with jars [file:/opt/seatunnel/connectors/connector-elasticsearch-2.3.8-SNAPSHOT.jar, file:/opt/seatunnel/connectors/seatunnel-transforms-v2-2.3.8-SNAPSHOT.jar] 2024-11-25 20:35:29,384 INFO [.c.c.DefaultClassLoaderService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - recycle classloader for thread pool-21-thread-1 2024-11-25 20:35:29,384 INFO [.c.c.DefaultClassLoaderService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - recycle classloader for thread BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000} 2024-11-25 20:35:29,384 INFO [.c.c.DefaultClassLoaderService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - recycle classloader for thread I/O dispatcher 1 2024-11-25 20:35:29,384 INFO [.c.c.DefaultClassLoaderService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - Release classloader for job 913407264055099393 with jars [file:/opt/seatunnel/connectors/connector-doris-2.3.8-SNAPSHOT.jar] 2024-11-25 20:35:29,385 INFO [.c.c.DefaultClassLoaderService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - recycle classloader for thread ForkJoinPool.commonPool-worker-1 2024-11-25 20:35:29,386 INFO [.c.c.DefaultClassLoaderService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - recycle classloader for thread hz.main.seaTunnel.task.thread-1 2024-11-25 20:35:29,392 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=1}] - [10.117.233.186]:5802 [seatunnel-cluster] [5.1] taskGroup TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=1} complete with CANCELED 2024-11-25 20:35:29,392 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.seaTunnel.task.thread-1] - [10.117.233.186]:5802 [seatunnel-cluster] [5.1] Task TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=1} complete with state CANCELED 2024-11-25 20:35:29,398 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - [10.117.233.186]:5802 [seatunnel-cluster] [5.1] taskGroup TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000} complete with CANCELED 2024-11-25 20:35:29,399 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.seaTunnel.task.thread-2] - [10.117.233.186]:5802 [seatunnel-cluster] [5.1] Task TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000} complete with state CANCELED 2024-11-25 20:35:29,401 INFO [a.s.e.s.s.s.DefaultSlotService] [hz.main.generic-operation.thread-39] - received slot release request, jobID: 913407264055099393, slot: SlotProfile{worker=[10.117.233.186]:5802, slotID=7, ownerJobID=913407264055099393, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='ed123ee6-9449-4296-aa56-f1f957e53d19'} 2024-11-25 20:35:48,482 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-25] - [10.117.173.92]:5802 [seatunnel-cluster] [5.1] received deploying task executionId [913407264055558145] 2024-11-25 20:35:48,482 INFO [.c.c.DefaultClassLoaderService] [hz.main.generic-operation.thread-25] - Create classloader for job 913407264055099393 with jars [file:/opt/seatunnel/connectors/connector-elasticsearch-2.3.8-SNAPSHOT.jar] 2024-11-25 20:35:48,492 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-25] - [10.117.173.92]:5802 [seatunnel-cluster] [5.1] deploying task TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=1}, executionId [913407264055558145] 2024-11-25 20:35:48,492 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-25] - [10.117.173.92]:5802 [seatunnel-cluster] [5.1] deploying TaskGroup TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=1} init success 2024-11-25 20:35:48,493 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-25] - [10.117.173.92]:5802 [seatunnel-cluster] [5.1] deploying TaskGroup TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=1} success 2024-11-25 20:35:48,494 INFO [.s.t.SourceSplitEnumeratorTask] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=1}] - starting seatunnel source split enumerator task, source name: pipeline-1 [Source[0]-Elasticsearch] 2024-11-25 20:35:48,496 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-26] - [10.117.173.92]:5802 [seatunnel-cluster] [5.1] received deploying task executionId [913407264055623681] 2024-11-25 20:35:48,497 INFO [.c.c.DefaultClassLoaderService] [hz.main.generic-operation.thread-26] - Create classloader for job 913407264055099393 with jars [file:/opt/seatunnel/connectors/connector-elasticsearch-2.3.8-SNAPSHOT.jar, file:/opt/seatunnel/connectors/seatunnel-transforms-v2-2.3.8-SNAPSHOT.jar] 2024-11-25 20:35:48,509 INFO [.c.c.DefaultClassLoaderService] [hz.main.generic-operation.thread-26] - Create classloader for job 913407264055099393 with jars [file:/opt/seatunnel/connectors/connector-doris-2.3.8-SNAPSHOT.jar] 2024-11-25 20:35:48,515 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-26] - [10.117.173.92]:5802 [seatunnel-cluster] [5.1] deploying task TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}, executionId [913407264055623681] 2024-11-25 20:35:48,515 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-26] - [10.117.173.92]:5802 [seatunnel-cluster] [5.1] deploying TaskGroup TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000} init success 2024-11-25 20:35:48,516 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-26] - [10.117.173.92]:5802 [seatunnel-cluster] [5.1] deploying TaskGroup TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000} success 2024-11-25 20:35:48,524 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-29] - [10.117.173.92]:5802 [seatunnel-cluster] [5.1] Task (TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=1}) need cancel. 2024-11-25 20:35:48,524 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=1}] - [10.117.173.92]:5802 [seatunnel-cluster] [5.1] Interrupted task 20000 - org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask@4fe605c4 2024-11-25 20:35:48,524 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=1}] - [10.117.173.92]:5802 [seatunnel-cluster] [5.1] taskDone, taskId = 20000, taskGroup = TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=1} 2024-11-25 20:35:48,524 INFO [.c.c.DefaultClassLoaderService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=1}] - Release classloader for job 913407264055099393 with jars [file:/opt/seatunnel/connectors/connector-elasticsearch-2.3.8-SNAPSHOT.jar] 2024-11-25 20:35:48,527 INFO [.c.c.DefaultClassLoaderService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=1}] - recycle classloader for thread BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=1} 2024-11-25 20:35:48,528 INFO [.a.s.e.s.t.SourceSeaTunnelTask] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - starting seatunnel source task, index 0 2024-11-25 20:35:48,530 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-31] - [10.117.173.92]:5802 [seatunnel-cluster] [5.1] Task (TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}) need cancel. 2024-11-25 20:35:48,534 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=1}] - [10.117.173.92]:5802 [seatunnel-cluster] [5.1] taskGroup TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=1} complete with CANCELED 2024-11-25 20:35:48,535 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.seaTunnel.task.thread-6] - [10.117.173.92]:5802 [seatunnel-cluster] [5.1] Task TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=1} complete with state CANCELED 2024-11-25 20:35:48,537 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - [10.117.173.92]:5802 [seatunnel-cluster] [5.1] taskDone, taskId = 40000, taskGroup = TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000} 2024-11-25 20:35:48,537 ERROR [e.s.t.f.TransformFlowLifeCycle] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - Close transform: Sql failed, cause: null java.lang.NullPointerException: null at org.apache.seatunnel.transform.sql.SQLTransform.close(SQLTransform.java:184) ~[?:?] at org.apache.seatunnel.engine.server.task.flow.TransformFlowLifeCycle.close(TransformFlowLifeCycle.java:119) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at org.apache.seatunnel.engine.server.task.SeaTunnelTask.lambda$close$189(SeaTunnelTask.java:330) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) ~[?:1.8.0_342] at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384) ~[?:1.8.0_342] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482) ~[?:1.8.0_342] at java.util.stream.ForEachOps$ForEachTask.compute(ForEachOps.java:290) ~[?:1.8.0_342] at java.util.concurrent.CountedCompleter.exec(CountedCompleter.java:731) ~[?:1.8.0_342] at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) ~[?:1.8.0_342] at java.util.concurrent.ForkJoinTask.doInvoke(ForkJoinTask.java:401) ~[?:1.8.0_342] at java.util.concurrent.ForkJoinTask.invoke(ForkJoinTask.java:734) ~[?:1.8.0_342] at java.util.stream.ForEachOps$ForEachOp.evaluateParallel(ForEachOps.java:159) ~[?:1.8.0_342] at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateParallel(ForEachOps.java:173) ~[?:1.8.0_342] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:233) ~[?:1.8.0_342] at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485) ~[?:1.8.0_342] at java.util.stream.ReferencePipeline$Head.forEach(ReferencePipeline.java:650) ~[?:1.8.0_342] at org.apache.seatunnel.engine.server.task.SeaTunnelTask.close(SeaTunnelTask.java:327) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:710) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at org.apache.seatunnel.engine.server.TaskExecutionService$NamedTaskWrapper.run(TaskExecutionService.java:1018) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:39) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[?:1.8.0_342] at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_342] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_342] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_342] at java.lang.Thread.run(Thread.java:750) [?:1.8.0_342] 2024-11-25 20:35:48,588 INFO [s.e.s.t.TransformSeaTunnelTask] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - starting seatunnel transform task, index 0 2024-11-25 20:35:48,589 WARN [c.h.i.s.t.TcpServerConnection ] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - [10.117.173.92]:5802 [seatunnel-cluster] [5.1] Connection[id=1, /10.117.173.92:38402->/10.130.134.79:5801, qualifier=null, endpoint=[10.117.233.188]:5801, remoteUuid=cca4c50d-e9a8-4de3-a277-7cd9213cc537, alive=false, connectionType=MEMBER, planeIndex=0] closed. Reason: Exception in Connection[id=1, /10.117.173.92:38402->/10.130.134.79:5801, qualifier=null, endpoint=[10.117.233.188]:5801, remoteUuid=cca4c50d-e9a8-4de3-a277-7cd9213cc537, alive=true, connectionType=MEMBER, planeIndex=0], thread=BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000} java.nio.channels.ClosedByInterruptException: null at java.nio.channels.spi.AbstractInterruptibleChannel.end(AbstractInterruptibleChannel.java:202) ~[?:1.8.0_342] at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:477) ~[?:1.8.0_342] at com.hazelcast.internal.networking.nio.NioOutboundPipeline.flushToSocket(NioOutboundPipeline.java:439) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at com.hazelcast.internal.networking.nio.NioOutboundPipeline.process(NioOutboundPipeline.java:324) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at com.hazelcast.internal.networking.nio.NioOutboundPipeline.executePipeline(NioOutboundPipeline.java:240) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at com.hazelcast.internal.networking.nio.NioOutboundPipeline.write(NioOutboundPipeline.java:218) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at com.hazelcast.internal.networking.nio.NioChannel.write(NioChannel.java:79) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at com.hazelcast.internal.server.tcp.TcpServerConnection.write(TcpServerConnection.java:222) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at com.hazelcast.spi.impl.operationservice.impl.OutboundOperationHandler.send(OutboundOperationHandler.java:59) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at com.hazelcast.spi.impl.operationservice.impl.Invocation.doInvokeRemote(Invocation.java:612) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at com.hazelcast.spi.impl.operationservice.impl.Invocation.doInvoke(Invocation.java:582) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at com.hazelcast.spi.impl.operationservice.impl.Invocation.invoke0(Invocation.java:541) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at com.hazelcast.spi.impl.operationservice.impl.Invocation.invokeAsync(Invocation.java:246) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at com.hazelcast.spi.impl.operationservice.impl.InvocationBuilderImpl.invoke(InvocationBuilderImpl.java:60) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at org.apache.seatunnel.engine.server.utils.NodeEngineUtil.sendOperationToMasterNode(NodeEngineUtil.java:42) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at org.apache.seatunnel.engine.server.execution.TaskExecutionContext.sendToMaster(TaskExecutionContext.java:49) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at org.apache.seatunnel.engine.server.task.AbstractTask.reportTaskStatus(AbstractTask.java:110) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:144) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.call(TransformSeaTunnelTask.java:78) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:693) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at org.apache.seatunnel.engine.server.TaskExecutionService$NamedTaskWrapper.run(TaskExecutionService.java:1018) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:39) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[?:1.8.0_342] at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_342] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_342] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_342] at java.lang.Thread.run(Thread.java:750) [?:1.8.0_342] 2024-11-25 20:36:49,325 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - [10.117.173.92]:5802 [seatunnel-cluster] [5.1] Exception in org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask@3a2bb458 java.util.concurrent.CompletionException: com.hazelcast.core.OperationTimeoutException: TaskReportStatusOperation invocation failed to complete due to operation-heartbeat-timeout. Current time: 2024-11-25 20:36:49.325. Start time: 2024-11-25 20:35:48.588. Total elapsed time: 60737 ms. Last operation heartbeat: never. Last operation heartbeat from member: 2024-11-25 20:36:41.823. Invocation{op=org.apache.seatunnel.engine.server.checkpoint.operation.TaskReportStatusOperation{serviceName='st:impl:seaTunnelServer', identityHash=306183790, partitionId=-1, replicaIndex=0, callId=-145, invocationTime=1732537990031 (2024-11-25 20:33:10.031), waitTimeout=-1, callTimeout=60000, tenantControl=com.hazelcast.spi.impl.tenantcontrol.NoopTenantControl@0}, tryCount=20, tryPauseMillis=500, invokeCount=1, callTimeoutMillis=60000, firstInvocationTimeMs=1732538148588, firstInvocationTime='2024-11-25 20:35:48.588', lastHeartbeatMillis=0, lastHeartbeatTime='1970-01-01 08:00:00.000', target=[10.117.233.1 88]:5801, pendingResponse={VOID}, backupsAcksExpected=-1, backupsAcksReceived=0, connection=Connection[id=1, /10.117.173.92:38402->/10.130.134.79:5801, qualifier=null, endpoint=[10.117.233.188]:5801, remoteUuid=cca4c50d-e9a8-4de3-a277-7cd9213cc537, alive=false, connectionType=MEMBER, planeIndex=0]} at com.hazelcast.spi.impl.AbstractInvocationFuture.returnOrThrowWithJoinConventions(AbstractInvocationFuture.java:819) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at com.hazelcast.spi.impl.AbstractInvocationFuture.resolveAndThrowWithJoinConvention(AbstractInvocationFuture.java:835) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at com.hazelcast.spi.impl.AbstractInvocationFuture.join(AbstractInvocationFuture.java:553) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at org.apache.seatunnel.engine.server.task.AbstractTask.reportTaskStatus(AbstractTask.java:111) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:144) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.call(TransformSeaTunnelTask.java:78) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:693) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at org.apache.seatunnel.engine.server.TaskExecutionService$NamedTaskWrapper.run(TaskExecutionService.java:1018) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:39) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[?:1.8.0_342] at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_342] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_342] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_342] at java.lang.Thread.run(Thread.java:750) [?:1.8.0_342] Caused by: com.hazelcast.core.OperationTimeoutException: TaskReportStatusOperation invocation failed to complete due to operation-heartbeat-timeout. Current time: 2024-11-25 20:36:49.325. Start time: 2024-11-25 20:35:48.588. Total elapsed time: 60737 ms. Last operation heartbeat: never. Last operation heartbeat from member: 2024-11-25 20:36:41.823. Invocation{op=org.apache.seatunnel.engine.server.checkpoint.operation.TaskReportStatusOperation{serviceName='st:impl:seaTunnelServer', identityHash=306183790, partitionId=-1, replicaIndex=0, callId=-145, invocationTime=1732537990031 (2024-11-25 20:33:10.031), waitTimeout=-1, callTimeout=60000, tenantControl=com.hazelcast.spi.impl.tenantcontrol.NoopTenantControl@0}, tryCount=20, tryPauseMillis=500, invokeCount=1, callTimeoutMillis=60000, firstInvocationTimeMs=1732538148588, firstInvocationTime='2024-11-25 20:35:48.588', lastHeartbeatMillis=0, lastHeartbeatTime='1970-01-01 08:00:00.000', target=[10.117.233.188]:5801, pendingResponse={VOID }, backupsAcksExpected=-1, backupsAcksReceived=0, connection=Connection[id=1, /10.117.173.92:38402->/10.130.134.79:5801, qualifier=null, endpoint=[10.117.233.188]:5801, remoteUuid=cca4c50d-e9a8-4de3-a277-7cd9213cc537, alive=false, connectionType=MEMBER, planeIndex=0]} at com.hazelcast.spi.impl.operationservice.impl.InvocationFuture.newOperationTimeoutException(InvocationFuture.java:194) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at com.hazelcast.spi.impl.operationservice.impl.InvocationFuture.resolve(InvocationFuture.java:136) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at com.hazelcast.spi.impl.AbstractInvocationFuture.resolveAndThrowWithJoinConvention(AbstractInvocationFuture.java:834) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] ... 12 more 2024-11-25 20:36:49,325 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - [10.117.173.92]:5802 [seatunnel-cluster] [5.1] taskDone, taskId = 50000, taskGroup = TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000} 2024-11-25 20:36:49,326 INFO [.c.c.DefaultClassLoaderService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - Release classloader for job 913407264055099393 with jars [file:/opt/seatunnel/connectors/connector-elasticsearch-2.3.8-SNAPSHOT.jar, file:/opt/seatunnel/connectors/seatunnel-transforms-v2-2.3.8-SNAPSHOT.jar] 2024-11-25 20:36:49,327 INFO [.c.c.DefaultClassLoaderService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - Release classloader for job 913407264055099393 with jars [file:/opt/seatunnel/connectors/connector-doris-2.3.8-SNAPSHOT.jar] 2024-11-25 20:36:49,329 INFO [.c.c.DefaultClassLoaderService] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - recycle classloader for thread BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000} 2024-11-25 20:36:49,329 WARN [c.h.i.s.t.TcpServerConnection ] [BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000}] - [10.117.173.92]:5802 [seatunnel-cluster] [5.1] Connection[id=4, /10.117.173.92:5802->/10.117.233.188:38197, qualifier=null, endpoint=[10.117.233.188]:5801, remoteUuid=cca4c50d-e9a8-4de3-a277-7cd9213cc537, alive=false, connectionType=MEMBER, planeIndex=0] closed. Reason: Exception in Connection[id=4, /10.117.173.92:5802->/10.117.233.188:38197, qualifier=null, endpoint=[10.117.233.188]:5801, remoteUuid=cca4c50d-e9a8-4de3-a277-7cd9213cc537, alive=true, connectionType=MEMBER, planeIndex=0], thread=BlockingWorker-TaskGroupLocation{jobId=913407264055099393, pipelineId=1, taskGroupId=30000} java.nio.channels.ClosedByInterruptException: null at java.nio.channels.spi.AbstractInterruptibleChannel.end(AbstractInterruptibleChannel.java:202) ~[?:1.8.0_342] at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:477) ~[?:1.8.0_342] at com.hazelcast.internal.networking.nio.NioOutboundPipeline.flushToSocket(NioOutboundPipeline.java:439) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at com.hazelcast.internal.networking.nio.NioOutboundPipeline.process(NioOutboundPipeline.java:324) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at com.hazelcast.internal.networking.nio.NioOutboundPipeline.executePipeline(NioOutboundPipeline.java:240) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at com.hazelcast.internal.networking.nio.NioOutboundPipeline.write(NioOutboundPipeline.java:218) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at com.hazelcast.internal.networking.nio.NioChannel.write(NioChannel.java:79) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at com.hazelcast.internal.server.tcp.TcpServerConnection.write(TcpServerConnection.java:222) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at com.hazelcast.spi.impl.operationservice.impl.OutboundOperationHandler.send(OutboundOperationHandler.java:59) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at com.hazelcast.spi.impl.operationservice.impl.Invocation.doInvokeRemote(Invocation.java:612) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at com.hazelcast.spi.impl.operationservice.impl.Invocation.doInvoke(Invocation.java:582) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at com.hazelcast.spi.impl.operationservice.impl.Invocation.invoke0(Invocation.java:541) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at com.hazelcast.spi.impl.operationservice.impl.Invocation.invoke(Invocation.java:241) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at com.hazelcast.spi.impl.operationservice.impl.OperationServiceImpl.invokeOnPartition(OperationServiceImpl.java:330) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at com.hazelcast.internal.locksupport.LockProxySupport.invoke(LockProxySupport.java:55) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at com.hazelcast.internal.locksupport.LockProxySupport.tryLock(LockProxySupport.java:103) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at com.hazelcast.internal.locksupport.LockProxySupport.tryLock(LockProxySupport.java:94) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at com.hazelcast.map.impl.proxy.MapProxyImpl.tryLock(MapProxyImpl.java:529) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at org.apache.seatunnel.engine.server.TaskExecutionService.updateMetricsContextInImap(TaskExecutionService.java:609) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at org.apache.seatunnel.engine.server.TaskExecutionService.access$1200(TaskExecutionService.java:117) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at org.apache.seatunnel.engine.server.TaskExecutionService$TaskGroupExecutionTracker.taskDone(TaskExecutionService.java:952) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:707) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at org.apache.seatunnel.engine.server.TaskExecutionService$NamedTaskWrapper.run(TaskExecutionService.java:1018) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:39) ~[seatunnel-starter.jar:2.3.8-SNAPSHOT] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[?:1.8.0_342] at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_342] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_342] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_342] at java.lang.Thread.run(Thread.java:750) [?:1.8.0_342] ``` ### Zeta or Flink or Spark Version Zeta ### 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]
