wangbh666 opened a new issue, #9725:
URL: https://github.com/apache/seatunnel/issues/9725

   ### 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
   
   Error reported when synchronizing Oracle data to MySQL
   
   ### SeaTunnel Version
   
   2.3.8
   
   ### SeaTunnel Config
   
   ```conf
   env {
     parallelism = 2
     job.mode = "STREAMING"
     checkpoint.interval = 2000
   }
   
   source {
     Oracle-CDC {
       driver = "oracle.jdbc.driver.OracleDriver"
       username = "logminer_user"
       password = "oracle"
       database-names = ["SINOEPUIAS"]
       schema-names = ["LOGMINER_USER"]
       table-names = ["SINOEPUIAS.LOGMINER_USER.TEST"]
       startup.mode = "initial"
       base-url = "jdbc:oracle:thin:@192.168.80.180:1521:sinoepuias"
       debezium {
        database.oracle.jdbc.timezoneAsRegion = "false"
       }
       source.reader.close.timeout = 120000
     }
   sink {
      jdbc {
       url = 
"jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=UTF-8&rewriteBatchedStatements=true"
       driver = "com.mysql.cj.jdbc.Driver"
       user = "root"
       password = "Mysql@8099"
       support_delete = true
       upsert_key = ["id"]
       query = "insert into ab_copy1(id,time1,newname,type1,num) 
values(?,?,?,?,?) ON DUPLICATE KEY UPDATE id = VALUES(id),time1 = 
VALUES(time1),newname = VALUES(newname),type1 = VALUES(type1),num = VALUES(num)"
     }
   }
   ```
   
   ### Running Command
   
   ```shell
   bin/seatunnel.sh --config config/v2.streaming.conf.template -m local
   ```
   
   ### Error Exception
   
   ```log
   2025-08-19 11:22:09,953 INFO  [c.h.i.c.AbstractConfigLocator ] [main] - 
Loading configuration '/home/apache-seatunnel-2.3.8/config/seatunnel.yaml' from 
System property 'seatunnel.config'
   2025-08-19 11:22:09,956 INFO  [c.h.i.c.AbstractConfigLocator ] [main] - 
Using configuration file at /home/apache-seatunnel-2.3.8/config/seatunnel.yaml
   2025-08-19 11:22:09,958 INFO  [o.a.s.e.c.c.SeaTunnelConfig   ] [main] - 
seatunnel.home is /home/apache-seatunnel-2.3.8
   2025-08-19 11:22:10,035 INFO  [c.h.i.c.AbstractConfigLocator ] [main] - 
Loading configuration '/home/apache-seatunnel-2.3.8/config/hazelcast.yaml' from 
System property 'hazelcast.config'
   2025-08-19 11:22:10,035 INFO  [c.h.i.c.AbstractConfigLocator ] [main] - 
Using configuration file at /home/apache-seatunnel-2.3.8/config/hazelcast.yaml
   2025-08-19 11:22:10,316 INFO  [c.h.i.c.AbstractConfigLocator ] [main] - 
Loading configuration 
'/home/apache-seatunnel-2.3.8/config/hazelcast-client.yaml' from System 
property 'hazelcast.client.config'
   2025-08-19 11:22:10,316 INFO  [c.h.i.c.AbstractConfigLocator ] [main] - 
Using configuration file at 
/home/apache-seatunnel-2.3.8/config/hazelcast-client.yaml
   2025-08-19 11:22:10,365 WARN  [c.h.i.AddressPicker           ] [main] - 
[LOCAL] [seatunnel-702925] [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-08-19 11:22:10,365 INFO  [c.h.i.AddressPicker           ] [main] - 
[LOCAL] [seatunnel-702925] [5.1] Resolving domain name 'localhost' to 
address(es): [127.0.0.1]
   2025-08-19 11:22:10,365 INFO  [c.h.i.AddressPicker           ] [main] - 
[LOCAL] [seatunnel-702925] [5.1] Interfaces is disabled, trying to pick one 
address from TCP-IP config addresses: [localhost/127.0.0.1]
   2025-08-19 11:22:10,386 INFO  [o.a.s.e.s.SeaTunnelServer     ] [main] - 
SeaTunnel server start...
   2025-08-19 11:22:10,388 INFO  [c.h.system                    ] [main] - 
[localhost]:5802 [seatunnel-702925] [5.1] Based on Hazelcast IMDG version: 
5.1.0 (20220228 - 21f20e7)
   2025-08-19 11:22:10,388 INFO  [c.h.system                    ] [main] - 
[localhost]:5802 [seatunnel-702925] [5.1] Cluster name: seatunnel-702925
   2025-08-19 11:22:10,388 INFO  [c.h.system                    ] [main] - 
[localhost]:5802 [seatunnel-702925] [5.1]
   
    _____               _____                             _
   /  ___|             |_   _|                           | |
   \ `--.   ___   __ _   | |   _   _  _ __   _ __    ___ | |
    `--. \ / _ \ / _` |  | |  | | | || '_ \ | '_ \  / _ \| |
   /\__/ /|  __/| (_| |  | |  | |_| || | | || | | ||  __/| |
   \____/  \___| \__,_|  \_/   \__,_||_| |_||_| |_| \___||_|
   
   
   2025-08-19 11:22:10,388 INFO  [c.h.system                    ] [main] - 
[localhost]:5802 [seatunnel-702925] [5.1] Copyright © 2021-2022 The Apache 
Software Foundation. Apache SeaTunnel, SeaTunnel, and its feather logo are 
trademarks of The Apache Software Foundation.
   2025-08-19 11:22:10,388 INFO  [c.h.system                    ] [main] - 
[localhost]:5802 [seatunnel-702925] [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-08-19 11:22:10,390 INFO  [c.h.system                    ] [main] - 
[localhost]:5802 [seatunnel-702925] [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-08-19 11:22:10,723 INFO  [c.h.s.security                ] [main] - 
[localhost]:5802 [seatunnel-702925] [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-08-19 11:22:10,775 INFO  [o.a.s.e.s.SeaTunnelNodeContext] [main] - 
Using LiteNodeDropOutTcpIpJoiner TCP/IP discovery
   2025-08-19 11:22:10,777 WARN  [c.h.c.CPSubsystem             ] [main] - 
[localhost]:5802 [seatunnel-702925] [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-08-19 11:22:10,905 INFO  [.c.c.DefaultClassLoaderService] [main] - 
start classloader service
   2025-08-19 11:22:10,911 INFO  [c.h.i.c.AbstractConfigLocator ] [main] - 
Loading configuration '/home/apache-seatunnel-2.3.8/config/seatunnel.yaml' from 
System property 'seatunnel.config'
   2025-08-19 11:22:10,911 INFO  [c.h.i.c.AbstractConfigLocator ] [main] - 
Using configuration file at /home/apache-seatunnel-2.3.8/config/seatunnel.yaml
   2025-08-19 11:22:10,914 INFO  [c.h.i.c.AbstractConfigLocator ] [main] - 
Loading configuration '/home/apache-seatunnel-2.3.8/config/hazelcast.yaml' from 
System property 'hazelcast.config'
   2025-08-19 11:22:10,914 INFO  [c.h.i.c.AbstractConfigLocator ] [main] - 
Using configuration file at /home/apache-seatunnel-2.3.8/config/hazelcast.yaml
   2025-08-19 11:22:10,923 WARN  [o.a.s.e.s.TaskExecutionService] 
[pool-3-thread-1] - [localhost]:5802 [seatunnel-702925] [5.1] The Node is not 
ready yet, Node state STARTING,looking forward to the next scheduling
   2025-08-19 11:22:10,924 INFO  [o.a.s.e.s.TaskExecutionService] [main] - 
[localhost]:5802 [seatunnel-702925] [5.1] Created new BusWork : 1446238973
   2025-08-19 11:22:10,934 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]:5802
   2025-08-19 11:22:10,937 INFO  [o.a.s.e.s.CoordinatorService  ] 
[pool-6-thread-1] - [localhost]:5802 [seatunnel-702925] [5.1]
   ***********************************************
        CoordinatorService Thread Pool Status
   ***********************************************
   activeCount               :                   0
   corePoolSize              :                   0
   maximumPoolSize           :          2147483647
   poolSize                  :                   0
   completedTaskCount        :                   0
   taskCount                 :                   0
   ***********************************************
   
   2025-08-19 11:22:10,968 INFO  [c.h.i.d.Diagnostics           ] [main] - 
[localhost]:5802 [seatunnel-702925] [5.1] Diagnostics disabled. To enable add 
-Dhazelcast.diagnostics.enabled=true to the JVM arguments.
   2025-08-19 11:22:10,975 INFO  [c.h.c.LifecycleService        ] [main] - 
[localhost]:5802 [seatunnel-702925] [5.1] [localhost]:5802 is STARTING
   2025-08-19 11:22:11,006 INFO  [e.s.LiteNodeDropOutTcpIpJoiner] 
[hz.main.cached.thread-3] - [localhost]:5802 [seatunnel-702925] [5.1] 
[localhost]:5823 is added to the blacklist.
   2025-08-19 11:22:11,006 INFO  [e.s.LiteNodeDropOutTcpIpJoiner] 
[hz.main.cached.thread-1] - [localhost]:5802 [seatunnel-702925] [5.1] 
[localhost]:5827 is added to the blacklist.
   2025-08-19 11:22:11,006 INFO  [e.s.LiteNodeDropOutTcpIpJoiner] 
[hz.main.cached.thread-4] - [localhost]:5802 [seatunnel-702925] [5.1] 
[localhost]:5825 is added to the blacklist.
   2025-08-19 11:22:11,007 INFO  [e.s.LiteNodeDropOutTcpIpJoiner] 
[hz.main.cached.thread-2] - [localhost]:5802 [seatunnel-702925] [5.1] 
[localhost]:5821 is added to the blacklist.
   2025-08-19 11:22:11,011 INFO  [e.s.LiteNodeDropOutTcpIpJoiner] 
[hz.main.cached.thread-2] - [localhost]:5802 [seatunnel-702925] [5.1] 
[localhost]:5815 is added to the blacklist.
   2025-08-19 11:22:11,012 INFO  [e.s.LiteNodeDropOutTcpIpJoiner] 
[hz.main.cached.thread-2] - [localhost]:5802 [seatunnel-702925] [5.1] 
[localhost]:5813 is added to the blacklist.
   2025-08-19 11:22:11,012 INFO  [e.s.LiteNodeDropOutTcpIpJoiner] 
[hz.main.cached.thread-6] - [localhost]:5802 [seatunnel-702925] [5.1] 
[localhost]:5817 is added to the blacklist.
   2025-08-19 11:22:11,012 INFO  [e.s.LiteNodeDropOutTcpIpJoiner] 
[hz.main.cached.thread-5] - [localhost]:5802 [seatunnel-702925] [5.1] 
[localhost]:5819 is added to the blacklist.
   2025-08-19 11:22:11,014 INFO  [e.s.LiteNodeDropOutTcpIpJoiner] 
[hz.main.cached.thread-1] - [localhost]:5802 [seatunnel-702925] [5.1] 
[localhost]:5806 is added to the blacklist.
   2025-08-19 11:22:11,015 INFO  [e.s.LiteNodeDropOutTcpIpJoiner] 
[hz.main.cached.thread-1] - [localhost]:5802 [seatunnel-702925] [5.1] 
[localhost]:5804 is added to the blacklist.
   2025-08-19 11:22:11,016 INFO  [e.s.LiteNodeDropOutTcpIpJoiner] 
[hz.main.cached.thread-1] - [localhost]:5802 [seatunnel-702925] [5.1] 
[localhost]:5808 is added to the blacklist.
   2025-08-19 11:22:11,016 INFO  [e.s.LiteNodeDropOutTcpIpJoiner] 
[hz.main.cached.thread-1] - [localhost]:5802 [seatunnel-702925] [5.1] 
[localhost]:5829 is added to the blacklist.
   2025-08-19 11:22:11,016 INFO  [e.s.LiteNodeDropOutTcpIpJoiner] 
[hz.main.cached.thread-4] - [localhost]:5802 [seatunnel-702925] [5.1] 
[localhost]:5822 is added to the blacklist.
   2025-08-19 11:22:11,016 INFO  [e.s.LiteNodeDropOutTcpIpJoiner] 
[hz.main.cached.thread-1] - [localhost]:5802 [seatunnel-702925] [5.1] 
[localhost]:5820 is added to the blacklist.
   2025-08-19 11:22:11,016 INFO  [e.s.LiteNodeDropOutTcpIpJoiner] 
[hz.main.cached.thread-4] - [localhost]:5802 [seatunnel-702925] [5.1] 
[localhost]:5826 is added to the blacklist.
   2025-08-19 11:22:11,015 INFO  [e.s.LiteNodeDropOutTcpIpJoiner] 
[hz.main.cached.thread-8] - [localhost]:5802 [seatunnel-702925] [5.1] 
[localhost]:5810 is added to the blacklist.
   2025-08-19 11:22:11,018 INFO  [e.s.LiteNodeDropOutTcpIpJoiner] 
[hz.main.cached.thread-4] - [localhost]:5802 [seatunnel-702925] [5.1] 
[localhost]:5814 is added to the blacklist.
   2025-08-19 11:22:11,018 INFO  [e.s.LiteNodeDropOutTcpIpJoiner] 
[hz.main.cached.thread-2] - [localhost]:5802 [seatunnel-702925] [5.1] 
[localhost]:5818 is added to the blacklist.
   2025-08-19 11:22:11,018 INFO  [e.s.LiteNodeDropOutTcpIpJoiner] 
[hz.main.cached.thread-1] - [localhost]:5802 [seatunnel-702925] [5.1] 
[localhost]:5824 is added to the blacklist.
   2025-08-19 11:22:11,022 INFO  [e.s.LiteNodeDropOutTcpIpJoiner] 
[hz.main.cached.thread-3] - [localhost]:5802 [seatunnel-702925] [5.1] 
[localhost]:5812 is added to the blacklist.
   2025-08-19 11:22:11,023 INFO  [e.s.LiteNodeDropOutTcpIpJoiner] 
[hz.main.cached.thread-6] - [localhost]:5802 [seatunnel-702925] [5.1] 
[localhost]:5816 is added to the blacklist.
   2025-08-19 11:22:11,023 INFO  [e.s.LiteNodeDropOutTcpIpJoiner] 
[hz.main.cached.thread-9] - [localhost]:5802 [seatunnel-702925] [5.1] 
[localhost]:5807 is added to the blacklist.
   2025-08-19 11:22:11,023 INFO  [e.s.LiteNodeDropOutTcpIpJoiner] 
[hz.main.cached.thread-6] - [localhost]:5802 [seatunnel-702925] [5.1] 
[localhost]:5805 is added to the blacklist.
   2025-08-19 11:22:11,027 INFO  [e.s.LiteNodeDropOutTcpIpJoiner] 
[hz.main.cached.thread-9] - [localhost]:5802 [seatunnel-702925] [5.1] 
[localhost]:5811 is added to the blacklist.
   2025-08-19 11:22:11,028 INFO  [e.s.LiteNodeDropOutTcpIpJoiner] 
[hz.main.cached.thread-12] - [localhost]:5802 [seatunnel-702925] [5.1] 
[localhost]:5809 is added to the blacklist.
   2025-08-19 11:22:11,031 INFO  [e.s.LiteNodeDropOutTcpIpJoiner] 
[hz.main.cached.thread-12] - [localhost]:5802 [seatunnel-702925] [5.1] 
[localhost]:5830 is added to the blacklist.
   2025-08-19 11:22:11,031 INFO  [e.s.LiteNodeDropOutTcpIpJoiner] 
[hz.main.cached.thread-11] - [localhost]:5802 [seatunnel-702925] [5.1] 
[localhost]:5828 is added to the blacklist.
   2025-08-19 11:22:11,035 INFO  [e.s.LiteNodeDropOutTcpIpJoiner] 
[hz.main.cached.thread-11] - [localhost]:5802 [seatunnel-702925] [5.1] 
[localhost]:5803 is added to the blacklist.
   2025-08-19 11:22:11,042 INFO  [c.h.i.s.t.TcpServerConnection ] 
[hz.main.IO.thread-in-1] - [localhost]:5802 [seatunnel-702925] [5.1] 
Initialized new cluster connection between /127.0.0.1:56738 and 
localhost/127.0.0.1:5801
   2025-08-19 11:22:11,137 INFO  [c.h.i.s.t.TcpServerConnection ] 
[hz.main.priority-generic-operation.thread-0] - [localhost]:5802 
[seatunnel-702925] [5.1] Connection[id=1, 
/127.0.0.1:56738->localhost/127.0.0.1:5801, qualifier=null, 
endpoint=[localhost]:5801, remoteUuid=ccd1186b-f456-4b08-b6c9-4c4845ef7fc0, 
alive=false, connectionType=MEMBER, planeIndex=0] closed. Reason: Node could 
not join cluster at node: [localhost]:5801 Cause: the target cluster has a 
different cluster-name
   2025-08-19 11:22:11,139 WARN  [c.h.cluster                   ] 
[hz.main.priority-generic-operation.thread-0] - [localhost]:5802 
[seatunnel-702925] [5.1] Node could not join cluster at node: [localhost]:5801 
Cause: the target cluster has a different cluster-name
   2025-08-19 11:22:11,139 INFO  [e.s.LiteNodeDropOutTcpIpJoiner] 
[hz.main.priority-generic-operation.thread-0] - [localhost]:5802 
[seatunnel-702925] [5.1] [127.0.0.1]:5801 is permanently added to the blacklist.
   2025-08-19 11:22:11,139 INFO  [e.s.LiteNodeDropOutTcpIpJoiner] 
[hz.main.priority-generic-operation.thread-0] - [localhost]:5802 
[seatunnel-702925] [5.1] [localhost]:5801 is permanently added to the blacklist.
   2025-08-19 11:22:12,036 INFO  [c.h.i.c.ClusterService        ] [main] - 
[localhost]:5802 [seatunnel-702925] [5.1]
   
   Members {size:1, ver:1} [
           Member [localhost]:5802 - f80d72d7-95a9-4eb2-844e-b5bf390373d9 this 
master
   ]
   
   2025-08-19 11:22:12,036 WARN  [c.h.i.i.Node                  ] [main] - 
[localhost]:5802 [seatunnel-702925] [5.1] Config seed port is 5801 and cluster 
size is 1. Some of the ports seem occupied!
   2025-08-19 11:22:12,087 INFO  [c.h.c.LifecycleService        ] [main] - 
[localhost]:5802 [seatunnel-702925] [5.1] [localhost]:5802 is STARTED
   2025-08-19 11:22:12,117 INFO  [.c.i.s.ClientInvocationService] [main] - 
hz.client_1 [seatunnel-702925] [5.1] Running with 2 response threads, 
dynamic=true
   2025-08-19 11:22:12,125 INFO  [c.h.c.LifecycleService        ] [main] - 
hz.client_1 [seatunnel-702925] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) 
is STARTING
   2025-08-19 11:22:12,126 INFO  [c.h.c.LifecycleService        ] [main] - 
hz.client_1 [seatunnel-702925] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) 
is STARTED
   2025-08-19 11:22:12,130 INFO  [.c.i.c.ClientConnectionManager] [main] - 
hz.client_1 [seatunnel-702925] [5.1] Trying to connect to cluster: 
seatunnel-702925
   2025-08-19 11:22:12,132 INFO  [.c.i.c.ClientConnectionManager] [main] - 
hz.client_1 [seatunnel-702925] [5.1] Trying to connect to [localhost]:5802
   2025-08-19 11:22:12,135 INFO  [o.a.s.e.s.CoordinatorService  ] 
[pool-5-thread-1] - [localhost]:5802 [seatunnel-702925] [5.1] This node become 
a new active master node, begin init coordinator service
   2025-08-19 11:22:12,142 INFO  [.p.t.AuthenticationMessageTask] 
[hz.main.priority-generic-operation.thread-0] - [localhost]:5802 
[seatunnel-702925] [5.1] Received auth from Connection[id=2, 
/127.0.0.1:5802->/127.0.0.1:50965, qualifier=null, endpoint=[127.0.0.1]:50965, 
remoteUuid=35ad105c-05bd-4e63-97fc-1090be393ca0, alive=true, 
connectionType=JVM, planeIndex=-1], successfully authenticated, clientUuid: 
35ad105c-05bd-4e63-97fc-1090be393ca0, client name: hz.client_1, client version: 
5.1
   2025-08-19 11:22:12,144 INFO  [c.h.c.LifecycleService        ] [main] - 
hz.client_1 [seatunnel-702925] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) 
is CLIENT_CONNECTED
   2025-08-19 11:22:12,144 INFO  [.c.i.c.ClientConnectionManager] [main] - 
hz.client_1 [seatunnel-702925] [5.1] Authenticated with server 
[localhost]:5802:f80d72d7-95a9-4eb2-844e-b5bf390373d9, server version: 5.1, 
local address: /127.0.0.1:50965
   2025-08-19 11:22:12,145 INFO  [c.h.i.d.Diagnostics           ] [main] - 
hz.client_1 [seatunnel-702925] [5.1] Diagnostics disabled. To enable add 
-Dhazelcast.diagnostics.enabled=true to the JVM arguments.
   2025-08-19 11:22:12,149 INFO  [c.h.c.i.s.ClientClusterService] 
[hz.client_1.event-9] - hz.client_1 [seatunnel-702925] [5.1]
   
   Members [1] {
           Member [localhost]:5802 - f80d72d7-95a9-4eb2-844e-b5bf390373d9
   }
   
   2025-08-19 11:22:12,164 INFO  [.c.i.s.ClientStatisticsService] [main] - 
Client statistics is enabled with period 5 seconds.
   2025-08-19 11:22:12,255 INFO  [o.a.s.e.s.CoordinatorService  ] 
[pool-5-thread-1] - [localhost]:5802 [seatunnel-702925] [5.1] Loaded event 
handlers: [org.apache.seatunnel.api.event.LoggingEventHandler@2f0012ff]
   2025-08-19 11:22:12,268 INFO  [.h.i.p.i.PartitionStateManager] 
[seatunnel-coordinator-service-0] - [localhost]:5802 [seatunnel-702925] [5.1] 
Initializing cluster partition table arrangement...
   2025-08-19 11:22:12,273 INFO  [o.a.s.c.s.u.ConfigBuilder     ] [main] - 
Loading config file from path: config/v2.streaming.conf.template
   2025-08-19 11:22:12,358 INFO  [o.a.s.c.s.u.ConfigShadeUtils  ] [main] - Load 
config shade spi: [base64]
   2025-08-19 11:22:12,387 INFO  [o.a.s.c.s.u.ConfigBuilder     ] [main] - 
Parsed config file:
   {
       "sink" : [
           {
               "support_delete" : true,
               "password" : "******",
               "driver" : "com.mysql.cj.jdbc.Driver",
               "query" : "insert into ab_copy1(id,time1,newname,type1,num) 
values(?,?,?,?,?) ON DUPLICATE KEY UPDATE id = VALUES(id),time1 = 
VALUES(time1),newname = VALUES(newname),type1 = VALUES(type1),num = 
VALUES(num)",
               "upsert_key" : [
                   "id"
               ],
               "plugin_name" : "jdbc",
               "user" : "root",
               "url" : 
"jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=UTF-8&rewriteBatchedStatements=true"
           }
       ],
       "source" : [
           {
               "base-url" : "jdbc:oracle:thin:@192.168.80.180:1521:sinoepuias",
               "password" : "******",
               "startup.mode" : "initial",
               "driver" : "oracle.jdbc.driver.OracleDriver",
               "debezium" : {
                   "database.oracle.jdbc.timezoneAsRegion" : "false"
               },
               "table-names" : [
                   "SINOEPUIAS.LOGMINER_USER.TEST"
               ],
               "database-names" : [
                   "SINOEPUIAS"
               ],
               "schema-names" : [
                   "LOGMINER_USER"
               ],
               "source.reader.close.timeout" : 120000,
               "plugin_name" : "Oracle-CDC",
               "username" : "******"
           }
       ],
       "env" : {
           "job.mode" : "STREAMING",
           "parallelism" : 2,
           "checkpoint.interval" : 2000
       }
   }
   
   2025-08-19 11:22:12,393 INFO  [p.MultipleTableJobConfigParser] [main] - add 
common jar in plugins 
:[file:/home/apache-seatunnel-2.3.8/plugins/jdbc/lib/mssql-jdbc-9.4.0.jre8.jar, 
file:/home/apache-seatunnel-2.3.8/plugins/jdbc/lib/seatunnel-hadoop3-3.1.4-uber.jar,
 
file:/home/apache-seatunnel-2.3.8/plugins/jdbc/lib/mysql-connector-java-8.0.27.jar,
 file:/home/apache-seatunnel-2.3.8/plugins/jdbc/lib/ojdbc8-12.2.0.1.jar]
   2025-08-19 11:22:12,401 INFO  [.s.p.d.AbstractPluginDiscovery] [main] - Load 
SeaTunnelSink Plugin from /home/apache-seatunnel-2.3.8/connectors
   2025-08-19 11:22:12,403 INFO  [.s.p.d.AbstractPluginDiscovery] [main] - 
Discovery plugin jar for: PluginIdentifier{engineType='seatunnel', 
pluginType='source', pluginName='Oracle-CDC'} at: 
file:/home/apache-seatunnel-2.3.8/connectors/connector-cdc-oracle-2.3.8.jar
   2025-08-19 11:22:12,403 INFO  [.s.p.d.AbstractPluginDiscovery] [main] - 
Discovery plugin jar for: PluginIdentifier{engineType='seatunnel', 
pluginType='sink', pluginName='jdbc'} at: 
file:/home/apache-seatunnel-2.3.8/connectors/connector-jdbc-2.3.8.jar
   2025-08-19 11:22:12,405 INFO  [p.MultipleTableJobConfigParser] [main] - 
start generating all sources.
   2025-08-19 11:22:12,971 INFO  [.s.c.s.j.c.AbstractJdbcCatalog] [main] - 
Catalog Oracle established connection to 
jdbc:oracle:thin:@192.168.80.180:1521:sinoepuias
   2025-08-19 11:22:13,139 INFO  [o.a.s.a.t.c.CatalogTableUtil  ] [main] - Get 
catalog tables, cost time: 698 ms
   2025-08-19 11:22:13,155 INFO  [.s.c.s.j.c.AbstractJdbcCatalog] [main] - 
Catalog Oracle closing
   2025-08-19 11:22:13,157 INFO  [c.h.c.LifecycleService        ] [main] - 
hz.client_1 [seatunnel-702925] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) 
is SHUTTING_DOWN
   2025-08-19 11:22:13,159 INFO  [c.h.i.s.t.TcpServerConnection ] 
