企业官网建设流程全解析

Apache Seatunnel 抽取Oracle数据库测试

准备测试数据

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

准备抽取配置文件Capture-oracle-test.conf

cat Capture-oracle-test.conf

env { # 并行度 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" # 连接参数 connection_check_timeout_sec = 300 properties = { # Oracle 建议使用 oracle.net.CONNECT_TIMEOUT = 30000 oracle.jdbc.ReadTimeout = 300000 } } } sink { Console {} }

准备驱动文件

# 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#kind=INSERT : 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] - subtaskIndex=0 rowIndex=9990: SeaTunnelRow#tableId=default.default.default SeaTunnelRow#kind=INSERT : 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] - subtaskIndex=0 rowIndex=9991: SeaTunnelRow#tableId=default.default.default SeaTunnelRow#kind=INSERT : 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] - subtaskIndex=0 rowIndex=9992: SeaTunnelRow#tableId=default.default.default SeaTunnelRow#kind=INSERT : 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] - subtaskIndex=0 rowIndex=9993: SeaTunnelRow#tableId=default.default.default SeaTunnelRow#kind=INSERT : 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] - subtaskIndex=0 rowIndex=9994: SeaTunnelRow#tableId=default.default.default SeaTunnelRow#kind=INSERT : 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] - subtaskIndex=0 rowIndex=9995: SeaTunnelRow#tableId=default.default.default SeaTunnelRow#kind=INSERT : 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] - subtaskIndex=0 rowIndex=9996: SeaTunnelRow#tableId=default.default.default SeaTunnelRow#kind=INSERT : 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] - subtaskIndex=0 rowIndex=9997: SeaTunnelRow#tableId=default.default.default SeaTunnelRow#kind=INSERT : 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] - subtaskIndex=0 rowIndex=9998: SeaTunnelRow#tableId=default.default.default SeaTunnelRow#kind=INSERT : 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] - subtaskIndex=0 rowIndex=9999: SeaTunnelRow#tableId=default.default.default SeaTunnelRow#kind=INSERT : 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] - subtaskIndex=0 rowIndex=10000: SeaTunnelRow#tableId=default.default.default SeaTunnelRow#kind=INSERT : 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/1@1147207106223407105) 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{jobId=1147207106223407105, pipelineId=1, taskGroupId=1}] - [localhost]:5802 [seatunnel-271485] [5.1] taskDone, taskId = 1000100000000, taskGroup = TaskGroupLocation{jobId=1147207106223407105, pipelineId=1, taskGroupId=1} 2026-09-02 00:31:31,896 INFO [o.a.s.a.e.LoggingEventHandler ] [hz.main.generic-operation.thread-34] - log event: EnumeratorCloseEvent(createdTime=1788280291895, jobId=1147207106223407105, eventType=LIFECYCLE_ENUMERATOR_CLOSE) 2026-09-02 00:31:31,900 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1147207106223407105, pipelineId=1, taskGroupId=1}] - [localhost]:5802 [seatunnel-271485] [5.1] taskGroup TaskGroupLocation{jobId=1147207106223407105, pipelineId=1, taskGroupId=1} 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{jobId=1147207106223407105, pipelineId=1, taskGroupId=1} 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{jobId=1147207106223407105, pipelineId=1, taskGroupId=1}, 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{jobId=1147207106223407105, pipelineId=1, taskGroupId=1}] 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{jobId=1147207106223407105, pipelineId=1, taskGroupId=1}] 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{jobId=1147207106223407105, pipelineId=1, taskGroupId=1}] 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(createdTime=1788280291946, jobId=1147207106223407105, eventType=LIFECYCLE_READER_CLOSE) 2026-09-02 00:31:31,948 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1147207106223407105, pipelineId=1, taskGroupId=2}] - [localhost]:5802 [seatunnel-271485] [5.1] taskDone, taskId = 1000200000000, taskGroup = TaskGroupLocation{jobId=1147207106223407105, pipelineId=1, taskGroupId=2} 2026-09-02 00:31:31,978 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1147207106223407105, pipelineId=1, taskGroupId=2}] - [localhost]:5802 [seatunnel-271485] [5.1] taskDone, taskId = 1000200010000, taskGroup = TaskGroupLocation{jobId=1147207106223407105, pipelineId=1, taskGroupId=2} 2026-09-02 00:31:31,979 INFO [o.a.s.a.e.LoggingEventHandler ] [hz.main.generic-operation.thread-36] - log event: WriterCloseEvent(createdTime=1788280291978, jobId=1147207106223407105, eventType=LIFECYCLE_WRITER_CLOSE) 2026-09-02 00:31:31,981 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1147207106223407105, pipelineId=1, taskGroupId=2}] - [localhost]:5802 [seatunnel-271485] [5.1] taskGroup TaskGroupLocation{jobId=1147207106223407105, pipelineId=1, taskGroupId=2} 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{jobId=1147207106223407105, pipelineId=1, taskGroupId=2} 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{jobId=1147207106223407105, pipelineId=1, taskGroupId=2}, 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{jobId=1147207106223407105, pipelineId=1, taskGroupId=2}] 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{jobId=1147207106223407105, pipelineId=1, taskGroupId=2}] 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{jobId=1147207106223407105, pipelineId=1, taskGroupId=2}] 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{jobId=1147207106223407105, pipelineId=1, taskGroupId=2} 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, slotID=2, ownerJobID=1147207106223407105, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='950414ef-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, slotID=1, ownerJobID=1147207106223407105, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='950414ef-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(jobId=1147207106223407105, jobName=SeaTunnel_Job, jobStatus=FINISHED, createdTime=1788280292049) 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[id=2, /127.0.0.1:5802->/127.0.0.1:55573, qualifier=null, endpoint=[127.0.0.1]:55573, remoteUuid=477d9a34-c271-435b-a15c-845bb33872b7, alive=false, connectionType=JVM, 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{alive=false, connectionId=1, channel=NioChannel{/127.0.0.1:55573->localhost/127.0.0.1:5802}, remoteAddress=[localhost]:5802, lastReadTime=2026-09-02 00:31:32.079, lastWriteTime=2026-09-02 00:31:32.050, closedTime=2026-09-02 00:31:32.085, connected server version=5.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{connection=Connection[id=2, /127.0.0.1:5802->/127.0.0.1:55573, qualifier=null, endpoint=[127.0.0.1]:55573, remoteUuid=477d9a34-c271-435b-a15c-845bb33872b7, alive=false, connectionType=JVM, planeIndex=-1], clientUuid=477d9a34-c271-435b-a15c-845bb33872b7, clientName=hz.client_1, authenticated=true, clientVersion=5.1, creationTime=1788280288130, latest clientAttributes=lastStatisticsCollectionTime=1788280288163,enterprise=false,clientType=JVM,clientVersion=5.1,clusterConnectionTimestamp=1788280288121,clientAddress=127.0.0.1,clientName=hz.client_1,credentials.principal=null,os.committedVirtualMemorySize=10915172352,os.freePhysicalMemorySize=1284915200,os.freeSwapSpaceSize=876158976,os.maxFileDescriptorCount=1000000,os.openFileDescriptorCount=55,os.processCpuTime=7890000000,os.systemLoadAverage=1.24,os.totalPhysicalMemorySize=33812103168,os.totalSwapSpaceSize=8585736192,runtime.availableProcessors=16,runtime.freeMemory=224300928,runtime.maxMemory=477626368,runtime.totalMemory=331874304,runtime.uptime=3912,runtime.usedMemory=107573376, 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 ServerConnector@47311277{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.ServletContextHandler@2fd72332{/,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

测试抽取验证成功。