Kurola-Bryson opened a new issue, #10054: URL: https://github.com/apache/seatunnel/issues/10054
### 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 The maxcompute sink cannot write to partitioned tables, and automatic table creation fails to add partitions. The save_mode_create_template can only run a single create table SQL statement and cannot batch execute additional partition creation SQL statements, resulting in the target maxcompute table being automatically created without partitions, leading to task failure. After switching from automatic partitioning to manually creating maxcompute tables and adding partitions, both writing to multiple partitions at once and single partition writing result in errors stating that maxcompute access is rejected. However, further investigation confirmed that this is not a connection issue. Single-table partitionless jobs can still be automatically created and executed successfully, but there have been persistent issues with partitioned table collection in maxcompute sinks, including poor support for the automatic table creation module。 maxcompute sink无法写入分区表，且自动建表无法添加分区，save_mode_create_template只能运行单条建表sql，无法批量附带执行添加分区sql，导致目标maxcompute表即使被自动创建也没有被添加分区导致任务失败，关闭自动分区改为手动创建maxcompute表并添加分区后，无论是一次性写入多分区还是单分区，都会报错maxcompute连接被拒绝访问，但是最终排查证明这不是连接问题，单表无分区作业是可以自动建表并作业成功的，但是maxcompute sink的分区表采集一直存在很多问题，包括自动建表模块的支持也不好 ### SeaTunnel Version 2.3.12 ### SeaTunnel Config ```conf env { parallelism = 4 job.mode = "BATCH" } source { Jdbc { url = "jdbc:mysql://*.mysql.rds.aliyuncs.com:3306/*?serverTimezone=GMT%2b8&useUnicode=true&characterEncoding=UTF-8&rewriteBatchedStatements=true" driver = "com.mysql.cj.jdbc.Driver" connection_check_timeout_sec = 100 username = "*" password = "*" query = """ SELECT id, user_id, order_no, amount, status, create_time, update_time, '2025-10-14' as etl_time FROM user_order_202401 WHERE create_time IS NOT NULL UNION ALL SELECT id, user_id, order_no, amount, status, create_time, update_time, '2025-10-14' as etl_time FROM user_order_202402 WHERE create_time IS NOT NULL UNION ALL SELECT id, user_id, order_no, amount, status, create_time, update_time, '2025-10-14' as etl_time FROM user_order_202403 WHERE create_time IS NOT NULL """ } } transform { } sink { Maxcompute { accessId = "*" accesskey = "*" endpoint = "*/api" project = "*" table_name = "ods_user_order" schema_save_mode = "IGNORE" data_save_mode = "APPEND_DATA" partition_spec = "etl_time='2025-10-14'" } } ``` ### Running Command ```shell seatunnel.sh --config abc.conf -m local ``` ### Error Exception ```log 2025-11-12 16:51:16,579 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=4}] - [localhost]:5801 [seatunnel-803218] [5.1] taskDone, taskId = 1000400010002, taskGroup = TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=4} 2025-11-12 16:51:16,579 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=4}] - [localhost]:5801 [seatunnel-803218] [5.1] task 1000400010002 error with exception: [java.lang.RuntimeException: java.lang.RuntimeException: java.lang.RuntimeException: table default.default.default sink throw error], cancel other task in taskGroup TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=4}. 2025-11-12 16:51:16,580 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=4}] - [localhost]:5801 [seatunnel-803218] [5.1] Interrupted task 1000400000002 - org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask@6f0602e8 2025-11-12 16:51:16,580 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=4}] - [localhost]:5801 [seatunnel-803218] [5.1] taskDone, taskId = 1000400000002, taskGroup = TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=4} 2025-11-12 16:51:16,582 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=4}] - [localhost]:5801 [seatunnel-803218] [5.1] taskGroup TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=4} complete with FAILED 2025-11-12 16:51:16,582 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=4}] - [localhost]:5801 [seatunnel-803218] [5.1] task 1000400000002 error with exception: [java.lang.RuntimeException: java.lang.RuntimeException: java.lang.RuntimeException: table default.default.default sink throw error], cancel other task in taskGroup TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=4}. 2025-11-12 16:51:16,582 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.seaTunnel.task.thread-3] - [localhost]:5801 [seatunnel-803218] [5.1] Task TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=4} complete with state FAILED 2025-11-12 16:51:16,582 INFO [o.a.s.e.s.CoordinatorService ] [hz.main.seaTunnel.task.thread-3] - [localhost]:5801 [seatunnel-803218] [5.1] Received task end from execution TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=4}, state FAILED 2025-11-12 16:51:16,583 INFO [o.a.s.e.s.m.JobMaster ] [hz.main.seaTunnel.task.thread-3] - release the task group resource TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=4} 2025-11-12 16:51:16,583 INFO [a.s.e.s.s.s.DefaultSlotService] [hz.main.generic-operation.thread-43] - received slot release request, jobID: 1040909990178586625, slot: SlotProfile{worker=[localhost]:5801, slotID=15, ownerJobID=1040909990178586625, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='4f7f07fb-b61d-468d-8a36-0d5190d24454'} 2025-11-12 16:51:16,586 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-8] - [localhost]:5801 [seatunnel-803218] [5.1] Task (TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=1}) need cancel. 2025-11-12 16:51:16,587 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=1}] - [localhost]:5801 [seatunnel-803218] [5.1] Interrupted task 1000100000000 - org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask@5b7eac17 2025-11-12 16:51:16,587 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=1}] - [localhost]:5801 [seatunnel-803218] [5.1] taskDone, taskId = 1000100000000, taskGroup = TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=1} 2025-11-12 16:51:16,588 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-8] - [localhost]:5801 [seatunnel-803218] [5.1] Task (TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=2}) need cancel. 2025-11-12 16:51:16,588 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=2}] - [localhost]:5801 [seatunnel-803218] [5.1] Interrupted task 1000200000000 - org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask@57f157c0 2025-11-12 16:51:16,588 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=2}] - [localhost]:5801 [seatunnel-803218] [5.1] Interrupted task 1000200010000 - org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask@62eac35d 2025-11-12 16:51:16,588 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=2}] - [localhost]:5801 [seatunnel-803218] [5.1] taskDone, taskId = 1000200000000, taskGroup = TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=2} 2025-11-12 16:51:16,588 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=2}] - [localhost]:5801 [seatunnel-803218] [5.1] taskDone, taskId = 1000200010000, taskGroup = TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=2} 2025-11-12 16:51:16,589 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=1}] - [localhost]:5801 [seatunnel-803218] [5.1] taskGroup TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=1} complete with CANCELED 2025-11-12 16:51:16,589 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.seaTunnel.task.thread-17] - [localhost]:5801 [seatunnel-803218] [5.1] Task TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=1} complete with state CANCELED 2025-11-12 16:51:16,589 INFO [o.a.s.e.s.CoordinatorService ] [hz.main.seaTunnel.task.thread-17] - [localhost]:5801 [seatunnel-803218] [5.1] Received task end from execution TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=1}, state CANCELED 2025-11-12 16:51:16,590 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-8] - [localhost]:5801 [seatunnel-803218] [5.1] Task (TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=3}) need cancel. 2025-11-12 16:51:16,590 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=2}] - [localhost]:5801 [seatunnel-803218] [5.1] taskGroup TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=2} complete with CANCELED 2025-11-12 16:51:16,590 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.seaTunnel.task.thread-17] - [localhost]:5801 [seatunnel-803218] [5.1] Task TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=2} complete with state CANCELED 2025-11-12 16:51:16,591 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=3}] - [localhost]:5801 [seatunnel-803218] [5.1] Interrupted task 1000300010001 - org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask@4bd8f9de 2025-11-12 16:51:16,591 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=3}] - [localhost]:5801 [seatunnel-803218] [5.1] taskDone, taskId = 1000300010001, taskGroup = TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=3} 2025-11-12 16:51:16,591 INFO [o.a.s.e.s.CoordinatorService ] [hz.main.seaTunnel.task.thread-17] - [localhost]:5801 [seatunnel-803218] [5.1] Received task end from execution TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=2}, state CANCELED 2025-11-12 16:51:16,591 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-8] - [localhost]:5801 [seatunnel-803218] [5.1] Task (TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=5}) need cancel. 2025-11-12 16:51:16,591 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=3}] - [localhost]:5801 [seatunnel-803218] [5.1] Interrupted task 1000300000001 - org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask@82207c7 2025-11-12 16:51:16,591 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=3}] - [localhost]:5801 [seatunnel-803218] [5.1] taskDone, taskId = 1000300000001, taskGroup = TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=3} 2025-11-12 16:51:16,591 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=5}] - [localhost]:5801 [seatunnel-803218] [5.1] Interrupted task 1000500000003 - org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask@7d7fa7e4 2025-11-12 16:51:16,591 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=5}] - [localhost]:5801 [seatunnel-803218] [5.1] taskDone, taskId = 1000500000003, taskGroup = TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=5} 2025-11-12 16:51:16,591 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=5}] - [localhost]:5801 [seatunnel-803218] [5.1] Interrupted task 1000500010003 - org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask@541aab23 2025-11-12 16:51:16,591 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=5}] - [localhost]:5801 [seatunnel-803218] [5.1] taskDone, taskId = 1000500010003, taskGroup = TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=5} 2025-11-12 16:51:16,592 INFO [o.a.s.e.s.m.JobMaster ] [hz.main.seaTunnel.task.thread-17] - release the task group resource TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=2} 2025-11-12 16:51:16,592 INFO [a.s.e.s.s.s.DefaultSlotService] [hz.main.generic-operation.thread-49] - received slot release request, jobID: 1040909990178586625, slot: SlotProfile{worker=[localhost]:5801, slotID=14, ownerJobID=1040909990178586625, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='4f7f07fb-b61d-468d-8a36-0d5190d24454'} 2025-11-12 16:51:16,592 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=3}] - [localhost]:5801 [seatunnel-803218] [5.1] taskGroup TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=3} complete with CANCELED 2025-11-12 16:51:16,593 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.seaTunnel.task.thread-17] - [localhost]:5801 [seatunnel-803218] [5.1] Task TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=3} complete with state CANCELED 2025-11-12 16:51:16,593 INFO [o.a.s.e.s.CoordinatorService ] [hz.main.seaTunnel.task.thread-17] - [localhost]:5801 [seatunnel-803218] [5.1] Received task end from execution TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=3}, state CANCELED 2025-11-12 16:51:16,593 INFO [o.a.s.e.s.m.JobMaster ] [hz.main.seaTunnel.task.thread-17] - release the task group resource TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=3} 2025-11-12 16:51:16,594 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=5}] - [localhost]:5801 [seatunnel-803218] [5.1] taskGroup TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=5} complete with CANCELED 2025-11-12 16:51:16,594 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.seaTunnel.task.thread-12] - [localhost]:5801 [seatunnel-803218] [5.1] Task TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=5} complete with state CANCELED 2025-11-12 16:51:16,594 INFO [o.a.s.e.s.CoordinatorService ] [hz.main.seaTunnel.task.thread-12] - [localhost]:5801 [seatunnel-803218] [5.1] Received task end from execution TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=5}, state CANCELED 2025-11-12 16:51:16,595 INFO [o.a.s.e.s.m.JobMaster ] [hz.main.seaTunnel.task.thread-12] - release the task group resource TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=5} 2025-11-12 16:51:16,596 INFO [a.s.e.s.s.s.DefaultSlotService] [hz.main.generic-operation.thread-0] - received slot release request, jobID: 1040909990178586625, slot: SlotProfile{worker=[localhost]:5801, slotID=12, ownerJobID=1040909990178586625, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='4f7f07fb-b61d-468d-8a36-0d5190d24454'} 2025-11-12 16:51:16,596 INFO [a.s.e.s.s.s.DefaultSlotService] [hz.main.generic-operation.thread-1] - received slot release request, jobID: 1040909990178586625, slot: SlotProfile{worker=[localhost]:5801, slotID=13, ownerJobID=1040909990178586625, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='4f7f07fb-b61d-468d-8a36-0d5190d24454'} 2025-11-12 16:51:19,598 INFO [o.a.s.e.s.m.JobMaster ] [seatunnel-coordinator-service-8] - release the pipeline Job SeaTunnel_Job (1040909990178586625), Pipeline: [(1/1)] resource 2025-11-12 16:51:19,599 INFO [a.s.e.s.s.s.DefaultSlotService] [hz.main.generic-operation.thread-6] - received slot release request, jobID: 1040909990178586625, slot: SlotProfile{worker=[localhost]:5801, slotID=11, ownerJobID=1040909990178586625, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='4f7f07fb-b61d-468d-8a36-0d5190d24454'} 2025-11-12 16:51:19,602 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-8] - [localhost]:5801 [seatunnel-803218] [5.1] received deploying task executionId [1040909993547595777] 2025-11-12 16:51:19,602 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-8] - [localhost]:5801 [seatunnel-803218] [5.1] deploying task TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=1}, executionId [1040909993547595777] 2025-11-12 16:51:19,602 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-8] - [localhost]:5801 [seatunnel-803218] [5.1] deploying TaskGroup TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=1} init success 2025-11-12 16:51:19,603 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-8] - [localhost]:5801 [seatunnel-803218] [5.1] deploying TaskGroup TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=1} success 2025-11-12 16:51:19,605 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-8] - [localhost]:5801 [seatunnel-803218] [5.1] received deploying task executionId [1040909993547661313] 2025-11-12 16:51:19,606 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-8] - [localhost]:5801 [seatunnel-803218] [5.1] deploying task TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=2}, executionId [1040909993547661313] 2025-11-12 16:51:19,606 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-8] - [localhost]:5801 [seatunnel-803218] [5.1] deploying TaskGroup TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=2} init success 2025-11-12 16:51:19,606 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-8] - [localhost]:5801 [seatunnel-803218] [5.1] deploying TaskGroup TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=2} success 2025-11-12 16:51:19,606 INFO [s.e.s.t.TransformSeaTunnelTask] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=2}] - starting seatunnel transform task, index 0 2025-11-12 16:51:19,607 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-8] - [localhost]:5801 [seatunnel-803218] [5.1] received deploying task executionId [1040909993547726849] 2025-11-12 16:51:19,608 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-8] - [localhost]:5801 [seatunnel-803218] [5.1] deploying task TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=3}, executionId [1040909993547726849] 2025-11-12 16:51:19,608 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-8] - [localhost]:5801 [seatunnel-803218] [5.1] deploying TaskGroup TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=3} init success 2025-11-12 16:51:19,608 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-8] - [localhost]:5801 [seatunnel-803218] [5.1] deploying TaskGroup TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=3} success 2025-11-12 16:51:19,609 INFO [.a.s.e.s.t.SourceSeaTunnelTask] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=2}] - starting seatunnel source task, index 0 2025-11-12 16:51:19,609 INFO [s.e.s.t.TransformSeaTunnelTask] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=3}] - starting seatunnel transform task, index 1 2025-11-12 16:51:19,610 INFO [.a.s.e.s.t.SourceSeaTunnelTask] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=3}] - starting seatunnel source task, index 1 2025-11-12 16:51:19,610 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-8] - [localhost]:5801 [seatunnel-803218] [5.1] received deploying task executionId [1040909993547792385] 2025-11-12 16:51:19,611 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-8] - [localhost]:5801 [seatunnel-803218] [5.1] deploying task TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=4}, executionId [1040909993547792385] 2025-11-12 16:51:19,611 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-8] - [localhost]:5801 [seatunnel-803218] [5.1] deploying TaskGroup TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=4} init success 2025-11-12 16:51:19,612 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-8] - [localhost]:5801 [seatunnel-803218] [5.1] deploying TaskGroup TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=4} success 2025-11-12 16:51:19,612 INFO [s.e.s.t.TransformSeaTunnelTask] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=4}] - starting seatunnel transform task, index 2 2025-11-12 16:51:19,613 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-8] - [localhost]:5801 [seatunnel-803218] [5.1] received deploying task executionId [1040909993547857921] 2025-11-12 16:51:19,614 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-8] - [localhost]:5801 [seatunnel-803218] [5.1] deploying task TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=5}, executionId [1040909993547857921] 2025-11-12 16:51:19,614 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-8] - [localhost]:5801 [seatunnel-803218] [5.1] deploying TaskGroup TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=5} init success 2025-11-12 16:51:19,617 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-8] - [localhost]:5801 [seatunnel-803218] [5.1] deploying TaskGroup TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=5} success 2025-11-12 16:51:19,617 INFO [s.e.s.t.TransformSeaTunnelTask] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=5}] - starting seatunnel transform task, index 3 2025-11-12 16:51:19,619 INFO [.a.s.e.s.t.SourceSeaTunnelTask] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=4}] - starting seatunnel source task, index 2 2025-11-12 16:51:19,619 INFO [.a.s.e.s.t.SourceSeaTunnelTask] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=5}] - starting seatunnel source task, index 3 2025-11-12 16:51:39,357 INFO [o.a.s.e.s.CoordinatorService ] [pool-7-thread-1] - [localhost]:5801 [seatunnel-803218] [5.1] *********************************************** CoordinatorService Thread Pool Status *********************************************** activeCount : 2 corePoolSize : 10 maximumPoolSize : 2147483647 poolSize : 10 completedTaskCount : 112 taskCount : 114 *********************************************** 2025-11-12 16:51:39,358 INFO [o.a.s.e.s.CoordinatorService ] [pool-7-thread-1] - [localhost]:5801 [seatunnel-803218] [5.1] *********************************************** Job info detail *********************************************** createdJobCount : 0 pendingJobCount : 0 scheduledJobCount : 0 runningJobCount : 1 failingJobCount : 0 failedJobCount : 0 cancellingJobCount : 0 canceledJobCount : 0 finishedJobCount : 0 *********************************************** 2025-11-12 16:52:39,357 INFO [o.a.s.e.s.CoordinatorService ] [pool-7-thread-1] - [localhost]:5801 [seatunnel-803218] [5.1] *********************************************** CoordinatorService Thread Pool Status *********************************************** activeCount : 2 corePoolSize : 10 maximumPoolSize : 2147483647 poolSize : 10 completedTaskCount : 112 taskCount : 114 *********************************************** 2025-11-12 16:52:39,358 INFO [o.a.s.e.s.CoordinatorService ] [pool-7-thread-1] - [localhost]:5801 [seatunnel-803218] [5.1] *********************************************** Job info detail *********************************************** createdJobCount : 0 pendingJobCount : 0 scheduledJobCount : 0 runningJobCount : 1 failingJobCount : 0 failedJobCount : 0 cancellingJobCount : 0 canceledJobCount : 0 finishedJobCount : 0 *********************************************** 2025-11-12 16:53:29,657 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=4}] - [localhost]:5801 [seatunnel-803218] [5.1] Exception in org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask@164be41f java.lang.RuntimeException: java.lang.RuntimeException: java.lang.RuntimeException: table default.default.default sink throw error at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:303) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:70) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.task.SeaTunnelTransformCollector.collect(SeaTunnelTransformCollector.java:39) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.task.SeaTunnelTransformCollector.collect(SeaTunnelTransformCollector.java:27) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.handleRecord(IntermediateBlockingQueue.java:77) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.collect(IntermediateBlockingQueue.java:56) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.task.flow.IntermediateQueueFlowLifeCycle.collect(IntermediateQueueFlowLifeCycle.java:51) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.collect(TransformSeaTunnelTask.java:72) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:165) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.call(TransformSeaTunnelTask.java:77) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:679) [seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.TaskExecutionService$NamedTaskWrapper.run(TaskExecutionService.java:1008) [seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43) [seatunnel-starter.jar:2.3.12] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_181] at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_181] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_181] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_181] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_181] Caused by: java.lang.RuntimeException: java.lang.RuntimeException: table default.default.default sink throw error at org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.abortPrepare(MultiTableSinkWriter.java:309) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:204) ~[seatunnel-starter.jar:2.3.12] ... 17 more Caused by: java.lang.RuntimeException: table default.default.default sink throw error at org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.subSinkErrorCheck(MultiTableSinkWriter.java:140) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.checkQueueRemain(MultiTableSinkWriter.java:358) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.abortPrepare(MultiTableSinkWriter.java:289) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:204) ~[seatunnel-starter.jar:2.3.12] ... 17 more Caused by: org.apache.seatunnel.common.exception.SeaTunnelRuntimeException: ErrorCode:[COMMON-23], ErrorDescription:[Maxcompute write SeaTunnelRow failed, the SeaTunnelRow value is 'SeaTunnelRow{tableId=default.default.default, kind=+I, fields=[1, 1001, 20240101001, 199.99, 1, 2024-01-15T10:30, 2025-11-07T15:58:39, 2025-10-14]}'.] at org.apache.seatunnel.common.exception.CommonError.writeSeaTunnelRowFailed(CommonError.java:97) ~[seatunnel-starter.jar:2.3.12] at org.apache.seatunnel.connectors.seatunnel.maxcompute.sink.MaxcomputeWriter.write(MaxcomputeWriter.java:56) ~[connector-maxcompute-2.3.12.jar:2.3.12] at org.apache.seatunnel.connectors.seatunnel.maxcompute.sink.MaxcomputeWriter.write(MaxcomputeWriter.java:35) ~[connector-maxcompute-2.3.12.jar:2.3.12] at org.apache.seatunnel.api.sink.multitablesink.MultiTableWriterRunnable.run(MultiTableWriterRunnable.java:67) ~[seatunnel-starter.jar:2.3.12] ... 6 more Caused by: com.aliyun.odps.tunnel.TunnelException: RequestId=20251112165329532a4d1a05a59993, ErrorCode=InternalServerError, ErrorMessage=Service internal error, please try again later. at com.aliyun.odps.tunnel.impl.SessionBase.httpRequestWithNoRetry(SessionBase.java:65) ~[connector-maxcompute-2.3.12.jar:2.3.12] at com.aliyun.odps.tunnel.impl.SessionBase.lambda$httpRequest$0(SessionBase.java:91) ~[connector-maxcompute-2.3.12.jar:2.3.12] at com.aliyun.odps.tunnel.io.TunnelRetryHandler.executeWithRetry(TunnelRetryHandler.java:105) ~[connector-maxcompute-2.3.12.jar:2.3.12] at com.aliyun.odps.tunnel.io.TunnelRetryHandler.executeWithRetry(TunnelRetryHandler.java:97) ~[connector-maxcompute-2.3.12.jar:2.3.12] at com.aliyun.odps.tunnel.impl.SessionBase.httpRequest(SessionBase.java:90) ~[connector-maxcompute-2.3.12.jar:2.3.12] at com.aliyun.odps.tunnel.impl.UpsertSessionImpl.initiate(UpsertSessionImpl.java:268) ~[connector-maxcompute-2.3.12.jar:2.3.12] at com.aliyun.odps.tunnel.impl.UpsertSessionImpl.<init>(UpsertSessionImpl.java:96) ~[connector-maxcompute-2.3.12.jar:2.3.12] at com.aliyun.odps.tunnel.impl.UpsertSessionImpl$Builder.build(UpsertSessionImpl.java:677) ~[connector-maxcompute-2.3.12.jar:2.3.12] at com.aliyun.odps.tunnel.impl.UpsertSessionImpl$Builder.build(UpsertSessionImpl.java:535) ~[connector-maxcompute-2.3.12.jar:2.3.12] at org.apache.seatunnel.connectors.seatunnel.maxcompute.util.MaxcomputeOutputFormat.initializeUpsertSession(MaxcomputeOutputFormat.java:129) ~[connector-maxcompute-2.3.12.jar:2.3.12] at org.apache.seatunnel.connectors.seatunnel.maxcompute.util.MaxcomputeOutputFormat.ensureUpsertSessionAndWriter(MaxcomputeOutputFormat.java:104) ~[connector-maxcompute-2.3.12.jar:2.3.12] at org.apache.seatunnel.connectors.seatunnel.maxcompute.util.MaxcomputeOutputFormat.write(MaxcomputeOutputFormat.java:58) ~[connector-maxcompute-2.3.12.jar:2.3.12] at org.apache.seatunnel.connectors.seatunnel.maxcompute.sink.MaxcomputeWriter.write(MaxcomputeWriter.java:52) ~[connector-maxcompute-2.3.12.jar:2.3.12] at org.apache.seatunnel.connectors.seatunnel.maxcompute.sink.MaxcomputeWriter.write(MaxcomputeWriter.java:35) ~[connector-maxcompute-2.3.12.jar:2.3.12] at org.apache.seatunnel.api.sink.multitablesink.MultiTableWriterRunnable.run(MultiTableWriterRunnable.java:67) ~[seatunnel-starter.jar:2.3.12] ... 6 more 2025-11-12 16:53:29,659 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=4}] - [localhost]:5801 [seatunnel-803218] [5.1] taskDone, taskId = 1000400010002, taskGroup = TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=4} 2025-11-12 16:53:29,659 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=4}] - [localhost]:5801 [seatunnel-803218] [5.1] task 1000400010002 error with exception: [java.lang.RuntimeException: java.lang.RuntimeException: java.lang.RuntimeException: table default.default.default sink throw error], cancel other task in taskGroup TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=4}. 2025-11-12 16:53:29,659 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=4}] - [localhost]:5801 [seatunnel-803218] [5.1] Interrupted task 1000400000002 - org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask@5883a21 2025-11-12 16:53:29,659 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=4}] - [localhost]:5801 [seatunnel-803218] [5.1] taskDone, taskId = 1000400000002, taskGroup = TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=4} 2025-11-12 16:53:29,661 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=4}] - [localhost]:5801 [seatunnel-803218] [5.1] taskGroup TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=4} complete with FAILED 2025-11-12 16:53:29,661 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=4}] - [localhost]:5801 [seatunnel-803218] [5.1] task 1000400000002 error with exception: [java.lang.RuntimeException: java.lang.RuntimeException: java.lang.RuntimeException: table default.default.default sink throw error], cancel other task in taskGroup TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=4}. 2025-11-12 16:53:29,661 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.seaTunnel.task.thread-2] - [localhost]:5801 [seatunnel-803218] [5.1] Task TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=4} complete with state FAILED 2025-11-12 16:53:29,661 INFO [o.a.s.e.s.CoordinatorService ] [hz.main.seaTunnel.task.thread-2] - [localhost]:5801 [seatunnel-803218] [5.1] Received task end from execution TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=4}, state FAILED 2025-11-12 16:53:29,662 INFO [o.a.s.e.s.m.JobMaster ] [hz.main.seaTunnel.task.thread-2] - release the task group resource TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=4} 2025-11-12 16:53:29,662 INFO [a.s.e.s.s.s.DefaultSlotService] [hz.main.generic-operation.thread-12] - received slot release request, jobID: 1040909990178586625, slot: SlotProfile{worker=[localhost]:5801, slotID=19, ownerJobID=1040909990178586625, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='4f7f07fb-b61d-468d-8a36-0d5190d24454'} 2025-11-12 16:53:29,663 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-7] - [localhost]:5801 [seatunnel-803218] [5.1] Task (TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=1}) need cancel. 2025-11-12 16:53:29,664 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=1}] - [localhost]:5801 [seatunnel-803218] [5.1] Interrupted task 1000100000000 - org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask@7683bf40 2025-11-12 16:53:29,664 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=1}] - [localhost]:5801 [seatunnel-803218] [5.1] taskDone, taskId = 1000100000000, taskGroup = TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=1} 2025-11-12 16:53:29,664 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-7] - [localhost]:5801 [seatunnel-803218] [5.1] Task (TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=2}) need cancel. 2025-11-12 16:53:29,664 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=2}] - [localhost]:5801 [seatunnel-803218] [5.1] Interrupted task 1000200000000 - org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask@2712b1c6 2025-11-12 16:53:29,664 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=2}] - [localhost]:5801 [seatunnel-803218] [5.1] taskDone, taskId = 1000200000000, taskGroup = TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=2} 2025-11-12 16:53:29,665 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=2}] - [localhost]:5801 [seatunnel-803218] [5.1] Interrupted task 1000200010000 - org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask@5895e598 2025-11-12 16:53:29,665 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=2}] - [localhost]:5801 [seatunnel-803218] [5.1] taskDone, taskId = 1000200010000, taskGroup = TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=2} 2025-11-12 16:53:29,665 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=1}] - [localhost]:5801 [seatunnel-803218] [5.1] taskGroup TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=1} complete with CANCELED 2025-11-12 16:53:29,665 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-7] - [localhost]:5801 [seatunnel-803218] [5.1] Task (TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=3}) need cancel. 2025-11-12 16:53:29,665 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.seaTunnel.task.thread-17] - [localhost]:5801 [seatunnel-803218] [5.1] Task TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=1} complete with state CANCELED 2025-11-12 16:53:29,665 INFO [o.a.s.e.s.CoordinatorService ] [hz.main.seaTunnel.task.thread-17] - [localhost]:5801 [seatunnel-803218] [5.1] Received task end from execution TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=1}, state CANCELED 2025-11-12 16:53:29,665 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=3}] - [localhost]:5801 [seatunnel-803218] [5.1] Interrupted task 1000300010001 - org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask@785c224d 2025-11-12 16:53:29,665 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=3}] - [localhost]:5801 [seatunnel-803218] [5.1] Interrupted task 1000300000001 - org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask@70f7490 2025-11-12 16:53:29,665 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=3}] - [localhost]:5801 [seatunnel-803218] [5.1] taskDone, taskId = 1000300010001, taskGroup = TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=3} 2025-11-12 16:53:29,665 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=3}] - [localhost]:5801 [seatunnel-803218] [5.1] taskDone, taskId = 1000300000001, taskGroup = TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=3} 2025-11-12 16:53:29,667 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-7] - [localhost]:5801 [seatunnel-803218] [5.1] Task (TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=5}) need cancel. 2025-11-12 16:53:29,667 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=5}] - [localhost]:5801 [seatunnel-803218] [5.1] Interrupted task 1000500000003 - org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask@675e90ce 2025-11-12 16:53:29,667 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=5}] - [localhost]:5801 [seatunnel-803218] [5.1] Interrupted task 1000500010003 - org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask@78b21e1d 2025-11-12 16:53:29,667 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=5}] - [localhost]:5801 [seatunnel-803218] [5.1] taskDone, taskId = 1000500000003, taskGroup = TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=5} 2025-11-12 16:53:29,667 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=5}] - [localhost]:5801 [seatunnel-803218] [5.1] taskDone, taskId = 1000500010003, taskGroup = TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=5} 2025-11-12 16:53:29,667 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=2}] - [localhost]:5801 [seatunnel-803218] [5.1] taskGroup TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=2} complete with CANCELED 2025-11-12 16:53:29,668 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.seaTunnel.task.thread-27] - [localhost]:5801 [seatunnel-803218] [5.1] Task TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=2} complete with state CANCELED 2025-11-12 16:53:29,668 INFO [o.a.s.e.s.CoordinatorService ] [hz.main.seaTunnel.task.thread-27] - [localhost]:5801 [seatunnel-803218] [5.1] Received task end from execution TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=2}, state CANCELED 2025-11-12 16:53:29,669 INFO [o.a.s.e.s.m.JobMaster ] [hz.main.seaTunnel.task.thread-27] - release the task group resource TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=2} 2025-11-12 16:53:29,669 INFO [a.s.e.s.s.s.DefaultSlotService] [hz.main.generic-operation.thread-18] - received slot release request, jobID: 1040909990178586625, slot: SlotProfile{worker=[localhost]:5801, slotID=17, ownerJobID=1040909990178586625, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='4f7f07fb-b61d-468d-8a36-0d5190d24454'} 2025-11-12 16:53:29,669 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=5}] - [localhost]:5801 [seatunnel-803218] [5.1] taskGroup TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=5} complete with CANCELED 2025-11-12 16:53:29,669 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.seaTunnel.task.thread-1] - [localhost]:5801 [seatunnel-803218] [5.1] Task TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=5} complete with state CANCELED 2025-11-12 16:53:29,669 INFO [o.a.s.e.s.CoordinatorService ] [hz.main.seaTunnel.task.thread-1] - [localhost]:5801 [seatunnel-803218] [5.1] Received task end from execution TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=5}, state CANCELED 2025-11-12 16:53:29,683 INFO [o.a.s.e.s.m.JobMaster ] [hz.main.seaTunnel.task.thread-1] - release the task group resource TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=5} 2025-11-12 16:53:29,688 INFO [a.s.e.s.s.s.DefaultSlotService] [hz.main.generic-operation.thread-22] - received slot release request, jobID: 1040909990178586625, slot: SlotProfile{worker=[localhost]:5801, slotID=18, ownerJobID=1040909990178586625, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='4f7f07fb-b61d-468d-8a36-0d5190d24454'} 2025-11-12 16:53:29,689 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=3}] - [localhost]:5801 [seatunnel-803218] [5.1] taskGroup TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=3} complete with CANCELED 2025-11-12 16:53:29,689 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.seaTunnel.task.thread-1] - [localhost]:5801 [seatunnel-803218] [5.1] Task TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=3} complete with state CANCELED 2025-11-12 16:53:29,689 INFO [o.a.s.e.s.CoordinatorService ] [hz.main.seaTunnel.task.thread-1] - [localhost]:5801 [seatunnel-803218] [5.1] Received task end from execution TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=3}, state CANCELED 2025-11-12 16:53:29,690 INFO [o.a.s.e.s.m.JobMaster ] [hz.main.seaTunnel.task.thread-1] - release the task group resource TaskGroupLocation{jobId=1040909990178586625, pipelineId=1, taskGroupId=3} 2025-11-12 16:53:29,690 INFO [a.s.e.s.s.s.DefaultSlotService] [hz.main.generic-operation.thread-17] - received slot release request, jobID: 1040909990178586625, slot: SlotProfile{worker=[localhost]:5801, slotID=20, ownerJobID=1040909990178586625, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='4f7f07fb-b61d-468d-8a36-0d5190d24454'} 2025-11-12 16:53:29,707 INFO [o.a.s.e.s.m.JobMaster ] [seatunnel-coordinator-service-7] - release the pipeline Job SeaTunnel_Job (1040909990178586625), Pipeline: [(1/1)] resource 2025-11-12 16:53:29,707 INFO [a.s.e.s.s.s.DefaultSlotService] [hz.main.generic-operation.thread-28] - received slot release request, jobID: 1040909990178586625, slot: SlotProfile{worker=[localhost]:5801, slotID=16, ownerJobID=1040909990178586625, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='4f7f07fb-b61d-468d-8a36-0d5190d24454'} 2025-11-12 16:53:29,721 INFO [o.a.s.e.c.j.ClientJobProxy ] [main] - Job (1040909990178586625) end with state FAILED 2025-11-12 16:53:29,721 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel-803218] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is SHUTTING_DOWN 2025-11-12 16:53:29,725 INFO [c.h.i.s.t.TcpServerConnection ] [hz.main.IO.thread-in-1] - [localhost]:5801 [seatunnel-803218] [5.1] Connection[id=1, /127.0.0.1:5801->/127.0.0.1:44496, qualifier=null, endpoint=[127.0.0.1]:44496, remoteUuid=18060d24-b088-489b-a987-5a66b50b322b, alive=false, connectionType=JVM, planeIndex=-1] closed. Reason: Connection closed by the other side 2025-11-12 16:53:29,725 INFO [.c.i.c.ClientConnectionManager] [main] - hz.client_1 [seatunnel-803218] [5.1] Removed connection to endpoint: [localhost]:5801:a343f6de-cc30-4e2a-8037-ee603c9ca1b9, connection: ClientConnection{alive=false, connectionId=1, channel=NioChannel{/127.0.0.1:44496->localhost/127.0.0.1:5801}, remoteAddress=[localhost]:5801, lastReadTime=2025-11-12 16:53:29.720, lastWriteTime=2025-11-12 16:53:25.804, closedTime=2025-11-12 16:53:29.722, connected server version=5.1} 2025-11-12 16:53:29,726 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel-803218] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is CLIENT_DISCONNECTED 2025-11-12 16:53:29,727 INFO [c.h.c.i.ClientEndpointManager ] [hz.main.event-2] - [localhost]:5801 [seatunnel-803218] [5.1] Destroying ClientEndpoint{connection=Connection[id=1, /127.0.0.1:5801->/127.0.0.1:44496, qualifier=null, endpoint=[127.0.0.1]:44496, remoteUuid=18060d24-b088-489b-a987-5a66b50b322b, alive=false, connectionType=JVM, planeIndex=-1], clientUuid=18060d24-b088-489b-a987-5a66b50b322b, clientName=hz.client_1, authenticated=true, clientVersion=5.1, creationTime=1762937080768, latest clientAttributes=lastStatisticsCollectionTime=1762937605801,enterprise=false,clientType=JVM,clientVersion=5.1,clusterConnectionTimestamp=1762937080758,clientAddress=127.0.0.1,clientName=hz.client_1,credentials.principal=null,os.committedVirtualMemorySize=6650859520,os.freePhysicalMemorySize=186019840,os.freeSwapSpaceSize=0,os.maxFileDescriptorCount=65536,os.openFileDescriptorCount=79,os.processCpuTime=26110000000,os.systemLoadAverage=0.54,os.totalPhysicalMemorySize=16427765760,os.totalSw apSpaceSize=0,runtime.availableProcessors=8,runtime.freeMemory=248736200,runtime.maxMemory=477626368,runtime.totalMemory=408944640,runtime.uptime=528575,runtime.usedMemory=160356384, labels=[]} 2025-11-12 16:53:29,730 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel-803218] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is SHUTDOWN 2025-11-12 16:53:29,730 INFO [c.h.c.LifecycleService ] [main] - [localhost]:5801 [seatunnel-803218] [5.1] [localhost]:5801 is SHUTTING_DOWN 2025-11-12 16:53:29,734 INFO [c.h.i.p.i.MigrationManager ] [hz.main.cached.thread-12] - [localhost]:5801 [seatunnel-803218] [5.1] Shutdown request of Member [localhost]:5801 - a343f6de-cc30-4e2a-8037-ee603c9ca1b9 [master node] [active master] this is handled 2025-11-12 16:53:29,739 INFO [c.h.i.i.Node ] [main] - [localhost]:5801 [seatunnel-803218] [5.1] Shutting down connection manager... 2025-11-12 16:53:29,742 INFO [c.h.i.i.Node ] [main] - [localhost]:5801 [seatunnel-803218] [5.1] Shutting down node engine... 2025-11-12 16:53:29,770 INFO [c.h.i.i.NodeExtension ] [main] - [localhost]:5801 [seatunnel-803218] [5.1] Destroying node NodeExtension. 2025-11-12 16:53:29,770 INFO [c.h.i.i.Node ] [main] - [localhost]:5801 [seatunnel-803218] [5.1] Hazelcast Shutdown is completed in 37 ms. 2025-11-12 16:53:29,770 INFO [c.h.c.LifecycleService ] [main] - [localhost]:5801 [seatunnel-803218] [5.1] [localhost]:5801 is SHUTDOWN Exception in thread "main" org.apache.seatunnel.core.starter.exception.CommandExecuteException: SeaTunnel job executed failed at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:228) at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40) at org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:40) Caused by: org.apache.seatunnel.engine.common.exception.SeaTunnelEngineException: java.lang.RuntimeException: java.lang.RuntimeException: java.lang.RuntimeException: table default.default.default sink throw error at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:303) at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:70) at org.apache.seatunnel.engine.server.task.SeaTunnelTransformCollector.collect(SeaTunnelTransformCollector.java:39) at org.apache.seatunnel.engine.server.task.SeaTunnelTransformCollector.collect(SeaTunnelTransformCollector.java:27) at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.handleRecord(IntermediateBlockingQueue.java:77) at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.collect(IntermediateBlockingQueue.java:56) at org.apache.seatunnel.engine.server.task.flow.IntermediateQueueFlowLifeCycle.collect(IntermediateQueueFlowLifeCycle.java:51) at org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.collect(TransformSeaTunnelTask.java:72) at org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:165) at org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.call(TransformSeaTunnelTask.java:77) at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:679) at org.apache.seatunnel.engine.server.TaskExecutionService$NamedTaskWrapper.run(TaskExecutionService.java:1008) at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) Caused by: java.lang.RuntimeException: java.lang.RuntimeException: table default.default.default sink throw error at org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.abortPrepare(MultiTableSinkWriter.java:309) at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:204) ... 17 more Caused by: java.lang.RuntimeException: table default.default.default sink throw error at org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.subSinkErrorCheck(MultiTableSinkWriter.java:140) at org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.checkQueueRemain(MultiTableSinkWriter.java:358) at org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.abortPrepare(MultiTableSinkWriter.java:289) ... 18 more Caused by: org.apache.seatunnel.common.exception.SeaTunnelRuntimeException: ErrorCode:[COMMON-23], ErrorDescription:[Maxcompute write SeaTunnelRow failed, the SeaTunnelRow value is 'SeaTunnelRow{tableId=default.default.default, kind=+I, fields=[1, 1001, 20240101001, 199.99, 1, 2024-01-15T10:30, 2025-11-07T15:58:39, 2025-10-14]}'.] at org.apache.seatunnel.common.exception.CommonError.writeSeaTunnelRowFailed(CommonError.java:97) at org.apache.seatunnel.connectors.seatunnel.maxcompute.sink.MaxcomputeWriter.write(MaxcomputeWriter.java:56) at org.apache.seatunnel.connectors.seatunnel.maxcompute.sink.MaxcomputeWriter.write(MaxcomputeWriter.java:35) at org.apache.seatunnel.api.sink.multitablesink.MultiTableWriterRunnable.run(MultiTableWriterRunnable.java:67) ... 6 more Caused by: RequestId=20251112165329532a4d1a05a59993, ErrorCode=InternalServerError, ErrorMessage=Service internal error, please try again later. at com.aliyun.odps.tunnel.impl.SessionBase.httpRequestWithNoRetry(SessionBase.java:65) at com.aliyun.odps.tunnel.impl.SessionBase.lambda$httpRequest$0(SessionBase.java:91) at com.aliyun.odps.tunnel.io.TunnelRetryHandler.executeWithRetry(TunnelRetryHandler.java:105) at com.aliyun.odps.tunnel.io.TunnelRetryHandler.executeWithRetry(TunnelRetryHandler.java:97) at com.aliyun.odps.tunnel.impl.SessionBase.httpRequest(SessionBase.java:90) at com.aliyun.odps.tunnel.impl.UpsertSessionImpl.initiate(UpsertSessionImpl.java:268) at com.aliyun.odps.tunnel.impl.UpsertSessionImpl.<init>(UpsertSessionImpl.java:96) at com.aliyun.odps.tunnel.impl.UpsertSessionImpl$Builder.build(UpsertSessionImpl.java:677) at com.aliyun.odps.tunnel.impl.UpsertSessionImpl$Builder.build(UpsertSessionImpl.java:535) at org.apache.seatunnel.connectors.seatunnel.maxcompute.util.MaxcomputeOutputFormat.initializeUpsertSession(MaxcomputeOutputFormat.java:129) at org.apache.seatunnel.connectors.seatunnel.maxcompute.util.MaxcomputeOutputFormat.ensureUpsertSessionAndWriter(MaxcomputeOutputFormat.java:104) at org.apache.seatunnel.connectors.seatunnel.maxcompute.util.MaxcomputeOutputFormat.write(MaxcomputeOutputFormat.java:58) at org.apache.seatunnel.connectors.seatunnel.maxcompute.sink.MaxcomputeWriter.write(MaxcomputeWriter.java:52) ... 8 more at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:220) ... 2 more ``` ### Zeta or Flink or Spark Version zeta2.3.12 ### Java or Scala Version java1.8 ### Screenshots <img width="996" height="630" alt="Image" src="https://github.com/user-attachments/assets/46a90000-0170-47b8-9a8e-cebb52188d36"; /> <img width="1236" height="459" alt="Image" src="https://github.com/user-attachments/assets/1af28448-acf0-44fd-bded-97a2231cae4f"; /> <img width="1263" height="677" alt="Image" src="https://github.com/user-attachments/assets/c6645d99-57fd-446a-984b-fc26779f3a6d"; /> ### Are you willing to submit PR? - [x] 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]