[hz.main.IO.thread-in-0] - [localhost]:5802 [seatunnel-702925] [5.1] 
Connection[id=2, /127.0.0.1:5802->/127.0.0.1:50965, qualifier=null, 
endpoint=[127.0.0.1]:50965, remoteUuid=35ad105c-05bd-4e63-97fc-1090be393ca0, 
alive=false, connectionType=JVM, planeIndex=-1] closed. Reason: Connection 
closed by the other side
   2025-08-19 11:22:13,160 INFO  [.c.i.c.ClientConnectionManager] [main] - 
hz.client_1 [seatunnel-702925] [5.1] Removed connection to endpoint: 
[localhost]:5802:f80d72d7-95a9-4eb2-844e-b5bf390373d9, connection: 
ClientConnection{alive=false, connectionId=1, 
channel=NioChannel{/127.0.0.1:50965->localhost/127.0.0.1:5802}, 
remoteAddress=[localhost]:5802, lastReadTime=2025-08-19 11:22:12.380, 
lastWriteTime=2025-08-19 11:22:12.267, closedTime=2025-08-19 11:22:13.158, 
connected server version=5.1}
   2025-08-19 11:22:13,160 INFO  [c.h.c.LifecycleService        ] [main] - 
hz.client_1 [seatunnel-702925] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) 
is CLIENT_DISCONNECTED
   2025-08-19 11:22:13,160 INFO  [c.h.c.i.ClientEndpointManager ] 
