Apache Seatunnel 抽取Oracle數(shù)據(jù)庫測試準(zhǔn)備測試數(shù)據(jù)create tablespace testtbs datafile /data/oradata/SJZTNCDB/testtbs01.dbf size 1024m autoextend on next 10m; create user anger identified by Bai_yun123 default tablespace testtbs; grant connect,resource to anger; grant dba to anger; CREATE TABLE TEST_CDC_ORDERS ( ID NUMBER(20) PRIMARY KEY, ORDER_NO VARCHAR2(50) NOT NULL, CUSTOMER_NAME VARCHAR2(100), AMOUNT NUMBER(18,2), STATUS VARCHAR2(20), PHONE VARCHAR2(30), ADDRESS VARCHAR2(500), CREATE_TIME TIMESTAMP DEFAULT SYSTIMESTAMP, UPDATE_TIME TIMESTAMP DEFAULT SYSTIMESTAMP, DESCRIPTION VARCHAR2(1000) ); CREATE INDEX IDX_TEST_CDC_ORDERS_CREATE_TIME ON TEST_CDC_ORDERS(CREATE_TIME); CREATE INDEX IDX_TEST_CDC_ORDERS_STATUS ON TEST_CDC_ORDERS(STATUS); INSERT /* APPEND */ INTO TEST_CDC_ORDERS ( ID, ORDER_NO, CUSTOMER_NAME, AMOUNT, STATUS, PHONE, ADDRESS, CREATE_TIME, UPDATE_TIME, DESCRIPTION ) SELECT LEVEL AS ID, ORD || LPAD(LEVEL, 12, 0) AS ORDER_NO, CUSTOMER_ || MOD(LEVEL, 100000) AS CUSTOMER_NAME, ROUND(DBMS_RANDOM.VALUE(10, 10000), 2) AS AMOUNT, CASE MOD(LEVEL, 5) WHEN 0 THEN NEW WHEN 1 THEN PAID WHEN 2 THEN SHIPPED WHEN 3 THEN COMPLETED ELSE CANCELLED END AS STATUS, 138 || LPAD(MOD(LEVEL, 100000000), 8, 0) AS PHONE, ADDRESS_ || MOD(LEVEL, 10000) AS ADDRESS, SYSTIMESTAMP - NUMTODSINTERVAL(MOD(LEVEL, 86400), SECOND) AS CREATE_TIME, SYSTIMESTAMP AS UPDATE_TIME, CDC_TEST_DATA_ || LEVEL AS DESCRIPTION FROM DUAL CONNECT BY LEVEL 10000; COMMIT; SQL select count(*) from TEST_CDC_ORDERS; COUNT(*) ---------- 10000準(zhǔn)備抽取配置文件Capture-oracle-test.confcat Capture-oracle-test.confenv { # 并行度 execution.parallelism 2 scn.storage file scn.file.path /data/apache-seatunnel-2.3.12/scn_oracle/oracle_cdc.scn # 批處理模式 job.mode BATCH } source { Jdbc { # Oracle JDBC 連接 url jdbc:oracle:thin://127.0.0.1:1521/sjztncdb # Oracle JDBC Driver driver oracle.jdbc.OracleDriver # Oracle 用戶 user anger # Oracle 密碼 password Bai_yun123 # 抽取 SQL query SELECT * FROM TEST_CDC_ORDERS # 連接參數(shù) connection_check_timeout_sec 300 properties { # Oracle 建議使用 oracle.net.CONNECT_TIMEOUT 30000 oracle.jdbc.ReadTimeout 300000 } } } sink { Console {} }準(zhǔn)備驅(qū)動文件# mv /home/maintain/ojdbc8.jar ./ # ll total 201464 -rw-r--r-- 1 root root 2481560 Aug 30 23:44 mysql-connector-j-8.0.33.jar -rw-r----- 1 maintain maintain 7650635 Sep 2 00:30 ojdbc8.jar -rw-r--r-- 1 root root 43209805 Nov 9 2023 seatunnel-hadoop3-3.1.4-uber.jar -rw-r--r-- 1 root root 86818044 Nov 9 2023 seatunnel-hadoop-aws.jar -rw-r--r-- 1 root root 66131549 Nov 9 2023 seatunnel-transforms-v2.jar測試運行/data/apache-seatunnel-2.3.12/bin/seatunnel.sh \ --config /data/apache-seatunnel-2.3.12/config/Capture-oracle-test.conf \ -m local查看日志記錄.....省略一大段 elRow#kindINSERT : 9989, ORD000000009989, CUSTOMER_9989, 1345.05, CANCELLED, 13800009989, ADDRESS_9989, 2026-09-01T21:35:34.286173, 2026-09-02T00:22:03.286173, CDC_TEST_DATA_9989 2026-09-02 00:31:31,790 INFO [.a.s.c.s.c.s.ConsoleSinkWriter] [st-multi-table-sink-writer-1] - subtaskIndex0 rowIndex9990: SeaTunnelRow#tableIddefault.default.default SeaTunnelRow#kindINSERT : 9990, ORD000000009990, CUSTOMER_9990, 5896.3, NEW, 13800009990, ADDRESS_9990, 2026-09-01T21:35:33.286173, 2026-09-02T00:22:03.286173, CDC_TEST_DATA_9990 2026-09-02 00:31:31,790 INFO [.a.s.c.s.c.s.ConsoleSinkWriter] [st-multi-table-sink-writer-1] - subtaskIndex0 rowIndex9991: SeaTunnelRow#tableIddefault.default.default SeaTunnelRow#kindINSERT : 9991, ORD000000009991, CUSTOMER_9991, 9004.17, PAID, 13800009991, ADDRESS_9991, 2026-09-01T21:35:32.286173, 2026-09-02T00:22:03.286173, CDC_TEST_DATA_9991 2026-09-02 00:31:31,790 INFO [.a.s.c.s.c.s.ConsoleSinkWriter] [st-multi-table-sink-writer-1] - subtaskIndex0 rowIndex9992: SeaTunnelRow#tableIddefault.default.default SeaTunnelRow#kindINSERT : 9992, ORD000000009992, CUSTOMER_9992, 4452.19, SHIPPED, 13800009992, ADDRESS_9992, 2026-09-01T21:35:31.286173, 2026-09-02T00:22:03.286173, CDC_TEST_DATA_9992 2026-09-02 00:31:31,790 INFO [.a.s.c.s.c.s.ConsoleSinkWriter] [st-multi-table-sink-writer-1] - subtaskIndex0 rowIndex9993: SeaTunnelRow#tableIddefault.default.default SeaTunnelRow#kindINSERT : 9993, ORD000000009993, CUSTOMER_9993, 2210.03, COMPLETED, 13800009993, ADDRESS_9993, 2026-09-01T21:35:30.286173, 2026-09-02T00:22:03.286173, CDC_TEST_DATA_9993 2026-09-02 00:31:31,790 INFO [.a.s.c.s.c.s.ConsoleSinkWriter] [st-multi-table-sink-writer-1] - subtaskIndex0 rowIndex9994: SeaTunnelRow#tableIddefault.default.default SeaTunnelRow#kindINSERT : 9994, ORD000000009994, CUSTOMER_9994, 7034.16, CANCELLED, 13800009994, ADDRESS_9994, 2026-09-01T21:35:29.286173, 2026-09-02T00:22:03.286173, CDC_TEST_DATA_9994 2026-09-02 00:31:31,790 INFO [.a.s.c.s.c.s.ConsoleSinkWriter] [st-multi-table-sink-writer-1] - subtaskIndex0 rowIndex9995: SeaTunnelRow#tableIddefault.default.default SeaTunnelRow#kindINSERT : 9995, ORD000000009995, CUSTOMER_9995, 6112.47, NEW, 13800009995, ADDRESS_9995, 2026-09-01T21:35:28.286173, 2026-09-02T00:22:03.286173, CDC_TEST_DATA_9995 2026-09-02 00:31:31,790 INFO [.a.s.c.s.c.s.ConsoleSinkWriter] [st-multi-table-sink-writer-1] - subtaskIndex0 rowIndex9996: SeaTunnelRow#tableIddefault.default.default SeaTunnelRow#kindINSERT : 9996, ORD000000009996, CUSTOMER_9996, 4255.93, PAID, 13800009996, ADDRESS_9996, 2026-09-01T21:35:27.286173, 2026-09-02T00:22:03.286173, CDC_TEST_DATA_9996 2026-09-02 00:31:31,790 INFO [.a.s.c.s.c.s.ConsoleSinkWriter] [st-multi-table-sink-writer-1] - subtaskIndex0 rowIndex9997: SeaTunnelRow#tableIddefault.default.default SeaTunnelRow#kindINSERT : 9997, ORD000000009997, CUSTOMER_9997, 5822.19, SHIPPED, 13800009997, ADDRESS_9997, 2026-09-01T21:35:26.286173, 2026-09-02T00:22:03.286173, CDC_TEST_DATA_9997 2026-09-02 00:31:31,790 INFO [.a.s.c.s.c.s.ConsoleSinkWriter] [st-multi-table-sink-writer-1] - subtaskIndex0 rowIndex9998: SeaTunnelRow#tableIddefault.default.default SeaTunnelRow#kindINSERT : 9998, ORD000000009998, CUSTOMER_9998, 3034.59, COMPLETED, 13800009998, ADDRESS_9998, 2026-09-01T21:35:25.286173, 2026-09-02T00:22:03.286173, CDC_TEST_DATA_9998 2026-09-02 00:31:31,790 INFO [.a.s.c.s.c.s.ConsoleSinkWriter] [st-multi-table-sink-writer-1] - subtaskIndex0 rowIndex9999: SeaTunnelRow#tableIddefault.default.default SeaTunnelRow#kindINSERT : 9999, ORD000000009999, CUSTOMER_9999, 351.24, CANCELLED, 13800009999, ADDRESS_9999, 2026-09-01T21:35:24.286173, 2026-09-02T00:22:03.286173, CDC_TEST_DATA_9999 2026-09-02 00:31:31,790 INFO [.a.s.c.s.c.s.ConsoleSinkWriter] [st-multi-table-sink-writer-1] - subtaskIndex0 rowIndex10000: SeaTunnelRow#tableIddefault.default.default SeaTunnelRow#kindINSERT : 10000, ORD000000010000, CUSTOMER_10000, 8839.98, NEW, 13800010000, ADDRESS_0, 2026-09-01T21:35:23.286173, 2026-09-02T00:22:03.286173, CDC_TEST_DATA_10000 2026-09-02 00:31:31,876 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-8] - pending checkpoint(9223372036854775807/11147207106223407105) notify finished! 2026-09-02 00:31:31,876 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-8] - start notify checkpoint completed, job id: 1147207106223407105, pipeline id: 1, checkpoint id:9223372036854775807 2026-09-02 00:31:31,883 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-8] - start clean pending checkpoint cause CheckpointCoordinator completed. 2026-09-02 00:31:31,884 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-8] - Turn checkpoint_state_1147207106223407105_1 state from null to FINISHED 2026-09-02 00:31:31,895 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId1147207106223407105, pipelineId1, taskGroupId1}] - [localhost]:5802 [seatunnel-271485] [5.1] taskDone, taskId 1000100000000, taskGroup TaskGroupLocation{jobId1147207106223407105, pipelineId1, taskGroupId1} 2026-09-02 00:31:31,896 INFO [o.a.s.a.e.LoggingEventHandler ] [hz.main.generic-operation.thread-34] - log event: EnumeratorCloseEvent(createdTime1788280291895, jobId1147207106223407105, eventTypeLIFECYCLE_ENUMERATOR_CLOSE) 2026-09-02 00:31:31,900 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId1147207106223407105, pipelineId1, taskGroupId1}] - [localhost]:5802 [seatunnel-271485] [5.1] taskGroup TaskGroupLocation{jobId1147207106223407105, pipelineId1, taskGroupId1} complete with FINISHED 2026-09-02 00:31:31,901 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.seaTunnel.task.thread-5] - [localhost]:5802 [seatunnel-271485] [5.1] Task TaskGroupLocation{jobId1147207106223407105, pipelineId1, taskGroupId1} complete with state FINISHED 2026-09-02 00:31:31,901 INFO [o.a.s.e.s.CoordinatorService ] [hz.main.seaTunnel.task.thread-5] - [localhost]:5802 [seatunnel-271485] [5.1] Received task end from execution TaskGroupLocation{jobId1147207106223407105, pipelineId1, taskGroupId1}, state FINISHED 2026-09-02 00:31:31,903 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [hz.main.seaTunnel.task.thread-5] - Job (1147207106223407105), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc]-SplitEnumerator (1/1)], taskGroupLocation: [TaskGroupLocation{jobId1147207106223407105, pipelineId1, taskGroupId1}] turned from state RUNNING to FINISHED. 2026-09-02 00:31:31,903 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [hz.main.seaTunnel.task.thread-5] - Job (1147207106223407105), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc]-SplitEnumerator (1/1)], taskGroupLocation: [TaskGroupLocation{jobId1147207106223407105, pipelineId1, taskGroupId1}] state process is stopped 2026-09-02 00:31:31,904 INFO [o.a.s.e.s.d.p.SubPlan ] [seatunnel-coordinator-service-8] - Job (1147207106223407105), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc]-SplitEnumerator (1/1)], taskGroupLocation: [TaskGroupLocation{jobId1147207106223407105, pipelineId1, taskGroupId1}] future complete with state FINISHED 2026-09-02 00:31:31,946 INFO [o.a.s.a.e.LoggingEventHandler ] [hz.main.generic-operation.thread-35] - log event: ReaderCloseEvent(createdTime1788280291946, jobId1147207106223407105, eventTypeLIFECYCLE_READER_CLOSE) 2026-09-02 00:31:31,948 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId1147207106223407105, pipelineId1, taskGroupId2}] - [localhost]:5802 [seatunnel-271485] [5.1] taskDone, taskId 1000200000000, taskGroup TaskGroupLocation{jobId1147207106223407105, pipelineId1, taskGroupId2} 2026-09-02 00:31:31,978 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId1147207106223407105, pipelineId1, taskGroupId2}] - [localhost]:5802 [seatunnel-271485] [5.1] taskDone, taskId 1000200010000, taskGroup TaskGroupLocation{jobId1147207106223407105, pipelineId1, taskGroupId2} 2026-09-02 00:31:31,979 INFO [o.a.s.a.e.LoggingEventHandler ] [hz.main.generic-operation.thread-36] - log event: WriterCloseEvent(createdTime1788280291978, jobId1147207106223407105, eventTypeLIFECYCLE_WRITER_CLOSE) 2026-09-02 00:31:31,981 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId1147207106223407105, pipelineId1, taskGroupId2}] - [localhost]:5802 [seatunnel-271485] [5.1] taskGroup TaskGroupLocation{jobId1147207106223407105, pipelineId1, taskGroupId2} complete with FINISHED 2026-09-02 00:31:31,981 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.seaTunnel.task.thread-3] - [localhost]:5802 [seatunnel-271485] [5.1] Task TaskGroupLocation{jobId1147207106223407105, pipelineId1, taskGroupId2} complete with state FINISHED 2026-09-02 00:31:31,981 INFO [o.a.s.e.s.CoordinatorService ] [hz.main.seaTunnel.task.thread-3] - [localhost]:5802 [seatunnel-271485] [5.1] Received task end from execution TaskGroupLocation{jobId1147207106223407105, pipelineId1, taskGroupId2}, state FINISHED 2026-09-02 00:31:31,983 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [hz.main.seaTunnel.task.thread-3] - Job (1147207106223407105), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc]-SourceTask (1/1)], taskGroupLocation: [TaskGroupLocation{jobId1147207106223407105, pipelineId1, taskGroupId2}] turned from state RUNNING to FINISHED. 2026-09-02 00:31:31,983 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [hz.main.seaTunnel.task.thread-3] - Job (1147207106223407105), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc]-SourceTask (1/1)], taskGroupLocation: [TaskGroupLocation{jobId1147207106223407105, pipelineId1, taskGroupId2}] state process is stopped 2026-09-02 00:31:31,983 INFO [o.a.s.e.s.d.p.SubPlan ] [seatunnel-coordinator-service-8] - Job (1147207106223407105), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc]-SourceTask (1/1)], taskGroupLocation: [TaskGroupLocation{jobId1147207106223407105, pipelineId1, taskGroupId2}] future complete with state FINISHED 2026-09-02 00:31:31,983 INFO [o.a.s.e.s.d.p.SubPlan ] [seatunnel-coordinator-service-8] - Job SeaTunnel_Job (1147207106223407105), Pipeline: [(1/1)] will end with state FINISHED 2026-09-02 00:31:31,984 INFO [o.a.s.e.s.m.JobMaster ] [hz.main.seaTunnel.task.thread-3] - release the task group resource TaskGroupLocation{jobId1147207106223407105, pipelineId1, taskGroupId2} 2026-09-02 00:31:31,984 INFO [o.a.s.e.s.d.p.SubPlan ] [seatunnel-coordinator-service-8] - Job SeaTunnel_Job (1147207106223407105), Pipeline: [(1/1)] turned from state RUNNING to FINISHED. 2026-09-02 00:31:31,984 INFO [a.s.e.s.s.s.DefaultSlotService] [hz.main.generic-operation.thread-37] - received slot release request, jobID: 1147207106223407105, slot: SlotProfile{worker[localhost]:5802, slotID2, ownerJobID1147207106223407105, assignedtrue, resourceProfileResourceProfile{cpuCPU{core0}, heapMemoryMemory{bytes0}}, sequence950414ef-334b-4dc2-9816-26139b5e5c1d} 2026-09-02 00:31:32,032 INFO [o.a.s.e.s.m.JobMaster ] [seatunnel-coordinator-service-8] - release the pipeline Job SeaTunnel_Job (1147207106223407105), Pipeline: [(1/1)] resource 2026-09-02 00:31:32,032 INFO [a.s.e.s.s.s.DefaultSlotService] [hz.main.generic-operation.thread-41] - received slot release request, jobID: 1147207106223407105, slot: SlotProfile{worker[localhost]:5802, slotID1, ownerJobID1147207106223407105, assignedtrue, resourceProfileResourceProfile{cpuCPU{core0}, heapMemoryMemory{bytes0}}, sequence950414ef-334b-4dc2-9816-26139b5e5c1d} 2026-09-02 00:31:32,033 INFO [o.a.s.e.s.d.p.SubPlan ] [seatunnel-coordinator-service-8] - Job SeaTunnel_Job (1147207106223407105), Pipeline: [(1/1)] state process is stop 2026-09-02 00:31:32,033 INFO [o.a.s.e.s.d.p.PhysicalPlan ] [seatunnel-coordinator-service-9] - Job SeaTunnel_Job (1147207106223407105), Pipeline: [(1/1)] future complete with state FINISHED 2026-09-02 00:31:32,034 INFO [o.a.s.e.s.d.p.PhysicalPlan ] [seatunnel-coordinator-service-9] - Job SeaTunnel_Job (1147207106223407105) turned from state RUNNING to FINISHED. 2026-09-02 00:31:32,034 INFO [o.a.s.e.s.d.p.PhysicalPlan ] [seatunnel-coordinator-service-9] - Job SeaTunnel_Job (1147207106223407105) state process is stop 2026-09-02 00:31:32,049 INFO [o.a.s.a.e.LoggingEventHandler ] [seatunnel-coordinator-service-9] - log event: JobStateEvent(jobId1147207106223407105, jobNameSeaTunnel_Job, jobStatusFINISHED, createdTime1788280292049) 2026-09-02 00:31:32,050 INFO [o.a.s.e.c.j.ClientJobProxy ] [main] - Job (1147207106223407105) end with state FINISHED 2026-09-02 00:31:32,084 INFO [s.c.s.s.c.ClientExecuteCommand] [main] - *********************************************** Job Statistic Information *********************************************** Start Time : 2026-09-02 00:31:28 End Time : 2026-09-02 00:31:32 Total Time(s) : 3 Total Read Count : 10000 Total Write Count : 10000 Total Failed Count : 0 *********************************************** 2026-09-02 00:31:32,084 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel-271485] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is SHUTTING_DOWN 2026-09-02 00:31:32,089 INFO [c.h.i.s.t.TcpServerConnection ] [hz.main.IO.thread-in-0] - [localhost]:5802 [seatunnel-271485] [5.1] Connection[id2, /127.0.0.1:5802-/127.0.0.1:55573, qualifiernull, endpoint[127.0.0.1]:55573, remoteUuid477d9a34-c271-435b-a15c-845bb33872b7, alivefalse, connectionTypeJVM, planeIndex-1] closed. Reason: Connection closed by the other side 2026-09-02 00:31:32,090 INFO [.c.i.c.ClientConnectionManager] [main] - hz.client_1 [seatunnel-271485] [5.1] Removed connection to endpoint: [localhost]:5802:7f693074-433f-42f7-a077-a73c966936ef, connection: ClientConnection{alivefalse, connectionId1, channelNioChannel{/127.0.0.1:55573-localhost/127.0.0.1:5802}, remoteAddress[localhost]:5802, lastReadTime2026-09-02 00:31:32.079, lastWriteTime2026-09-02 00:31:32.050, closedTime2026-09-02 00:31:32.085, connected server version5.1} 2026-09-02 00:31:32,090 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel-271485] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is CLIENT_DISCONNECTED 2026-09-02 00:31:32,090 INFO [c.h.c.i.ClientEndpointManager ] [hz.main.event-4] - [localhost]:5802 [seatunnel-271485] [5.1] Destroying ClientEndpoint{connectionConnection[id2, /127.0.0.1:5802-/127.0.0.1:55573, qualifiernull, endpoint[127.0.0.1]:55573, remoteUuid477d9a34-c271-435b-a15c-845bb33872b7, alivefalse, connectionTypeJVM, planeIndex-1], clientUuid477d9a34-c271-435b-a15c-845bb33872b7, clientNamehz.client_1, authenticatedtrue, clientVersion5.1, creationTime1788280288130, latest clientAttributeslastStatisticsCollectionTime1788280288163,enterprisefalse,clientTypeJVM,clientVersion5.1,clusterConnectionTimestamp1788280288121,clientAddress127.0.0.1,clientNamehz.client_1,credentials.principalnull,os.committedVirtualMemorySize10915172352,os.freePhysicalMemorySize1284915200,os.freeSwapSpaceSize876158976,os.maxFileDescriptorCount1000000,os.openFileDescriptorCount55,os.processCpuTime7890000000,os.systemLoadAverage1.24,os.totalPhysicalMemorySize33812103168,os.totalSwapSpaceSize8585736192,runtime.availableProcessors16,runtime.freeMemory224300928,runtime.maxMemory477626368,runtime.totalMemory331874304,runtime.uptime3912,runtime.usedMemory107573376, labels[]} 2026-09-02 00:31:32,093 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel-271485] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is SHUTDOWN 2026-09-02 00:31:32,093 INFO [s.c.s.s.c.ClientExecuteCommand] [main] - Closed SeaTunnel client...... 2026-09-02 00:31:32,093 INFO [c.h.c.LifecycleService ] [main] - [localhost]:5802 [seatunnel-271485] [5.1] [localhost]:5802 is SHUTTING_DOWN 2026-09-02 00:31:32,097 INFO [c.h.i.p.i.MigrationManager ] [hz.main.cached.thread-3] - [localhost]:5802 [seatunnel-271485] [5.1] Shutdown request of Member [localhost]:5802 - 7f693074-433f-42f7-a077-a73c966936ef [master node] [active master] this is handled 2026-09-02 00:31:32,103 INFO [c.h.i.i.Node ] [main] - [localhost]:5802 [seatunnel-271485] [5.1] Shutting down connection manager... 2026-09-02 00:31:32,105 INFO [c.h.i.i.Node ] [main] - [localhost]:5802 [seatunnel-271485] [5.1] Shutting down node engine... 2026-09-02 00:31:32,116 INFO [.s.s.o.e.j.s.AbstractConnector] [main] - Stopped ServerConnector47311277{HTTP/1.1, (http/1.1)}{0.0.0.0:8080} 2026-09-02 00:31:32,117 INFO [o.a.s.s.o.e.j.s.session ] [main] - node0 Stopped scavenging 2026-09-02 00:31:32,117 INFO [a.s.s.o.e.j.s.h.ContextHandler] [main] - Stopped o.a.s.s.o.e.j.s.ServletContextHandler2fd72332{/,null,STOPPED} 2026-09-02 00:31:32,120 INFO [.c.c.DefaultClassLoaderService] [main] - close classloader service 2026-09-02 00:31:32,121 INFO [o.a.s.e.s.EventService ] [event-forwarder-0] - Event forward thread interrupted 2026-09-02 00:31:33,435 INFO [c.h.i.i.NodeExtension ] [main] - [localhost]:5802 [seatunnel-271485] [5.1] Destroying node NodeExtension. 2026-09-02 00:31:33,436 INFO [c.h.i.i.Node ] [main] - [localhost]:5802 [seatunnel-271485] [5.1] Hazelcast Shutdown is completed in 1339 ms. 2026-09-02 00:31:33,436 INFO [c.h.c.LifecycleService ] [main] - [localhost]:5802 [seatunnel-271485] [5.1] [localhost]:5802 is SHUTDOWN 2026-09-02 00:31:33,436 INFO [s.c.s.s.c.ClientExecuteCommand] [main] - Closed HazelcastInstance ...... 2026-09-02 00:31:33,436 INFO [s.c.s.s.c.ClientExecuteCommand] [main] - Closed metrics executor service ...... 2026-09-02 00:31:33,438 INFO [s.c.s.s.c.ClientExecuteCommand] [SeaTunnel-CompletableFuture-Thread-7] - run shutdown hook because get close signal測試抽取驗證成功。