heheyo opened a new issue, #6516: URL: https://github.com/apache/seatunnel/issues/6516
### 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 1000多个任务并发执行，任务阻塞不动，读数显示一直为0/s ### SeaTunnel Version 2.3.4 ### SeaTunnel Config ```conf env { job.mode = "BATCH" execution.checkpoint.interval = 10000 } source { Jdbc { url = "jdbc:mysql://ip:3306/eioms1?serverTimezone=GMT%2B8&characterEncoding=UTF-8&useUnicode=true&useSSL=false" driver = "com.mysql.cj.jdbc.Driver" user = "111" password = "222" query = "select * from d9storesrequisition" result_table_name = "fake" } } transform { Sql{ source_table_name = "fake" result_table_name = "fake1" query = "select sre_id,sre_code,sre_desc,sre_org,sre_site,sre_store,sre_storeOrg,sre_storeSite,sre_status,sre_rstatus,sre_mrc,sre_mrcOrg,sre_object,sre_person,sre_personOrg,sre_date,sre_adminDepart,sre_adminDepartOrg,sre_cls,sre_clsOrg,sre_requiredDate,sre_address,sre_staff,sre_staffOrg,sre_project,sre_projectOrg,sre_budget,sre_budgetOrg,sre_event,sre_approveDate,sre_approver,sre_lineQty,sre_lineTotal,sre_remarks,sre_created,sre_updated,sre_createdby,sre_updatedby,sre_udfchar01,sre_udfchar02,sre_udfchar03,sre_udfchar04,sre_udfchar05,sre_udfchar06,sre_udfchar07,sre_udfchar08,sre_udfchar09,sre_udfchar10,sre_udfchar11,sre_udfchar12,sre_udfchar13,sre_udfchar14,sre_udfchar15,sre_udfchar16,sre_udfchar17,sre_udfchar18,sre_udfchar19,sre_udfchar20,sre_udfchar21,sre_udfchar22,sre_udfchar23,sre_udfchar24,sre_udfchar25,sre_udfchar26,sre_udfchar27,sre_udfchar28,sre_udfchar29,sre_udfchar30,sre_udfnum01,sre_udfnum02,sre_udfnum03,sre_udfnum04,sre_udfnum05,sre_udfnum06,sre_udfnum07,sre_udf num08,sre_udfnum09,sre_udfnum10,sre_udfdate01,sre_udfdate02,sre_udfdate03,sre_udfdate04,sre_udfdate05,sre_udfdate06,sre_udfdate07,sre_udfdate08,sre_udfdate09,sre_udfdate10,sre_udfchkbox01,sre_udfchkbox02,sre_udfchkbox03,sre_udfchkbox04,sre_udfchkbox05,sre_udfchkbox06,sre_udfchkbox07,sre_udfchkbox08,sre_udfchkbox09,sre_udfchkbox10,CURRENT_DATE() as pt from fake" } FieldMapper{ source_table_name = "fake1" result_table_name = "fake2" field_mapper = { sre_id = sre_id sre_code = sre_code sre_desc = sre_desc sre_org = sre_org sre_site = sre_site sre_store = sre_store sre_storeOrg = sre_storeOrg sre_storeSite = sre_storeSite sre_status = sre_status sre_rstatus = sre_rstatus sre_mrc = sre_mrc sre_mrcOrg = sre_mrcOrg sre_object = sre_object sre_person = sre_person sre_personOrg = sre_personOrg sre_date = sre_date sre_adminDepart = sre_adminDepart sre_adminDepartOrg = sre_adminDepartOrg sre_cls = sre_cls sre_clsOrg = sre_clsOrg sre_requiredDate = sre_requiredDate sre_address = sre_address sre_staff = sre_staff sre_staffOrg = sre_staffOrg sre_project = sre_project sre_projectOrg = sre_projectOrg sre_budget = sre_budget sre_budgetOrg = sre_budgetOrg sre_event = sre_event sre_approveDate = sre_approveDate sre_approver = sre_approver sre_lineQty = sre_lineQty sre_lineTotal = sre_lineTotal sre_remarks = sre_remarks sre_created = sre_created sre_updated = sre_updated sre_createdby = sre_createdby sre_updatedby = sre_updatedby sre_udfchar01 = sre_udfchar01 sre_udfchar02 = sre_udfchar02 sre_udfchar03 = sre_udfchar03 sre_udfchar04 = sre_udfchar04 sre_udfchar05 = sre_udfchar05 sre_udfchar06 = sre_udfchar06 sre_udfchar07 = sre_udfchar07 sre_udfchar08 = sre_udfchar08 sre_udfchar09 = sre_udfchar09 sre_udfchar10 = sre_udfchar10 sre_udfchar11 = sre_udfchar11 sre_udfchar12 = sre_udfchar12 sre_udfchar13 = sre_udfchar13 sre_udfchar14 = sre_udfchar14 sre_udfchar15 = sre_udfchar15 sre_udfchar16 = sre_udfchar16 sre_udfchar17 = sre_udfchar17 sre_udfchar18 = sre_udfchar18 sre_udfchar19 = sre_udfchar19 sre_udfchar20 = sre_udfchar20 sre_udfchar21 = sre_udfchar21 sre_udfchar22 = sre_udfchar22 sre_udfchar23 = sre_udfchar23 sre_udfchar24 = sre_udfchar24 sre_udfchar25 = sre_udfchar25 sre_udfchar26 = sre_udfchar26 sre_udfchar27 = sre_udfchar27 sre_udfchar28 = sre_udfchar28 sre_udfchar29 = sre_udfchar29 sre_udfchar30 = sre_udfchar30 sre_udfnum01 = sre_udfnum01 sre_udfnum02 = sre_udfnum02 sre_udfnum03 = sre_udfnum03 sre_udfnum04 = sre_udfnum04 sre_udfnum05 = sre_udfnum05 sre_udfnum06 = sre_udfnum06 sre_udfnum07 = sre_udfnum07 sre_udfnum08 = sre_udfnum08 sre_udfnum09 = sre_udfnum09 sre_udfnum10 = sre_udfnum10 sre_udfdate01 = sre_udfdate01 sre_udfdate02 = sre_udfdate02 sre_udfdate03 = sre_udfdate03 sre_udfdate04 = sre_udfdate04 sre_udfdate05 = sre_udfdate05 sre_udfdate06 = sre_udfdate06 sre_udfdate07 = sre_udfdate07 sre_udfdate08 = sre_udfdate08 sre_udfdate09 = sre_udfdate09 sre_udfdate10 = sre_udfdate10 sre_udfchkbox01 = sre_udfchkbox01 sre_udfchkbox02 = sre_udfchkbox02 sre_udfchkbox03 = sre_udfchkbox03 sre_udfchkbox04 = sre_udfchkbox04 sre_udfchkbox05 = sre_udfchkbox05 sre_udfchkbox06 = sre_udfchkbox06 sre_udfchkbox07 = sre_udfchkbox07 sre_udfchkbox08 = sre_udfchkbox08 sre_udfchkbox09 = sre_udfchkbox09 sre_udfchkbox10 = sre_udfchkbox10 pt = pt } } } sink { Hive { table_name = "cfd.ods_eioms1_d9storesrequisition_df_tmp_aae5008de0f04cf793c77271e5cf1833" metastore_uri = "thrift://tdh04:9083" hdfs_site_path = "/opt/dtc/TDH-Client/conf/hadoop/hdfs-site.xml" hive_site_path = "/opt/dtc/TDH-Client/conf/inceptor/hive-site.xml" source_table_name = "fake2" } } ``` ### Running Command ```shell ${SEATUNNEL_HOME}/bin/seatunnel.sh --config /dolphinscheduler/exec/process/default/12291667535520/12902949545120_1/3682/13996/seatunnel_3682_13996.conf --deploy-mode ``` ### Error Exception ```log 2024-03-15 03:00:26,109 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-30] - [tdh02]:5801 [seatunnel] [5.1] deploying task TaskGroupLocation{jobId=820733095626932237, pipelineId=1, taskGroupId=1}, executionId [820733096964259841] 2024-03-15 03:00:26,110 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-30] - [tdh02]:5801 [seatunnel] [5.1] deploying TaskGroup TaskGroupLocation{jobId=820733095626932237, pipelineId=1, taskGroupId=1} init success 2024-03-15 03:00:26,141 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-30] - [tdh02]:5801 [seatunnel] [5.1] deploying TaskGroup TaskGroupLocation{jobId=820733095626932237, pipelineId=1, taskGroupId=1} success 2024-03-15 03:00:26,498 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-18] - [tdh02]:5801 [seatunnel] [5.1] deploying task TaskGroupLocation{jobId=820733095626932237, pipelineId=1, taskGroupId=3}, executionId [820733096964456449] 2024-03-15 03:00:26,498 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-18] - [tdh02]:5801 [seatunnel] [5.1] deploying TaskGroup TaskGroupLocation{jobId=820733095626932237, pipelineId=1, taskGroupId=3} init success 2024-03-15 03:00:26,807 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-18] - [tdh02]:5801 [seatunnel] [5.1] deploying TaskGroup TaskGroupLocation{jobId=820733095626932237, pipelineId=1, taskGroupId=3} success 2024-03-15 03:00:28,136 INFO [.s.t.SourceSplitEnumeratorTask] [hz.main.seaTunnel.task.thread-1055] - received reader register, readerID: TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=820733095626932237, pipelineId=1, taskGroupId=50000}, taskID=60000, index=0} 2024-03-15 03:00:28,381 INFO [.s.t.SourceSplitEnumeratorTask] [BlockingWorker-TaskGroupLocation{jobId=820733095626932237, pipelineId=1, taskGroupId=1}] - starting seatunnel source split enumerator task, source name: pipeline-1 [Source[0]-Jdbc] 2024-03-15 03:00:30,211 INFO [.s.t.SourceSplitEnumeratorTask] [BlockingWorker-TaskGroupLocation{jobId=820733095626932237, pipelineId=1, taskGroupId=1}] - received enough reader, starting enumerator... 2024-03-15 03:00:30,211 INFO [.j.s.JdbcSourceSplitEnumerator] [BlockingWorker-TaskGroupLocation{jobId=820733095626932237, pipelineId=1, taskGroupId=1}] - Starting split enumerator. 2024-03-15 03:00:30,211 INFO [.j.s.JdbcSourceSplitEnumerator] [BlockingWorker-TaskGroupLocation{jobId=820733095626932237, pipelineId=1, taskGroupId=1}] - Splitting table default.default.default. 2024-03-15 03:00:30,212 INFO [o.a.s.c.s.j.s.ChunkSplitter ] [BlockingWorker-TaskGroupLocation{jobId=820733095626932237, pipelineId=1, taskGroupId=1}] - Start splitting table default.default.default into chunks... 2024-03-15 03:00:30,215 WARN [o.a.s.c.s.j.s.ChunkSplitter ] [BlockingWorker-TaskGroupLocation{jobId=820733095626932237, pipelineId=1, taskGroupId=1}] - No split key found for table default.default.default 2024-03-15 03:00:30,217 INFO [o.a.s.c.s.j.s.ChunkSplitter ] [BlockingWorker-TaskGroupLocation{jobId=820733095626932237, pipelineId=1, taskGroupId=1}] - Split table default.default.default into 1 chunks, time cost: 4ms. 2024-03-15 03:00:30,217 INFO [.j.s.JdbcSourceSplitEnumerator] [BlockingWorker-TaskGroupLocation{jobId=820733095626932237, pipelineId=1, taskGroupId=1}] - Split table default.default.default into 1 splits. 2024-03-15 03:00:30,273 INFO [.j.s.JdbcSourceSplitEnumerator] [BlockingWorker-TaskGroupLocation{jobId=820733095626932237, pipelineId=1, taskGroupId=1}] - No more splits to assign. Sending NoMoreSplitsEvent to reader [0]. 2024-03-15 03:00:33,762 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=820733095626932237, pipelineId=1, taskGroupId=1}] - [tdh02]:5801 [seatunnel] [5.1] taskDone, taskId = 20000, taskGroup = TaskGroupLocation{jobId=820733095626932237, pipelineId=1, taskGroupId=1} 2024-03-15 03:00:33,762 INFO [o.a.s.e.c.l.ClassLoaderUtil ] [BlockingWorker-TaskGroupLocation{jobId=820733095626932237, pipelineId=1, taskGroupId=1}] - recycle classloader org.apache.seatunnel.engine.common.loader.SeaTunnelChildFirstClassLoader@7ef62639 2024-03-15 03:00:33,798 INFO [o.a.s.e.c.l.ClassLoaderUtil ] [BlockingWorker-TaskGroupLocation{jobId=820733095626932237, pipelineId=1, taskGroupId=1}] - recycle classloader for thread BlockingWorker-TaskGroupLocation{jobId=820733095626932237, pipelineId=1, taskGroupId=1} 2024-03-15 03:00:33,798 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.seaTunnel.task.thread-1079] - [tdh02]:5801 [seatunnel] [5.1] Task TaskGroupLocation{jobId=820733095626932237, pipelineId=1, taskGroupId=1} complete with state FINISHED 2024-03-15 04:02:08,242 INFO [o.a.s.e.s.CoordinatorService ] [seatunnel-coordinator-service-9] - [tdh02]:5801 [seatunnel] [5.1] begin restore job (820733095626932237) from master active switch 2024-03-15 04:02:08,261 INFO [.e.s.r.AbstractResourceManager] [seatunnel-coordinator-service-9] - registerWorker: {[tdh02]:5801=WorkerProfile(address=[tdh02]:5801, profile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=12875464704}}, unassignedResource=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=12348030976}}, assignedSlots=[SlotProfile{worker=[tdh02]:5801, slotID=3585, ownerJobID=820733185707999234, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3841, ownerJobID=820748206705999885, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3842, ownerJobID=820748206441758721, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f- e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3843, ownerJobID=820748260334370829, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3844, ownerJobID=820748260334370829, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3845, ownerJobID=820748256781795332, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3846, ownerJobID=820748256781795332, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3847, ownerJobID=820748328496005121, assigned=true, resourceP rofile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3848, ownerJobID=820748332610617346, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3849, ownerJobID=820748360842477581, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3850, ownerJobID=820748360863449092, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3851, ownerJobID=820748365355548676, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'} , SlotProfile{worker=[tdh02]:5801, slotID=3852, ownerJobID=820748365355548676, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3853, ownerJobID=820748362583113729, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3854, ownerJobID=820748363925291023, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3855, ownerJobID=820748363925291023, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3856, ownerJobID=820748209939808269, assigned=true, resourceProfile=Resourc eProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3857, ownerJobID=820748360318189581, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3858, ownerJobID=820748365061947394, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=2067, ownerJobID=820397374420549633, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3859, ownerJobID=820748367859548164, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{ worker=[tdh02]:5801, slotID=3092, ownerJobID=820725748066156548, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3860, ownerJobID=820748367318482946, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3093, ownerJobID=820725748066156548, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3861, ownerJobID=820748367318482946, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3862, ownerJobID=820748367318482946, assigned=true, resourceProfile=ResourceProfile{cpu=C PU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3863, ownerJobID=820748374683680772, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3864, ownerJobID=820748400629645314, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3865, ownerJobID=820748369906368516, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3866, ownerJobID=820748404807172098, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02] :5801, slotID=3099, ownerJobID=820726349420298253, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3867, ownerJobID=820748404807172098, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3868, ownerJobID=820748382996791309, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3869, ownerJobID=820748384548683791, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3870, ownerJobID=820748383890178061, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, he apMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3871, ownerJobID=820748261320032258, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3634, ownerJobID=820733117751885825, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3387, ownerJobID=820727339120852996, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3646, ownerJobID=820733917806985217, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID= 3408, ownerJobID=820727402870079490, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=2432, ownerJobID=820695379543588867, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3713, ownerJobID=820734680784437250, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3714, ownerJobID=820733112651612164, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=2961, ownerJobID=820725689186516993, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memor y{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=2463, ownerJobID=820414059319918595, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=2464, ownerJobID=820414059319918595, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=1698, ownerJobID=820388673471119361, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3490, ownerJobID=820733095626932237, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3491, ownerJob ID=820733095626932237, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=2988, ownerJobID=820726031055847428, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=2989, ownerJobID=820725722652868611, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=2990, ownerJobID=820725547830083585, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3256, ownerJobID=820726573668761603, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, s equence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3515, ownerJobID=820733147632107535, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=450, ownerJobID=820365127281803266, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=451, ownerJobID=820365127281803266, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3524, ownerJobID=820733161867575298, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3525, ownerJobID=8207331618675 75298, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3014, ownerJobID=820397341071638531, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3015, ownerJobID=820257493400682499, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3024, ownerJobID=820725987577692173, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3025, ownerJobID=820725987577692173, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c5 2-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3819, ownerJobID=820748167522811908, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3820, ownerJobID=820748183507304463, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3821, ownerJobID=820748213060370433, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3823, ownerJobID=820748206903132161, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3824, ownerJobID=820748212586414084, assigne d=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3825, ownerJobID=820748208631185410, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3827, ownerJobID=820748219402158095, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3828, ownerJobID=820748206668251149, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3834, ownerJobID=820748205980385281, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-81 3f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3835, ownerJobID=820748217049153551, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3068, ownerJobID=820726344739454977, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3836, ownerJobID=820748221159571458, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3837, ownerJobID=820748234338074626, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3838, ownerJobID=820748241573249025, assigned=true, resour ceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}, SlotProfile{worker=[tdh02]:5801, slotID=3839, ownerJobID=820748241573249025, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='451c2c52-b20e-4ef6-813f-e43d7231aceb'}], unassignedSlots=[])} 2024-03-15 04:02:08,270 INFO [o.a.s.e.s.m.JobMaster ] [seatunnel-coordinator-service-9] - Init JobMaster for Job SeaTunnel_Job (820733095626932237) 2024-03-15 04:02:08,270 INFO [o.a.s.e.s.m.JobMaster ] [seatunnel-coordinator-service-9] - Job SeaTunnel_Job (820733095626932237) needed jar urls [file:/opt/seatunnel/connectors/connector-hive-2.3.4.jar, file:/opt/seatunnel/connectors/connector-jdbc-2.3.4.jar] 2024-03-15 04:02:10,227 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-9] - Create CheckpointCoordinator for job(1@820733095626932237) with plan(CheckpointPlan(pipelineId=1, pipelineSubtasks=[TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=820733095626932237, pipelineId=1, taskGroupId=3}, taskID=40000, index=0}, TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=820733095626932237, pipelineId=1, taskGroupId=50000}, taskID=60000, index=0}, TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=820733095626932237, pipelineId=1, taskGroupId=50000}, taskID=70000, index=0}, TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=820733095626932237, pipelineId=1, taskGroupId=1}, taskID=20000, index=0}], startingSubtasks=[TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=820733095626932237, pipelineId=1, taskGroupId=1}, taskID=20000, index=0}], pipelineActions={ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-Jdbc])=1, ActionStateKey(name=A ctionStateKey - pipeline-1 [Sink[0]-Hive])=1, ActionStateKey(name=ActionStateKey - pipeline-1 [TransformChain[Transform[0]-Sql->Transform[1]-FieldMapper]])=1}, subtaskActions={TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=820733095626932237, pipelineId=1, taskGroupId=3}, taskID=40000, index=0}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-Hive]), -1)], TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=820733095626932237, pipelineId=1, taskGroupId=50000}, taskID=60000, index=0}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-Jdbc]), 0), (ActionStateKey(name=ActionStateKey - pipeline-1 [TransformChain[Transform[0]-Sql->Transform[1]-FieldMapper]]), 0)], TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=820733095626932237, pipelineId=1, taskGroupId=50000}, taskID=70000, index=0}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-Hive]), 0)], TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=820733095626932237, pipelineId=1, taskG roupId=1}, taskID=20000, index=0}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-Jdbc]), -1)]})) 2024-03-15 04:02:11,221 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-9] - Restore job(1@820733095626932237) with checkpoint(9223372036854775807), data: CompletedCheckpoint(jobId=820733095626932237, pipelineId=1, checkpointId=9223372036854775807, triggerTimestamp=1710442829695, checkpointType=COMPLETED_POINT_TYPE, completedTimestamp=1710442831345, taskStates={ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-Jdbc])=ActionState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-Jdbc]), subtaskStates=[ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-Jdbc]), index=0)], coordinatorState=ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-Jdbc]), index=-1), parallelism=1), ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-Hive])=ActionState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-Hive]), subtaskStates=[ActionSubtaskState(stateKey=Ac tionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-Hive]), index=0)], coordinatorState=ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-Hive]), index=-1), parallelism=1), ActionStateKey(name=ActionStateKey - pipeline-1 [TransformChain[Transform[0]-Sql->Transform[1]-FieldMapper]])=ActionState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [TransformChain[Transform[0]-Sql->Transform[1]-FieldMapper]]), subtaskStates=[ActionSubtaskState(stateKey=ActionStateKey(name=ActionStateKey - pipeline-1 [TransformChain[Transform[0]-Sql->Transform[1]-FieldMapper]]), index=0)], coordinatorState=null, parallelism=1)}, taskStatistics={2=TaskStatistics(jobVertexId=2, subtaskStats=[SubtaskStatistics(subtaskIndex=0, ackTimestamp=1710442829938, stateSize=1, subtaskStatus=RUNNING)], subtaskCompleted=[false], numAcknowledgedSubtasks=1, latestAckedSubtaskStatistics=null), 4=TaskStatistics(jobVertexId=4, subtaskStats=[SubtaskStatistics(subtaskIndex=0, ackTimes tamp=1710442831058, stateSize=1, subtaskStatus=RUNNING)], subtaskCompleted=[false], numAcknowledgedSubtasks=1, latestAckedSubtaskStatistics=null), 6=TaskStatistics(jobVertexId=6, subtaskStats=[SubtaskStatistics(subtaskIndex=0, ackTimestamp=1710442829824, stateSize=0, subtaskStatus=RUNNING)], subtaskCompleted=[false], numAcknowledgedSubtasks=1, latestAckedSubtaskStatistics=null), 7=TaskStatistics(jobVertexId=7, subtaskStats=[SubtaskStatistics(subtaskIndex=0, ackTimestamp=1710442831345, stateSize=1, subtaskStatus=RUNNING)], subtaskCompleted=[false], numAcknowledgedSubtasks=1, latestAckedSubtaskStatistics=null)}, isRestored=true) 2024-03-15 04:02:11,226 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-9] - Turn checkpoint_state_820733095626932237_1 state from FINISHED to RUNNING 2024-03-15 04:02:11,231 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-9] - The task Job SeaTunnel_Job (820733095626932237), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc]-SourceTask (1/1)] is in state CREATED when init state future 2024-03-15 04:02:11,235 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-9] - The task Job SeaTunnel_Job (820733095626932237), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc]-SplitEnumerator (1/1)] is in state CREATED when init state future 2024-03-15 04:02:11,263 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-9] - The task Job SeaTunnel_Job (820733095626932237), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Hive]-AggregatedCommitterTask (1/1)] is in state CREATED when init state future 2024-03-15 04:02:11,263 INFO [o.a.s.e.s.CoordinatorService ] [seatunnel-coordinator-service-9] - [tdh02]:5801 [seatunnel] [5.1] The restore Job SeaTunnel_Job (820733095626932237) is in RUNNING state, restore pipeline and take over this job running 2024-03-15 04:02:11,263 INFO [o.a.s.e.s.CoordinatorService ] [seatunnel-coordinator-service-9] - [tdh02]:5801 [seatunnel] [5.1] restore job (820733095626932237) from master active switch finished 2024-03-15 04:02:11,266 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-54] - Job SeaTunnel_Job (820733095626932237), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc]-SourceTask (1/1)] state process is start 2024-03-15 04:02:11,266 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-54] - Job SeaTunnel_Job (820733095626932237), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc]-SplitEnumerator (1/1)] state process is start 2024-03-15 04:02:11,266 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-54] - Job SeaTunnel_Job (820733095626932237), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Hive]-AggregatedCommitterTask (1/1)] state process is start 2024-03-15 04:02:11,267 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-54] - Turn checkpoint_state_820733095626932237_1 state from RUNNING to RUNNING 2024-03-15 04:02:11,267 INFO [o.a.s.e.s.d.p.SubPlan ] [seatunnel-coordinator-service-54] - Job SeaTunnel_Job (820733095626932237), Pipeline: [(1/1)] state process is start 2024-03-15 04:02:11,267 INFO [o.a.s.e.s.d.p.PhysicalPlan ] [seatunnel-coordinator-service-54] - Job SeaTunnel_Job (820733095626932237) state process is start 2024-03-15 09:00:59,970 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-24] - [tdh02]:5801 [seatunnel] [5.1] deploying task TaskGroupLocation{jobId=820733095626932237, pipelineId=1, taskGroupId=3}, executionId [820823359915163649] 2024-03-15 09:00:59,971 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-24] - [tdh02]:5801 [seatunnel] [5.1] deploying TaskGroup TaskGroupLocation{jobId=820733095626932237, pipelineId=1, taskGroupId=3} init success 2024-03-15 09:00:59,978 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-24] - [tdh02]:5801 [seatunnel] [5.1] deploying TaskGroup TaskGroupLocation{jobId=820733095626932237, pipelineId=1, taskGroupId=3} success 2024-03-15 09:01:03,312 WARN [.c.s.f.h.HadoopFileSystemProxy] [hz.main.seaTunnel.task.thread-2] - rename file :[/tmp/seatunnel/seatunnel/820733095626932237/507928b67a/T_820733095626932237_507928b67a_0_1/pt=2024-03-15/T_820733095626932237_507928b67a_0_1_0.orc] to [/quark1/user/hive/warehouse/cfd.db/hive/ods_cfdny_t_v_b_cd_df_tmp_3182d577b217458ebb8b367209a3b9c1/pt=2024-03-15/T_820733095626932237_507928b67a_0_1_0.orc] already finished in the last commit, skip ``` ### Zeta or Flink or Spark Version zeta ### Java or Scala Version JDK8 ### Screenshots <img width="859" alt="b9332e319114cd0b12d50573eabe4fc" src="https://github.com/apache/seatunnel/assets/36808178/5061b421-5e6e-4224-8f42-222da721c60f";> <img width="323" alt="1e79e88aea7a91a8fe63406c10b5d93" src="https://github.com/apache/seatunnel/assets/36808178/e5096c43-fa80-4e22-ac7d-3ee5a7830719";> <img width="1040" alt="8b167c4fa798de87116a180885f1d9f" src="https://github.com/apache/seatunnel/assets/36808178/72ea553f-8cac-4056-93dc-df7da3f0b2cc";> <img width="743" alt="25b95964c49269b01b097e6c8bf8357" src="https://github.com/apache/seatunnel/assets/36808178/c604483b-6ff5-4bc4-acfa-25ba7a85e994";> <img width="131" alt="b151175342e3d0ef47237fb94608b6b" src="https://github.com/apache/seatunnel/assets/36808178/7f76f4c5-da4a-451a-b99b-708b35f1975e";> <img width="743" alt="758bc49043b643ebee79cb525cafb83" src="https://github.com/apache/seatunnel/assets/36808178/f1931bfb-7ea1-4149-8b51-925c4b2b8d8d";> <img width="480" alt="d22847408a8003f1784c1c54e43fe4a" src="https://github.com/apache/seatunnel/assets/36808178/220bfa3a-2005-4c9d-bd4a-405554c2a3fe";> ### 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]