[hz.main.event-1] - [localhost]:5802 [seatunnel-702925] [5.1] Destroying 
ClientEndpoint{connection=Connection[id=2, /127.0.0.1:5802->/127.0.0.1:50965, 
qualifier=null, endpoint=[127.0.0.1]:50965, 
remoteUuid=35ad105c-05bd-4e63-97fc-1090be393ca0, alive=false, 
connectionType=JVM, planeIndex=-1], 
clientUuid=35ad105c-05bd-4e63-97fc-1090be393ca0, clientName=hz.client_1, 
authenticated=true, clientVersion=5.1, creationTime=1755573732140, latest 
clientAttributes=lastStatisticsCollectionTime=1755573732163,enterprise=false,clientType=JVM,clientVersion=5.1,clusterConnectionTimestamp=1755573732133,clientAddress=127.0.0.1,clientName=hz.client_1,credentials.principal=null,os.committedVirtualMemorySize=4335112192,os.freePhysicalMemorySize=328450048,os.freeSwapSpaceSize=8223715328,os.maxFileDescriptorCount=1048576,os.openFileDescriptorCount=55,os.processCpuTime=5190000000,os.systemLoadAverage=0.17,os.totalPhysicalMemorySize=16527048704,
 
os.totalSwapSpaceSize=8388603904,runtime.availableProcessors=4,runtime.freeMemory=278331600,runtime.maxMemory=477626368,runtime.totalMemory=330825728,runtime.uptime=2676,runtime.usedMemory=52494128,
 labels=[]}
   2025-08-19 11:22:13,162 INFO  [c.h.c.LifecycleService        ] [main] - 
