wmmzz commented on issue #9907:
URL: https://github.com/apache/seatunnel/issues/9907#issuecomment-3342783957
root@wmz-vm:/opt/seatunnel/apache-seatunnel-2.3.11/confile#
/opt/seatunnel/apache-seatunnel-2.3.11/bin/seatunnel.sh --config hr.conf -m
local
WARNING: sun.reflect.Reflection.getCallerClass is not supported. This will
impact performance.
2025-09-28 18:05:21,898 INFO [c.h.i.c.AbstractConfigLocator ] [main] -
Loading configuration
'/opt/seatunnel/apache-seatunnel-2.3.11/config/seatunnel.yaml' from System
property 'seatunnel.config'
2025-09-28 18:05:21,901 INFO [c.h.i.c.AbstractConfigLocator ] [main] -
Using configuration file at
/opt/seatunnel/apache-seatunnel-2.3.11/config/seatunnel.yaml
2025-09-28 18:05:21,903 INFO [o.a.s.e.c.c.SeaTunnelConfig ] [main] -
seatunnel.home is /opt/seatunnel/apache-seatunnel-2.3.11/confile
2025-09-28 18:05:21,993 INFO [amlSeaTunnelDomConfigProcessor] [main] -
Dynamic slot is enabled, the schedule strategy is set to REJECT
2025-09-28 18:05:21,993 INFO [c.h.i.c.AbstractConfigLocator ] [main] -
Loading configuration
'/opt/seatunnel/apache-seatunnel-2.3.11/config/hazelcast.yaml' from System
property 'hazelcast.config'
2025-09-28 18:05:21,993 INFO [c.h.i.c.AbstractConfigLocator ] [main] -
Using configuration file at
/opt/seatunnel/apache-seatunnel-2.3.11/config/hazelcast.yaml
2025-09-28 18:05:22,367 INFO [c.h.i.c.AbstractConfigLocator ] [main] -
Loading configuration
'/opt/seatunnel/apache-seatunnel-2.3.11/config/hazelcast-client.yaml' from
System property 'hazelcast.client.config'
2025-09-28 18:05:22,367 INFO [c.h.i.c.AbstractConfigLocator ] [main] -
Using configuration file at
/opt/seatunnel/apache-seatunnel-2.3.11/config/hazelcast-client.yaml
2025-09-28 18:05:22,393 WARN [h.i.i.HazelcastInstanceFactory] [main] -
Hazelcast is starting in a Java modular environment (Java 9 and newer) but
without proper access to required Java packages. Use additional Java arguments
to provide Hazelcast access to Java internal API. The internal API access is
used to get the best performance results. Arguments to be used:
--add-modules java.se --add-exports java.base/jdk.internal.ref=ALL-UNNAMED
--add-opens java.base/java.lang=ALL-UNNAMED --add-opens
java.base/sun.nio.ch=ALL-UNNAMED --add-opens
java.management/sun.management=ALL-UNNAMED --add-opens
jdk.management/com.sun.management.internal=ALL-UNNAMED
2025-09-28 18:05:22,445 WARN [c.h.i.AddressPicker ] [main] -
[LOCAL] [seatunnel-402186] [5.1] You configured your member address as host
name. Please be aware of that your dns can be spoofed. Make sure that your dns
configurations are correct.
2025-09-28 18:05:22,446 INFO [c.h.i.AddressPicker ] [main] -
[LOCAL] [seatunnel-402186] [5.1] Resolving domain name 'localhost' to
address(es): [127.0.0.1]
2025-09-28 18:05:22,446 INFO [c.h.i.AddressPicker ] [main] -
[LOCAL] [seatunnel-402186] [5.1] Interfaces is disabled, trying to pick one
address from TCP-IP config addresses: [localhost/127.0.0.1]
2025-09-28 18:05:22,487 INFO [o.a.s.e.s.SeaTunnelServer ] [main] -
SeaTunnel server start...
2025-09-28 18:05:22,492 INFO [c.h.system ] [main] -
[localhost]:5801 [seatunnel-402186] [5.1] Based on Hazelcast IMDG version:
5.1.0 (20220228 - 21f20e7)
2025-09-28 18:05:22,493 INFO [c.h.system ] [main] -
[localhost]:5801 [seatunnel-402186] [5.1] Cluster name: seatunnel-402186
2025-09-28 18:05:22,493 INFO [c.h.system ] [main] -
[localhost]:5801 [seatunnel-402186] [5.1]
_____ _____ _
/ ___| |_ _| | |
\ `--. ___ __ _ | | _ _ _ __ _ __ ___ | |
`--. \ / _ \ / _` | | | | | | || '_ \ | '_ \ / _ \| |
/\__/ /| __/| (_| | | | | |_| || | | || | | || __/| |
\____/ \___| \__,_| \_/ \__,_||_| |_||_| |_| \___||_|
2025-09-28 18:05:22,494 INFO [c.h.system ] [main] -
[localhost]:5801 [seatunnel-402186] [5.1] Copyright © 2021-2024 The Apache
Software Foundation. Apache SeaTunnel, SeaTunnel, and its feather logo are
trademarks of The Apache Software Foundation.
2025-09-28 18:05:22,494 INFO [c.h.system ] [main] -
[localhost]:5801 [seatunnel-402186] [5.1] Integrity Checker is disabled.
Fail-fast on corrupted executables will not be performed.
To enable integrity checker do one of the following:
- Change member config using Java API:
config.setIntegrityCheckerEnabled(true);
- Change XML/YAML configuration property: Set
hazelcast.integrity-checker.enabled to true
- Add system property: -Dhz.integritychecker.enabled=true (for Hazelcast
embedded, works only when loading config via Config.load)
- Add environment variable: HZ_INTEGRITYCHECKER_ENABLED=true (recommended
when running container image. For Hazelcast embedded, works only when loading
config via Config.load)
2025-09-28 18:05:22,500 INFO [c.h.system ] [main] -
[localhost]:5801 [seatunnel-402186] [5.1] The Jet engine is disabled.
To enable the Jet engine on the members, do one of the following:
- Change member config using Java API:
config.getJetConfig().setEnabled(true)
- Change XML/YAML configuration property: Set hazelcast.jet.enabled to true
- Add system property: -Dhz.jet.enabled=true (for Hazelcast embedded,
works only when loading config via Config.load)
- Add environment variable: HZ_JET_ENABLED=true (recommended when running
container image. For Hazelcast embedded, works only when loading config via
Config.load)
2025-09-28 18:05:22,857 INFO [c.h.s.security ] [main] -
[localhost]:5801 [seatunnel-402186] [5.1] Enable DEBUG/FINE log level for log
category com.hazelcast.system.security or use
-Dhazelcast.security.recommendations system property to see 🔒 security
recommendations and the status of current config.
2025-09-28 18:05:22,925 INFO [o.a.s.e.s.SeaTunnelNodeContext] [main] -
Using LiteNodeDropOutTcpIpJoiner TCP/IP discovery
2025-09-28 18:05:22,930 WARN [c.h.c.CPSubsystem ] [main] -
[localhost]:5801 [seatunnel-402186] [5.1] CP Subsystem is not enabled. CP data
structures will operate in UNSAFE mode! Please note that UNSAFE mode will not
provide strong consistency guarantees.
2025-09-28 18:05:23,105 INFO [.c.c.DefaultClassLoaderService] [main] -
start classloader service with cache mode
2025-09-28 18:05:23,112 INFO [c.h.i.c.AbstractConfigLocator ] [main] -
Loading configuration
'/opt/seatunnel/apache-seatunnel-2.3.11/config/seatunnel.yaml' from System
property 'seatunnel.config'
2025-09-28 18:05:23,112 INFO [c.h.i.c.AbstractConfigLocator ] [main] -
Using configuration file at
/opt/seatunnel/apache-seatunnel-2.3.11/config/seatunnel.yaml
2025-09-28 18:05:23,117 INFO [amlSeaTunnelDomConfigProcessor] [main] -
Dynamic slot is enabled, the schedule strategy is set to REJECT
2025-09-28 18:05:23,118 INFO [c.h.i.c.AbstractConfigLocator ] [main] -
Loading configuration
'/opt/seatunnel/apache-seatunnel-2.3.11/config/hazelcast.yaml' from System
property 'hazelcast.config'
2025-09-28 18:05:23,118 INFO [c.h.i.c.AbstractConfigLocator ] [main] -
Using configuration file at
/opt/seatunnel/apache-seatunnel-2.3.11/config/hazelcast.yaml
2025-09-28 18:05:23,133 INFO [o.a.s.e.s.TaskExecutionService] [main] -
[localhost]:5801 [seatunnel-402186] [5.1] Created new BusWork : 704530496
2025-09-28 18:05:23,132 WARN [o.a.s.e.s.TaskExecutionService]
[pool-3-thread-1] - [localhost]:5801 [seatunnel-402186] [5.1] The Node is not
ready yet, Node state STARTING,looking forward to the next scheduling
2025-09-28 18:05:23,158 WARN [a.s.e.s.s.s.DefaultSlotService]
[hz.main.seaTunnel.slotService.thread] - failed send heartbeat to resource
manager, will retry later. this address: [localhost]:5801
2025-09-28 18:05:23,160 INFO [o.a.s.e.s.CoordinatorService ] [main] -
[localhost]:5801 [seatunnel-402186] [5.1] Start pending job schedule thread
2025-09-28 18:05:23,366 WARN [o.a.h.u.NativeCodeLoader ] [main] -
Unable to load native-hadoop library for your platform... using builtin-java
classes where applicable
2025-09-28 18:05:23,517 INFO [o.a.s.e.s.CoordinatorService ]
[pool-7-thread-1] - [localhost]:5801 [seatunnel-402186] [5.1]
***********************************************
CoordinatorService Thread Pool Status
***********************************************
activeCount : 1
corePoolSize : 10
maximumPoolSize : 2147483647
poolSize : 1
completedTaskCount : 0
taskCount : 1
***********************************************
2025-09-28 18:05:23,527 INFO [o.a.s.e.s.JettyService ] [main] -
SeaTunnel REST service will start on port 8080
2025-09-28 18:05:23,537 INFO [o.a.s.s.o.e.j.u.log ] [main] -
Logging initialized @2450ms to
org.apache.seatunnel.shade.org.eclipse.jetty.util.log.Slf4jLog
2025-09-28 18:05:23,589 WARN [a.s.s.o.e.j.s.h.ContextHandler] [main] -
Empty contextPath
2025-09-28 18:05:23,609 INFO [o.a.s.s.o.e.j.s.Server ] [main] -
jetty-9.4.56.v20240826; built: 2024-08-26T17:15:05.868Z; git:
ec6782ff5ead824dabdcf47fa98f90a4aedff401; jvm 11.0.27+8-LTS-232
2025-09-28 18:05:23,646 INFO [o.a.s.s.o.e.j.s.session ] [main] -
DefaultSessionIdManager workerName=node0
2025-09-28 18:05:23,647 INFO [o.a.s.s.o.e.j.s.session ] [main] - No
SessionScavenger set, using defaults
2025-09-28 18:05:23,649 INFO [o.a.s.s.o.e.j.s.session ] [main] -
node0 Scavenging every 660000ms
2025-09-28 18:05:23,776 INFO [a.s.s.o.e.j.s.h.ContextHandler] [main] -
Started o.a.s.s.o.e.j.s.ServletContextHandler@68fc9167{/,null,AVAILABLE}
2025-09-28 18:05:23,785 INFO [.s.s.o.e.j.s.AbstractConnector] [main] -
Started ServerConnector@2aee0704{HTTP/1.1, (http/1.1)}{0.0.0.0:8080}
2025-09-28 18:05:23,786 INFO [o.a.s.s.o.e.j.s.Server ] [main] -
Started @2700ms
2025-09-28 18:05:23,836 INFO [c.h.i.d.Diagnostics ] [main] -
[localhost]:5801 [seatunnel-402186] [5.1] Diagnostics disabled. To enable add
-Dhazelcast.diagnostics.enabled=true to the JVM arguments.
2025-09-28 18:05:23,842 INFO [c.h.c.LifecycleService ] [main] -
[localhost]:5801 [seatunnel-402186] [5.1] [localhost]:5801 is STARTING
WARNING: An illegal reflective access operation has occurred
WARNING: Illegal reflective access by
com.hazelcast.internal.networking.nio.SelectorOptimizer
(file:/opt/seatunnel/apache-seatunnel-2.3.11/starter/seatunnel-starter.jar) to
field sun.nio.ch.SelectorImpl.selectedKeys
WARNING: Please consider reporting this to the maintainers of
com.hazelcast.internal.networking.nio.SelectorOptimizer
WARNING: Use --illegal-access=warn to enable warnings of further illegal
reflective access operations
WARNING: All illegal access operations will be denied in a future release
2025-09-28 18:05:23,909 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-1] - [localhost]:5801 [seatunnel-402186] [5.1]
[localhost]:5827 is added to the blacklist.
2025-09-28 18:05:23,911 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-15] - [localhost]:5801 [seatunnel-402186] [5.1]
[localhost]:5826 is added to the blacklist.
2025-09-28 18:05:23,912 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-15] - [localhost]:5801 [seatunnel-402186] [5.1]
[localhost]:5824 is added to the blacklist.
2025-09-28 18:05:23,912 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-14] - [localhost]:5801 [seatunnel-402186] [5.1]
[localhost]:5802 is added to the blacklist.
2025-09-28 18:05:23,912 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-1] - [localhost]:5801 [seatunnel-402186] [5.1]
[localhost]:5820 is added to the blacklist.
2025-09-28 18:05:23,913 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-12] - [localhost]:5801 [seatunnel-402186] [5.1]
[localhost]:5810 is added to the blacklist.
2025-09-28 18:05:23,913 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-14] - [localhost]:5801 [seatunnel-402186] [5.1]
[localhost]:5814 is added to the blacklist.
2025-09-28 18:05:23,913 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-1] - [localhost]:5801 [seatunnel-402186] [5.1]
[localhost]:5812 is added to the blacklist.
2025-09-28 18:05:23,913 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-12] - [localhost]:5801 [seatunnel-402186] [5.1]
[localhost]:5818 is added to the blacklist.
2025-09-28 18:05:23,913 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-1] - [localhost]:5801 [seatunnel-402186] [5.1]
[localhost]:5807 is added to the blacklist.
2025-09-28 18:05:23,913 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-14] - [localhost]:5801 [seatunnel-402186] [5.1]
[localhost]:5816 is added to the blacklist.
2025-09-28 18:05:23,911 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-6] - [localhost]:5801 [seatunnel-402186] [5.1]
[localhost]:5813 is added to the blacklist.
2025-09-28 18:05:23,914 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-1] - [localhost]:5801 [seatunnel-402186] [5.1]
[localhost]:5811 is added to the blacklist.
2025-09-28 18:05:23,910 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-16] - [localhost]:5801 [seatunnel-402186] [5.1]
[localhost]:5822 is added to the blacklist.
2025-09-28 18:05:23,914 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-13] - [localhost]:5801 [seatunnel-402186] [5.1]
[localhost]:5808 is added to the blacklist.
2025-09-28 18:05:23,915 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-13] - [localhost]:5801 [seatunnel-402186] [5.1]
[localhost]:5809 is added to the blacklist.
2025-09-28 18:05:23,915 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-13] - [localhost]:5801 [seatunnel-402186] [5.1]
[localhost]:5803 is added to the blacklist.
2025-09-28 18:05:23,915 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-6] - [localhost]:5801 [seatunnel-402186] [5.1]
[localhost]:5828 is added to the blacklist.
2025-09-28 18:05:23,916 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-9] - [localhost]:5801 [seatunnel-402186] [5.1]
[localhost]:5806 is added to the blacklist.
2025-09-28 18:05:23,912 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-11] - [localhost]:5801 [seatunnel-402186] [5.1]
[localhost]:5804 is added to the blacklist.
2025-09-28 18:05:23,916 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-14] - [localhost]:5801 [seatunnel-402186] [5.1]
[localhost]:5830 is added to the blacklist.
2025-09-28 18:05:23,917 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-10] - [localhost]:5801 [seatunnel-402186] [5.1]
[localhost]:5829 is added to the blacklist.
2025-09-28 18:05:23,918 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-12] - [localhost]:5801 [seatunnel-402186] [5.1]
[localhost]:5805 is added to the blacklist.
2025-09-28 18:05:23,912 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-2] - [localhost]:5801 [seatunnel-402186] [5.1]
[localhost]:5821 is added to the blacklist.
2025-09-28 18:05:23,912 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-7] - [localhost]:5801 [seatunnel-402186] [5.1]
[localhost]:5819 is added to the blacklist.
2025-09-28 18:05:23,912 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-3] - [localhost]:5801 [seatunnel-402186] [5.1]
[localhost]:5823 is added to the blacklist.
2025-09-28 18:05:23,920 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-8] - [localhost]:5801 [seatunnel-402186] [5.1]
[localhost]:5817 is added to the blacklist.
2025-09-28 18:05:23,920 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-4] - [localhost]:5801 [seatunnel-402186] [5.1]
[localhost]:5825 is added to the blacklist.
2025-09-28 18:05:23,920 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-5] - [localhost]:5801 [seatunnel-402186] [5.1]
[localhost]:5815 is added to the blacklist.
2025-09-28 18:05:24,921 INFO [c.h.i.c.ClusterService ] [main] -
[localhost]:5801 [seatunnel-402186] [5.1]
Members {size:1, ver:1} [
Member [localhost]:5801 - c54d0717-2e69-4874-b06d-eab436bd5e62 [master
node] [active master] this
]
2025-09-28 18:05:24,934 INFO [c.h.c.LifecycleService ] [main] -
[localhost]:5801 [seatunnel-402186] [5.1] [localhost]:5801 is STARTED
2025-09-28 18:05:24,960 INFO [o.a.s.e.s.CoordinatorService ]
[pool-5-thread-1] - [localhost]:5801 [seatunnel-402186] [5.1] This node become
a new active master node, begin init coordinator service
2025-09-28 18:05:24,992 INFO [.c.i.s.ClientInvocationService] [main] -
hz.client_1 [seatunnel-402186] [5.1] Running with 2 response threads,
dynamic=true
2025-09-28 18:05:25,019 INFO [o.a.s.e.s.CoordinatorService ]
[pool-5-thread-1] - [localhost]:5801 [seatunnel-402186] [5.1] Loaded event
handlers: [org.apache.seatunnel.api.event.LoggingEventHandler@32c90769]
2025-09-28 18:05:25,022 INFO [c.h.c.LifecycleService ] [main] -
hz.client_1 [seatunnel-402186] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7)
is STARTING
2025-09-28 18:05:25,022 INFO [c.h.c.LifecycleService ] [main] -
hz.client_1 [seatunnel-402186] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7)
is STARTED
2025-09-28 18:05:25,032 INFO [.c.i.c.ClientConnectionManager] [main] -
hz.client_1 [seatunnel-402186] [5.1] Trying to connect to cluster:
seatunnel-402186
2025-09-28 18:05:25,034 INFO [.c.i.c.ClientConnectionManager] [main] -
hz.client_1 [seatunnel-402186] [5.1] Trying to connect to [localhost]:5801
2025-09-28 18:05:25,038 INFO [.h.i.p.i.PartitionStateManager]
[seatunnel-coordinator-service-1] - [localhost]:5801 [seatunnel-402186] [5.1]
Initializing cluster partition table arrangement...
2025-09-28 18:05:25,055 INFO [.p.t.AuthenticationMessageTask]
[hz.main.priority-generic-operation.thread-0] - [localhost]:5801
[seatunnel-402186] [5.1] Received auth from Connection[id=1,
/127.0.0.1:5801->/127.0.0.1:34747, qualifier=null, endpoint=[127.0.0.1]:34747,
remoteUuid=30c89f62-adad-4bfb-8071-13660ad57993, alive=true,
connectionType=JVM, planeIndex=-1], successfully authenticated, clientUuid:
30c89f62-adad-4bfb-8071-13660ad57993, client name: hz.client_1, client version:
5.1
2025-09-28 18:05:25,064 INFO [c.h.c.LifecycleService ] [main] -
hz.client_1 [seatunnel-402186] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7)
is CLIENT_CONNECTED
2025-09-28 18:05:25,064 INFO [.c.i.c.ClientConnectionManager] [main] -
hz.client_1 [seatunnel-402186] [5.1] Authenticated with server
[localhost]:5801:c54d0717-2e69-4874-b06d-eab436bd5e62, server version: 5.1,
local address: /127.0.0.1:34747
2025-09-28 18:05:25,066 INFO [c.h.i.d.Diagnostics ] [main] -
hz.client_1 [seatunnel-402186] [5.1] Diagnostics disabled. To enable add
-Dhazelcast.diagnostics.enabled=true to the JVM arguments.
2025-09-28 18:05:25,081 INFO [c.h.c.i.s.ClientClusterService]
[hz.client_1.event-10] - hz.client_1 [seatunnel-402186] [5.1]
Members [1] {
Member [localhost]:5801 - c54d0717-2e69-4874-b06d-eab436bd5e62 [master
node]
}
2025-09-28 18:05:25,109 INFO [.c.i.s.ClientStatisticsService] [main] -
Client statistics is enabled with period 5 seconds.
2025-09-28 18:05:25,152 INFO [o.a.s.c.s.u.ConfigBuilder ] [main] -
Loading config file from path: hr.conf
2025-09-28 18:05:25,331 INFO [o.a.s.c.s.u.ConfigShadeUtils ] [main] - Load
config shade spi: [base64]
2025-09-28 18:05:25,365 INFO [o.a.s.c.s.u.ConfigBuilder ] [main] -
Parsed config file:
{
"env" : {
"parallelism" : 1,
"job.mode" : "STREAMING",
"checkpoint.interval" : 5000
},
"source" : [
{
"plugin_output" : "customers",
"username" : "******",
"password" : "******",
"database-names" : [
"ORCLCDB"
],
"schema-names" : [
"HR"
],
"table-names" : [
"ORCLCDB.HR.NOE"
],
"base-url" : "jdbc:oracle:thin:@192.168.110.103:1521/ORCLCDB",
"source.reader.close.timeout" : 120000,
"connection.pool.size" : 1,
"schema-changes.enabled" : true,
"plugin_name" : "Oracle-CDC"
}
],
"sink" : [
{
"plugin_input" : "customers",
"driver" : "oracle.jdbc.driver.OracleDriver",
"url" : "jdbc:oracle:thin:@192.168.110.103:1521/ORCLCDB",
"user" : "scott",
"password" : "******",
"generate_sink_sql" : true,
"database" : "ORCLCDB",
"table" : "SCOTT.NOE",
"batch_size" : 1,
"primary_keys" : [
"ID"
],
"connection.pool.size" : 1,
"plugin_name" : "Jdbc"
}
]
}
2025-09-28 18:05:25,371 INFO [p.MultipleTableJobConfigParser] [main] - add
common jar in plugins :[]
2025-09-28 18:05:25,388 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load
SeaTunnelSink Plugin from /opt/seatunnel/apache-seatunnel-2.3.11/connectors
2025-09-28 18:05:25,391 INFO [.s.p.d.AbstractPluginDiscovery] [main] -
Discovery plugin jar for: PluginIdentifier{engineType='seatunnel',
pluginType='source', pluginName='Oracle-CDC'} at:
file:/opt/seatunnel/apache-seatunnel-2.3.11/connectors/connector-cdc-oracle-2.3.11.jar
2025-09-28 18:05:25,399 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load
SeaTunnelSink Plugin from /opt/seatunnel/apache-seatunnel-2.3.11/connectors
2025-09-28 18:05:25,403 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load
SeaTunnelSink Plugin from /opt/seatunnel/apache-seatunnel-2.3.11/connectors
2025-09-28 18:05:25,404 INFO [.s.p.d.AbstractPluginDiscovery] [main] -
Discovery plugin jar for: PluginIdentifier{engineType='seatunnel',
pluginType='sink', pluginName='Jdbc'} at:
file:/opt/seatunnel/apache-seatunnel-2.3.11/connectors/connector-jdbc-2.3.11.jar
2025-09-28 18:05:25,408 WARN [o.a.s.a.c.u.ConfigUtil ] [main] -
Option 'plugin_input' is a List, and it is recommended to configure it as
["string1","string2"]; we will only use ',' to split the String into a list.
2025-09-28 18:05:25,408 INFO [p.MultipleTableJobConfigParser] [main] -
start generating all sources.
2025-09-28 18:05:25,889 INFO [.s.c.s.j.c.AbstractJdbcCatalog] [main] -
Catalog Oracle established connection to
jdbc:oracle:thin:@192.168.110.103:1521/ORCLCDB
2025-09-28 18:05:26,310 INFO [o.a.s.a.t.c.CatalogTableUtil ] [main] - Get
catalog tables, cost time: 827 ms
2025-09-28 18:05:26,313 INFO [.s.c.s.j.c.AbstractJdbcCatalog] [main] -
Catalog Oracle closing
2025-09-28 18:05:26,486 INFO [i.d.c.o.OracleConnection ] [main] -
Database Version: Oracle Database 19c Enterprise Edition Release 19.0.0.0.0 -
Production
Version 19.3.0.0.0
2025-09-28 18:05:26,613 INFO [i.d.j.JdbcConnection ]
[pool-8-thread-1] - Connection gracefully closed
2025-09-28 18:05:26,679 INFO [i.d.c.o.OracleConnection ] [main] -
Database Version: Oracle Database 19c Enterprise Edition Release 19.0.0.0.0 -
Production
Version 19.3.0.0.0
2025-09-28 18:05:26,683 INFO [i.d.j.JdbcConnection ]
[pool-9-thread-1] - Connection gracefully closed
2025-09-28 18:05:26,708 INFO [o.a.s.a.t.f.FactoryUtil ] [main] - get
the CatalogTable from source Oracle-CDC: Oracle.ORCLCDB.HR.NOE
2025-09-28 18:05:26,720 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load
SeaTunnelSource Plugin from /opt/seatunnel/apache-seatunnel-2.3.11/connectors
2025-09-28 18:05:26,721 INFO [.s.p.d.AbstractPluginDiscovery] [main] -
Discovery plugin jar for: PluginIdentifier{engineType='seatunnel',
pluginType='source', pluginName='Oracle-CDC'} at:
file:/opt/seatunnel/apache-seatunnel-2.3.11/connectors/connector-cdc-oracle-2.3.11.jar
2025-09-28 18:05:26,723 INFO [p.MultipleTableJobConfigParser] [main] -
start generating all transforms.
2025-09-28 18:05:26,723 INFO [p.MultipleTableJobConfigParser] [main] -
start generating all sinks.
2025-09-28 18:05:26,724 WARN [o.a.s.a.c.u.ConfigUtil ] [main] -
Option 'plugin_input' is a List, and it is recommended to configure it as
["string1","string2"]; we will only use ',' to split the String into a list.
2025-09-28 18:05:26,730 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load
SeaTunnelSink Plugin from /opt/seatunnel/apache-seatunnel-2.3.11/connectors
2025-09-28 18:05:26,730 INFO [.s.p.d.AbstractPluginDiscovery] [main] -
Discovery plugin jar for: PluginIdentifier{engineType='seatunnel',
pluginType='sink', pluginName='Jdbc'} at:
file:/opt/seatunnel/apache-seatunnel-2.3.11/connectors/connector-jdbc-2.3.11.jar
2025-09-28 18:05:26,754 INFO [o.a.s.a.t.f.FactoryUtil ] [main] -
Create sink 'Jdbc' with upstream input catalog-table[database: ORCLCDB, schema:
HR, table: NOE]
2025-09-28 18:05:26,850 INFO [o.a.s.e.c.j.ClientJobProxy ] [main] -
Start submit job, job id: 1024622854756368385, with plugin jar
[file:/opt/seatunnel/apache-seatunnel-2.3.11/connectors/connector-jdbc-2.3.11.jar,
file:/opt/seatunnel/apache-seatunnel-2.3.11/connectors/connector-cdc-oracle-2.3.11.jar]
2025-09-28 18:05:26,868 INFO [.e.s.r.AbstractResourceManager]
[hz.main.client.thread-4] - Init ResourceManager
2025-09-28 18:05:26,869 INFO [.e.s.r.AbstractResourceManager]
[hz.main.client.thread-4] - initWorker...
2025-09-28 18:05:26,870 INFO [.e.s.r.AbstractResourceManager]
[hz.main.client.thread-4] - init live nodes: [[localhost]:5801]
2025-09-28 18:05:26,872 INFO [.e.s.r.AbstractResourceManager]
[SeaTunnel-CompletableFuture-Thread-2] - received new worker register:
[localhost]:5801
2025-09-28 18:05:26,873 INFO [.e.s.r.AbstractResourceManager]
[hz.main.client.thread-4] - registerWorker:
{[localhost]:5801=WorkerProfile(address=[localhost]:5801,
profile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=536870912}},
unassignedResource=ResourceProfile{cpu=CPU{core=0},
heapMemory=Memory{bytes=536870912}}, dynamicSlot=true, assignedSlots=[],
unassignedSlots=[], attributes={}, systemLoadInfo=null)}
2025-09-28 18:05:26,894 INFO [o.a.s.e.s.m.JobMaster ]
[seatunnel-coordinator-service-2] - Init JobMaster for Job SeaTunnel_Job
(1024622854756368385)
2025-09-28 18:05:26,894 INFO [o.a.s.e.s.m.JobMaster ]
[seatunnel-coordinator-service-2] - Job SeaTunnel_Job (1024622854756368385)
needed jar urls
[file:/opt/seatunnel/apache-seatunnel-2.3.11/connectors/connector-jdbc-2.3.11.jar,
file:/opt/seatunnel/apache-seatunnel-2.3.11/connectors/connector-cdc-oracle-2.3.11.jar]
2025-09-28 18:05:26,895 INFO [.c.c.DefaultClassLoaderService]
[seatunnel-coordinator-service-2] - Create classloader for job 1 with jars
[file:/opt/seatunnel/apache-seatunnel-2.3.11/connectors/connector-cdc-oracle-2.3.11.jar]
2025-09-28 18:05:26,895 INFO [.c.c.DefaultClassLoaderService]
[seatunnel-coordinator-service-2] - Create classloader for job 1 with jars
[file:/opt/seatunnel/apache-seatunnel-2.3.11/connectors/connector-jdbc-2.3.11.jar]
2025-09-28 18:05:27,083 INFO [.s.c.s.j.c.AbstractJdbcCatalog]
[seatunnel-coordinator-service-2] - Catalog Oracle established connection to
jdbc:oracle:thin:@192.168.110.103:1521/ORCLCDB
2025-09-28 18:05:27,085 INFO [a.s.a.s.SaveModeExecuteWrapper]
[seatunnel-coordinator-service-2] - Executing save mode for table:
ORCLCDB.SCOTT.NOE, with SchemaSaveMode: CREATE_SCHEMA_WHEN_NOT_EXIST,
DataSaveMode: APPEND_DATA using Catalog: Oracle
2025-09-28 18:05:27,092 INFO [a.s.a.s.DefaultSaveModeHandler]
[seatunnel-coordinator-service-2] - Creating table ORCLCDB.SCOTT.NOE with
action CREATE TABLE "SCOTT"."NOE" (
"ID" NUMBER NOT NULL,
"NAME" VARCHAR2(100) NOT NULL,
"CREATED_TIME" TIMESTAMP(6),
"UPDATED_TIME" TIMESTAMP(6),
CONSTRAINT NOE_config_pk_955d PRIMARY KEY ("ID")
)
2025-09-28 18:05:27,094 INFO [.s.c.s.j.c.AbstractJdbcCatalog]
[seatunnel-coordinator-service-2] - Execute sql : CREATE TABLE "SCOTT"."NOE" (
"ID" NUMBER NOT NULL,
"NAME" VARCHAR2(100) NOT NULL,
"CREATED_TIME" TIMESTAMP(6),
"UPDATED_TIME" TIMESTAMP(6),
CONSTRAINT NOE_config_pk_e44f PRIMARY KEY ("ID")
)
2025-09-28 18:05:27,149 INFO [.s.c.s.j.c.AbstractJdbcCatalog]
[seatunnel-coordinator-service-2] - Catalog Oracle closing
2025-09-28 18:05:27,249 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-2] - Create CheckpointCoordinator for
job(1@1024622854756368385) with plan(CheckpointPlan(pipelineId=1,
pipelineSubtasks=[TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=1024622854756368385,
pipelineId=1, taskGroupId=2}, taskID=1000200000000, index=0},
TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=1024622854756368385,
pipelineId=1, taskGroupId=2}, taskID=1000200010000, index=0},
TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=1024622854756368385,
pipelineId=1, taskGroupId=1}, taskID=1000100000000, index=0}],
startingSubtasks=[TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=1024622854756368385,
pipelineId=1, taskGroupId=1}, taskID=1000100000000, index=0}],
pipelineActions={ActionStateKey(name=ActionStateKey - pipeline-1
[Source[0]-Oracle-CDC])=1, ActionStateKey(name=ActionStateKey - pipeline-1
[Sink[0]-Jdbc-MultiTableSink])=1}, subtaskActions={TaskLocation{tas
kGroupLocation=TaskGroupLocation{jobId=1024622854756368385, pipelineId=1,
taskGroupId=2}, taskID=1000200000000,
index=0}=[(ActionStateKey(name=ActionStateKey - pipeline-1
[Source[0]-Oracle-CDC]), 0)],
TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=1024622854756368385,
pipelineId=1, taskGroupId=2}, taskID=1000200010000,
index=0}=[(ActionStateKey(name=ActionStateKey - pipeline-1
[Sink[0]-Jdbc-MultiTableSink]), 0)],
TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=1024622854756368385,
pipelineId=1, taskGroupId=1}, taskID=1000100000000,
index=0}=[(ActionStateKey(name=ActionStateKey - pipeline-1
[Source[0]-Oracle-CDC]), -1)]}))
2025-09-28 18:05:27,252 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[seatunnel-coordinator-service-2] - The task Job (1024622854756368385),
Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Oracle-CDC]-SourceTask (1/1)],
taskGroupLocation: [TaskGroupLocation{jobId=1024622854756368385, pipelineId=1,
taskGroupId=2}] is in state CREATED when init state future
2025-09-28 18:05:27,254 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[seatunnel-coordinator-service-2] - The task Job (1024622854756368385),
Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Oracle-CDC]-SplitEnumerator
(1/1)], taskGroupLocation: [TaskGroupLocation{jobId=1024622854756368385,
pipelineId=1, taskGroupId=1}] is in state CREATED when init state future
2025-09-28 18:05:27,261 INFO [o.a.s.e.s.d.p.PhysicalPlan ]
[seatunnel-coordinator-service-2] - Job SeaTunnel_Job (1024622854756368385)
turned from state CREATED to PENDING.
2025-09-28 18:05:27,261 WARN [o.a.s.e.s.d.p.PhysicalPlan ]
[seatunnel-coordinator-service-2] - Job SeaTunnel_Job (1024622854756368385)
state process is stopped
2025-09-28 18:05:27,262 INFO [o.a.s.e.s.CoordinatorService ]
[seatunnel-coordinator-service-2] - [localhost]:5801 [seatunnel-402186] [5.1]
The submit job enter the pending queue , jobId: 1024622854756368385 , jobName:
SeaTunnel_Job
2025-09-28 18:05:27,265 INFO [o.a.s.e.c.j.ClientJobProxy ] [main] -
Submit job finished, job id: 1024622854756368385, job name: SeaTunnel_Job
2025-09-28 18:05:27,285 INFO [o.a.s.e.s.CoordinatorService ]
[pending-job-schedule-runner] - [localhost]:5801 [seatunnel-402186] [5.1]
Resources enough, start running: 1024622854756368385
2025-09-28 18:05:27,291 INFO [o.a.s.e.s.CoordinatorService ]
[seatunnel-coordinator-service-3] - [localhost]:5801 [seatunnel-402186] [5.1]
The SUBMIT Job SeaTunnel_Job (1024622854756368385) is in PENDING state, restore
pipeline and take over this job running
2025-09-28 18:05:27,292 INFO [o.a.s.e.s.d.p.PhysicalPlan ]
[seatunnel-coordinator-service-3] - Job SeaTunnel_Job (1024622854756368385)
state process is start
2025-09-28 18:05:27,299 WARN [o.a.s.e.c.j.JobMetricsRunner ]
[job-metrics-runner-1024622854756368385] - Failed to get job metrics summary,
it maybe first-run
2025-09-28 18:05:27,300 INFO [o.a.s.e.s.d.p.SubPlan ]
[seatunnel-coordinator-service-3] - Job SeaTunnel_Job (1024622854756368385),
Pipeline: [(1/1)] state process is start
2025-09-28 18:05:27,304 INFO [o.a.s.e.s.d.p.SubPlan ]
[seatunnel-coordinator-service-3] - Job SeaTunnel_Job (1024622854756368385),
Pipeline: [(1/1)] turned from state CREATED to SCHEDULED.
2025-09-28 18:05:27,312 INFO [o.a.s.e.s.d.p.SubPlan ]
[seatunnel-coordinator-service-3] - Resource allocation for pipeline Job
SeaTunnel_Job (1024622854756368385), Pipeline: [(1/1)] completed. Task
execution locations:
2025-09-28 18:05:27,313 INFO [o.a.s.e.s.d.p.SubPlan ]
[seatunnel-coordinator-service-3] - Task
[TaskGroupLocation{jobId=1024622854756368385, pipelineId=1, taskGroupId=2}]
will be executed on worker [[localhost]:5801], slotID [2], resourceProfile
[ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}], sequence
[1ded0f6a-90e8-4ca7-87b7-030b3d08738f], assigned [1024622854756368385]
2025-09-28 18:05:27,313 INFO [o.a.s.e.s.d.p.SubPlan ]
[seatunnel-coordinator-service-3] - Task
[TaskGroupLocation{jobId=1024622854756368385, pipelineId=1, taskGroupId=1}]
will be executed on worker [[localhost]:5801], slotID [1], resourceProfile
[ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}], sequence
[1ded0f6a-90e8-4ca7-87b7-030b3d08738f], assigned [1024622854756368385]
2025-09-28 18:05:27,315 INFO [o.a.s.e.s.d.p.SubPlan ]
[seatunnel-coordinator-service-3] - Job SeaTunnel_Job (1024622854756368385),
Pipeline: [(1/1)] turned from state SCHEDULED to DEPLOYING.
2025-09-28 18:05:27,316 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[seatunnel-coordinator-service-3] - Job (1024622854756368385), Pipeline:
[(1/1)], task: [pipeline-1 [Source[0]-Oracle-CDC]-SplitEnumerator (1/1)],
taskGroupLocation: [TaskGroupLocation{jobId=1024622854756368385, pipelineId=1,
taskGroupId=1}] state process is start
2025-09-28 18:05:27,318 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[seatunnel-coordinator-service-3] - Job (1024622854756368385), Pipeline:
[(1/1)], task: [pipeline-1 [Source[0]-Oracle-CDC]-SplitEnumerator (1/1)],
taskGroupLocation: [TaskGroupLocation{jobId=1024622854756368385, pipelineId=1,
taskGroupId=1}] turned from state CREATED to DEPLOYING.
2025-09-28 18:05:27,329 INFO [o.a.s.e.s.TaskExecutionService]
[seatunnel-coordinator-service-3] - [localhost]:5801 [seatunnel-402186] [5.1]
received deploying task executionId [1024622863912534017]
2025-09-28 18:05:27,337 INFO [o.a.s.e.s.TaskExecutionService]
[seatunnel-coordinator-service-3] - [localhost]:5801 [seatunnel-402186] [5.1]
deploying task TaskGroupLocation{jobId=1024622854756368385, pipelineId=1,
taskGroupId=1}, executionId [1024622863912534017]
2025-09-28 18:05:27,338 INFO [o.a.s.e.s.TaskExecutionService]
[seatunnel-coordinator-service-3] - [localhost]:5801 [seatunnel-402186] [5.1]
deploying TaskGroup TaskGroupLocation{jobId=1024622854756368385, pipelineId=1,
taskGroupId=1} init success
2025-09-28 18:05:27,346 INFO [o.a.s.e.s.TaskExecutionService]
[seatunnel-coordinator-service-3] - [localhost]:5801 [seatunnel-402186] [5.1]
deploying TaskGroup TaskGroupLocation{jobId=1024622854756368385, pipelineId=1,
taskGroupId=1} success
2025-09-28 18:05:27,347 INFO [.s.t.SourceSplitEnumeratorTask]
[BlockingWorker-TaskGroupLocation{jobId=1024622854756368385, pipelineId=1,
taskGroupId=1}] - starting seatunnel source split enumerator task, source name:
pipeline-1 [Source[0]-Oracle-CDC]
2025-09-28 18:05:27,349 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[seatunnel-coordinator-service-3] - Job (1024622854756368385), Pipeline:
[(1/1)], task: [pipeline-1 [Source[0]-Oracle-CDC]-SplitEnumerator (1/1)],
taskGroupLocation: [TaskGroupLocation{jobId=1024622854756368385, pipelineId=1,
taskGroupId=1}] turned from state DEPLOYING to RUNNING.
2025-09-28 18:05:27,351 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[seatunnel-coordinator-service-3] - Job (1024622854756368385), Pipeline:
[(1/1)], task: [pipeline-1 [Source[0]-Oracle-CDC]-SplitEnumerator (1/1)],
taskGroupLocation: [TaskGroupLocation{jobId=1024622854756368385, pipelineId=1,
taskGroupId=1}] current state equals target state: RUNNING, skip
2025-09-28 18:05:27,351 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[seatunnel-coordinator-service-3] - Job (1024622854756368385), Pipeline:
[(1/1)], task: [pipeline-1 [Source[0]-Oracle-CDC]-SourceTask (1/1)],
taskGroupLocation: [TaskGroupLocation{jobId=1024622854756368385, pipelineId=1,
taskGroupId=2}] state process is start
2025-09-28 18:05:27,355 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[seatunnel-coordinator-service-3] - Job (1024622854756368385), Pipeline:
[(1/1)], task: [pipeline-1 [Source[0]-Oracle-CDC]-SourceTask (1/1)],
taskGroupLocation: [TaskGroupLocation{jobId=1024622854756368385, pipelineId=1,
taskGroupId=2}] turned from state CREATED to DEPLOYING.
2025-09-28 18:05:27,376 INFO [o.a.s.e.s.TaskExecutionService]
[seatunnel-coordinator-service-3] - [localhost]:5801 [seatunnel-402186] [5.1]
received deploying task executionId [1024622863912599553]
2025-09-28 18:05:27,388 INFO [o.a.s.e.s.TaskExecutionService]
[seatunnel-coordinator-service-3] - [localhost]:5801 [seatunnel-402186] [5.1]
deploying task TaskGroupLocation{jobId=1024622854756368385, pipelineId=1,
taskGroupId=2}, executionId [1024622863912599553]
2025-09-28 18:05:27,390 INFO [o.a.s.e.s.TaskExecutionService]
[seatunnel-coordinator-service-3] - [localhost]:5801 [seatunnel-402186] [5.1]
deploying TaskGroup TaskGroupLocation{jobId=1024622854756368385, pipelineId=1,
taskGroupId=2} init success
2025-09-28 18:05:27,405 INFO [o.a.s.e.s.TaskExecutionService]
[seatunnel-coordinator-service-3] - [localhost]:5801 [seatunnel-402186] [5.1]
deploying TaskGroup TaskGroupLocation{jobId=1024622854756368385, pipelineId=1,
taskGroupId=2} success
2025-09-28 18:05:27,417 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[seatunnel-coordinator-service-3] - Job (1024622854756368385), Pipeline:
[(1/1)], task: [pipeline-1 [Source[0]-Oracle-CDC]-SourceTask (1/1)],
taskGroupLocation: [TaskGroupLocation{jobId=1024622854756368385, pipelineId=1,
taskGroupId=2}] turned from state DEPLOYING to RUNNING.
2025-09-28 18:05:27,417 INFO [o.a.s.e.s.d.p.PhysicalVertex ]
[seatunnel-coordinator-service-3] - Job (1024622854756368385), Pipeline:
[(1/1)], task: [pipeline-1 [Source[0]-Oracle-CDC]-SourceTask (1/1)],
taskGroupLocation: [TaskGroupLocation{jobId=1024622854756368385, pipelineId=1,
taskGroupId=2}] current state equals target state: RUNNING, skip
2025-09-28 18:05:27,419 INFO [o.a.s.e.s.d.p.SubPlan ]
[seatunnel-coordinator-service-3] - Job SeaTunnel_Job (1024622854756368385),
Pipeline: [(1/1)] turned from state DEPLOYING to RUNNING.
2025-09-28 18:05:27,419 INFO [s.e.s.t.TransformSeaTunnelTask]
[BlockingWorker-TaskGroupLocation{jobId=1024622854756368385, pipelineId=1,
taskGroupId=2}] - starting seatunnel transform task, index 0
2025-09-28 18:05:27,423 INFO [o.a.s.e.s.d.p.PhysicalPlan ]
[seatunnel-coordinator-service-3] - Job SeaTunnel_Job (1024622854756368385)
turned from state PENDING to RUNNING.
2025-09-28 18:05:27,433 INFO [.a.s.e.s.t.SourceSeaTunnelTask]
[BlockingWorker-TaskGroupLocation{jobId=1024622854756368385, pipelineId=1,
taskGroupId=2}] - starting seatunnel source task, index 0
2025-09-28 18:05:27,483 INFO [.s.c.s.j.c.AbstractJdbcCatalog]
[hz.main.seaTunnel.task.thread-5] - Catalog Oracle established connection to
jdbc:oracle:thin:@192.168.110.103:1521/ORCLCDB
2025-09-28 18:05:27,540 INFO [i.d.c.o.OracleConnection ]
[hz.main.seaTunnel.task.thread-2] - Database Version: Oracle Database 19c
Enterprise Edition Release 19.0.0.0.0 - Production
Version 19.3.0.0.0
2025-09-28 18:05:27,545 INFO [a.s.c.s.c.s.r.SourceReaderBase]
[BlockingWorker-TaskGroupLocation{jobId=1024622854756368385, pipelineId=1,
taskGroupId=2}] - Open Source Reader.
2025-09-28 18:05:27,546 INFO [o.a.s.a.e.LoggingEventHandler ]
[hz.main.generic-operation.thread-12] - log event:
ReaderOpenEvent(createdTime=1759053927544, jobId=1024622854756368385,
eventType=LIFECYCLE_READER_OPEN)
2025-09-28 18:05:27,546 INFO [.s.t.SourceSplitEnumeratorTask]
[hz.main.seaTunnel.task.thread-6] - received reader register, readerID:
TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=1024622854756368385,
pipelineId=1, taskGroupId=2}, taskID=1000200000000, index=0}
2025-09-28 18:05:27,621 INFO [i.d.j.JdbcConnection ]
[pool-11-thread-1] - Connection gracefully closed
2025-09-28 18:05:27,665 INFO [i.d.c.o.OracleConnection ]
[hz.main.seaTunnel.task.thread-2] - Database Version: Oracle Database 19c
Enterprise Edition Release 19.0.0.0.0 - Production
Version 19.3.0.0.0
2025-09-28 18:05:27,669 INFO [i.d.j.JdbcConnection ]
[pool-12-thread-1] - Connection gracefully closed
2025-09-28 18:05:27,674 INFO [.c.b.s.e.SnapshotSplitAssigner]
[hz.main.seaTunnel.task.thread-2] - SnapshotSplitAssigner created with
remaining tables: []
2025-09-28 18:05:27,677 INFO [.c.b.s.e.SnapshotSplitAssigner]
[hz.main.seaTunnel.task.thread-2] - SnapshotSplitAssigner created with
remaining splits: []
2025-09-28 18:05:27,677 INFO [.c.b.s.e.SnapshotSplitAssigner]
[hz.main.seaTunnel.task.thread-2] - SnapshotSplitAssigner created with assigned
splits: []
2025-09-28 18:05:27,686 INFO [o.a.s.a.e.LoggingEventHandler ]
[hz.main.generic-operation.thread-14] - log event:
EnumeratorOpenEvent(createdTime=1759053927684, jobId=1024622854756368385,
eventType=LIFECYCLE_ENUMERATOR_OPEN)
2025-09-28 18:05:27,773 INFO [.s.c.s.j.c.AbstractJdbcCatalog]
[hz.main.seaTunnel.task.thread-5] - Catalog Oracle closing
2025-09-28 18:05:27,780 INFO [a.s.a.s.m.MultiTableSinkWriter]
[hz.main.seaTunnel.task.thread-5] - init multi table sink writer, queue size: 1
2025-09-28 18:05:27,855 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-9] - checkpoint is enabled, start schedule
trigger pending checkpoint.
2025-09-28 18:05:27,855 INFO [.s.t.SourceSplitEnumeratorTask]
[BlockingWorker-TaskGroupLocation{jobId=1024622854756368385, pipelineId=1,
taskGroupId=1}] - received enough reader, starting enumerator...
2025-09-28 18:05:32,864 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - wait checkpoint completed: 1
2025-09-28 18:05:32,882 WARN [o.a.s.s.c.z.h.HikariConfig ]
[st-multi-table-sink-writer-1] - HikariPool-1 - idleTimeout has been set but
has no effect because the pool is operating as a fixed size pool.
2025-09-28 18:05:32,883 INFO [o.a.s.s.c.z.h.HikariDataSource]
[st-multi-table-sink-writer-1] - HikariPool-1 - Starting...
2025-09-28 18:05:32,946 INFO [o.a.s.s.c.z.h.HikariDataSource]
[st-multi-table-sink-writer-1] - HikariPool-1 - Start completed.
2025-09-28 18:05:32,962 INFO [.e.FieldNamedPreparedStatement]
[st-multi-table-sink-writer-1] - PrepareStatement sql is:
MERGE INTO "SCOTT"."NOE" TARGET USING (SELECT ? "ID", ? "NAME", ?
"CREATED_TIME", ? "UPDATED_TIME" FROM DUAL) SOURCE ON (TARGET."ID"=SOURCE."ID")
WHEN MATCHED THEN UPDATE SET TARGET."NAME"=SOURCE."NAME",
TARGET."CREATED_TIME"=SOURCE."CREATED_TIME",
TARGET."UPDATED_TIME"=SOURCE."UPDATED_TIME" WHEN NOT MATCHED THEN INSERT ("ID",
"NAME", "CREATED_TIME", "UPDATED_TIME") VALUES (SOURCE."ID", SOURCE."NAME",
SOURCE."CREATED_TIME", SOURCE."UPDATED_TIME")
2025-09-28 18:05:32,966 INFO [.e.FieldNamedPreparedStatement]
[st-multi-table-sink-writer-1] - PrepareStatement sql is:
DELETE FROM "SCOTT"."NOE" WHERE "ID" = ?
2025-09-28 18:05:33,040 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - pending checkpoint(1/1@1024622854756368385)
notify finished!
2025-09-28 18:05:33,040 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - start notify checkpoint completed, job id:
1024622854756368385, pipeline id: 1, checkpoint id:1
2025-09-28 18:05:33,046 INFO [.c.b.s.e.SnapshotSplitAssigner]
[hz.main.generic-operation.thread-29] - Snapshot split assigner is turn into
completed status.
2025-09-28 18:05:37,866 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - wait checkpoint completed: 2
2025-09-28 18:05:37,882 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - pending checkpoint(2/1@1024622854756368385)
notify finished!
2025-09-28 18:05:37,883 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - start notify checkpoint completed, job id:
1024622854756368385, pipeline id: 1, checkpoint id:2
2025-09-28 18:05:42,864 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - wait checkpoint completed: 3
2025-09-28 18:05:42,879 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - pending checkpoint(3/1@1024622854756368385)
notify finished!
2025-09-28 18:05:42,879 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - start notify checkpoint completed, job id:
1024622854756368385, pipeline id: 1, checkpoint id:3
2025-09-28 18:05:47,867 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - wait checkpoint completed: 4
2025-09-28 18:05:47,888 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - pending checkpoint(4/1@1024622854756368385)
notify finished!
2025-09-28 18:05:47,888 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - start notify checkpoint completed, job id:
1024622854756368385, pipeline id: 1, checkpoint id:4
2025-09-28 18:05:52,867 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - wait checkpoint completed: 5
2025-09-28 18:05:52,886 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - pending checkpoint(5/1@1024622854756368385)
notify finished!
2025-09-28 18:05:52,887 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - start notify checkpoint completed, job id:
1024622854756368385, pipeline id: 1, checkpoint id:5
2025-09-28 18:05:57,868 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - wait checkpoint completed: 6
2025-09-28 18:05:57,908 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - pending checkpoint(6/1@1024622854756368385)
notify finished!
2025-09-28 18:05:57,908 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - start notify checkpoint completed, job id:
1024622854756368385, pipeline id: 1, checkpoint id:6
2025-09-28 18:06:02,870 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - wait checkpoint completed: 7
2025-09-28 18:06:02,889 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - pending checkpoint(7/1@1024622854756368385)
notify finished!
2025-09-28 18:06:02,889 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - start notify checkpoint completed, job id:
1024622854756368385, pipeline id: 1, checkpoint id:7
2025-09-28 18:06:07,870 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - wait checkpoint completed: 8
2025-09-28 18:06:07,889 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - pending checkpoint(8/1@1024622854756368385)
notify finished!
2025-09-28 18:06:07,889 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - start notify checkpoint completed, job id:
1024622854756368385, pipeline id: 1, checkpoint id:8
2025-09-28 18:06:12,872 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - wait checkpoint completed: 9
2025-09-28 18:06:12,897 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - pending checkpoint(9/1@1024622854756368385)
notify finished!
2025-09-28 18:06:12,897 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - start notify checkpoint completed, job id:
1024622854756368385, pipeline id: 1, checkpoint id:9
2025-09-28 18:06:17,872 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - wait checkpoint completed: 10
2025-09-28 18:06:17,893 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - pending
checkpoint(10/1@1024622854756368385) notify finished!
2025-09-28 18:06:17,893 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - start notify checkpoint completed, job id:
1024622854756368385, pipeline id: 1, checkpoint id:10
2025-09-28 18:06:22,873 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - wait checkpoint completed: 11
2025-09-28 18:06:22,893 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - pending
checkpoint(11/1@1024622854756368385) notify finished!
2025-09-28 18:06:22,894 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - start notify checkpoint completed, job id:
1024622854756368385, pipeline id: 1, checkpoint id:11
2025-09-28 18:06:23,517 INFO [o.a.s.e.s.CoordinatorService ]
[pool-7-thread-1] - [localhost]:5801 [seatunnel-402186] [5.1]
***********************************************
CoordinatorService Thread Pool Status
***********************************************
activeCount : 2
corePoolSize : 10
maximumPoolSize : 2147483647
poolSize : 10
completedTaskCount : 74
taskCount : 76
***********************************************
2025-09-28 18:06:23,536 INFO [o.a.s.e.s.CoordinatorService ]
[pool-7-thread-1] - [localhost]:5801 [seatunnel-402186] [5.1]
***********************************************
Job info detail
***********************************************
createdJobCount : 0
scheduledJobCount : 0
runningJobCount : 1
failingJobCount : 0
failedJobCount : 0
cancellingJobCount : 0
canceledJobCount : 0
finishedJobCount : 0
***********************************************
2025-09-28 18:06:27,369 INFO [o.a.s.e.c.j.JobMetricsRunner ]
[job-metrics-runner-1024622854756368385] -
***********************************************
Job Progress Information
***********************************************
Job Id : 1024622854756368385
Read Count So Far : 0
Write Count So Far : 0
Average Read Count : 0/s
Average Write Count : 0/s
Last Statistic Time : 2025-09-28 18:05:27
Current Statistic Time : 2025-09-28 18:06:27
***********************************************
2025-09-28 18:06:27,873 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - wait checkpoint completed: 12
2025-09-28 18:06:27,892 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - pending
checkpoint(12/1@1024622854756368385) notify finished!
2025-09-28 18:06:27,892 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - start notify checkpoint completed, job id:
1024622854756368385, pipeline id: 1, checkpoint id:12
2025-09-28 18:06:32,875 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - wait checkpoint completed: 13
2025-09-28 18:06:32,893 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - pending
checkpoint(13/1@1024622854756368385) notify finished!
2025-09-28 18:06:32,893 INFO [.s.e.s.c.CheckpointCoordinator]
[seatunnel-coordinator-service-8] - start notify checkpoint completed, job id:
1024622854756368385, pipeline id: 1, checkpoint id:13
新配置：env {
# You can set engine configuration here
parallelism = 1
job.mode = "STREAMING"
checkpoint.interval = 5000
}
source {
# This is a example source plugin **only for test and demonstrate the
feature source plugin**
Oracle-CDC {
plugin_output = "customers"
username = "logminer_user"
password = "***"
database-names = ["ORCLCDB"]
schema-names = ["HR"]
table-names = ["ORCLCDB.HR.NOE"]
base-url = "jdbc:oracle:thin:@***/ORCLCDB"
source.reader.close.timeout = 120000
connection.pool.size = 1
schema-changes.enabled = true
}
}
sink {
Jdbc {
plugin_input = "customers"
driver = "oracle.jdbc.driver.OracleDriver"
url = "jdbc:oracle:thin:@***/ORCLCDB"
user = "scott"
password = "***"
generate_sink_sql = true
database = "ORCLCDB"
table = "SCOTT.NOE"
batch_size = 1
primary_keys = ["ID"]
connection.pool.size = 1
}
}
--
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]