hz.client_1 [seatunnel-702925] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) 
is SHUTDOWN
   2025-08-19 11:22:13,162 INFO  [s.c.s.s.c.ClientExecuteCommand] [main] - 
Closed SeaTunnel client......
   2025-08-19 11:22:13,162 INFO  [c.h.c.LifecycleService        ] [main] - 
[localhost]:5802 [seatunnel-702925] [5.1] [localhost]:5802 is SHUTTING_DOWN
   2025-08-19 11:22:13,164 INFO  [c.h.i.p.i.MigrationManager    ] 
[hz.main.cached.thread-6] - [localhost]:5802 [seatunnel-702925] [5.1] Shutdown 
request of Member [localhost]:5802 - f80d72d7-95a9-4eb2-844e-b5bf390373d9 this 
master is handled
   2025-08-19 11:22:13,168 INFO  [c.h.i.i.Node                  ] [main] - 
[localhost]:5802 [seatunnel-702925] [5.1] Shutting down connection manager...
   2025-08-19 11:22:13,170 INFO  [c.h.i.i.Node                  ] [main] - 
[localhost]:5802 [seatunnel-702925] [5.1] Shutting down node engine...
   2025-08-19 11:22:13,176 INFO  [.c.c.DefaultClassLoaderService] [main] - 
close classloader service
   2025-08-19 11:22:13,179 INFO  [o.a.s.e.s.EventService        ] 
[event-forwarder-0] - Event forward thread interrupted
   2025-08-19 11:22:16,194 INFO  [c.h.i.i.NodeExtension         ] [main] - 
[localhost]:5802 [seatunnel-702925] [5.1] Destroying node NodeExtension.
   2025-08-19 11:22:16,195 INFO  [c.h.i.i.Node                  ] [main] - 
[localhost]:5802 [seatunnel-702925] [5.1] Hazelcast Shutdown is completed in 
3031 ms.
   2025-08-19 11:22:16,195 INFO  [c.h.c.LifecycleService        ] [main] - 
[localhost]:5802 [seatunnel-702925] [5.1] [localhost]:5802 is SHUTDOWN
   2025-08-19 11:22:16,195 INFO  [s.c.s.s.c.ClientExecuteCommand] [main] - 
Closed HazelcastInstance ......
   2025-08-19 11:22:16,195 ERROR [o.a.s.c.s.SeaTunnel           ] [main] -
   
   
===============================================================================
   
   
   2025-08-19 11:22:16,195 ERROR [o.a.s.c.s.SeaTunnel           ] [main] - 
Fatal Error,
   
   2025-08-19 11:22:16,195 ERROR [o.a.s.c.s.SeaTunnel           ] [main] - 
Please submit bug report in https://github.com/apache/seatunnel/issues
   
   2025-08-19 11:22:16,195 ERROR [o.a.s.c.s.SeaTunnel           ] [main] - 
Reason:SeaTunnel job executed failed
   
   2025-08-19 11:22:16,197 ERROR [o.a.s.c.s.SeaTunnel           ] [main] - 
Exception 
StackTrace:org.apache.seatunnel.core.starter.exception.CommandExecuteException: 
SeaTunnel job executed failed
           at 
org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:213)
           at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40)
           at 
org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:34)
   Caused by: org.apache.seatunnel.api.table.factory.FactoryException: 
ErrorCode:[API-06], ErrorDescription:[Factory initialize failed] - Unable to 
create a source for identifier 'Oracle-CDC'.
           at 
org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:101)
           at 
org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSource(MultipleTableJobConfigParser.java:375)
           at 
org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:209)
           at 
org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.getLogicalDag(ClientJobExecutionEnvironment.java:114)
           at 
org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.execute(ClientJobExecutionEnvironment.java:182)
           at 
org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:160)
           ... 2 more
   Caused by: org.apache.seatunnel.common.utils.SeaTunnelException: Can not 
find catalog table with factoryId [Oracle]
           at 
org.apache.seatunnel.api.table.catalog.CatalogTableUtil.lambda$getCatalogTables$0(CatalogTableUtil.java:131)
           at java.util.Optional.map(Optional.java:215)
           at 
org.apache.seatunnel.api.table.catalog.CatalogTableUtil.getCatalogTables(CatalogTableUtil.java:118)
           at 
org.apache.seatunnel.api.table.catalog.CatalogTableUtil.getCatalogTables(CatalogTableUtil.java:98)
           at 
org.apache.seatunnel.connectors.seatunnel.cdc.oracle.source.OracleIncrementalSourceFactory.lambda$createSource$1(OracleIncrementalSourceFactory.java:108)
           at 
org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:113)
           at 
org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:74)
           ... 7 more
   
   2025-08-19 11:22:16,197 ERROR [o.a.s.c.s.SeaTunnel           ] [main] -
   
===============================================================================
   
   
   
   Exception in thread "main" 
org.apache.seatunnel.core.starter.exception.CommandExecuteException: SeaTunnel 
job executed failed
           at 
org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:213)
           at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40)
           at 
org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:34)
   Caused by: org.apache.seatunnel.api.table.factory.FactoryException: 
ErrorCode:[API-06], ErrorDescription:[Factory initialize failed] - Unable to 
create a source for identifier 'Oracle-CDC'.
           at 
org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:101)
           at 
org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSource(MultipleTableJobConfigParser.java:375)
           at 
org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:209)
           at 
org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.getLogicalDag(ClientJobExecutionEnvironment.java:114)
           at 
org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.execute(ClientJobExecutionEnvironment.java:182)
           at 
org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:160)
           ... 2 more
   Caused by: org.apache.seatunnel.common.utils.SeaTunnelException: Can not 
find catalog table with factoryId [Oracle]
           at 
org.apache.seatunnel.api.table.catalog.CatalogTableUtil.lambda$getCatalogTables$0(CatalogTableUtil.java:131)
           at java.util.Optional.map(Optional.java:215)
           at 
org.apache.seatunnel.api.table.catalog.CatalogTableUtil.getCatalogTables(CatalogTableUtil.java:118)
           at 
org.apache.seatunnel.api.table.catalog.CatalogTableUtil.getCatalogTables(CatalogTableUtil.java:98)
           at 
org.apache.seatunnel.connectors.seatunnel.cdc.oracle.source.OracleIncrementalSourceFactory.lambda$createSource$1(OracleIncrementalSourceFactory.java:108)
           at 
org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:113)
           at 
org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:74)
           ... 7 more
   ```
   
   ### Zeta or Flink or Spark Version
   
   _No response_
   
   ### Java or Scala Version
   
   openjdk version "1.8.0_412"
   
   ### Screenshots
   
   _No response_
   
   ### 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]

Reply via email to