1362227089 commented on issue #12267:
URL: https://github.com/apache/seatunnel/issues/12267#issuecomment-5707698010
Thank you for your analysis.
We will follow the steps below:
1. Execute `ALTER TABLE testdb.test_a REPLICA IDENTITY FULL;` on HighGo,
then verify the updated `relreplident` value.
2. Re-run the job using the standard PostgreSQL JDBC driver and MD5 CDC
user, without modifying ports or connector code.
3. Attach the complete sanitized full exception stack trace and our startup
configuration.
Exception information after re-running:
```
WARNING: sun.reflect.Reflection.getCallerClass is not supported. This will
impact performance.
2026-09-17 10:36:19,460 INFO [c.h.i.c.AbstractConfigLocator ] [main] -
Loading configuration
'/usr/local/seatunnel/apache-seatunnel-2.3.13/config/seatunnel.yaml' from
System property 'seatunnel.config'
2026-09-17 10:36:19,479 INFO [c.h.i.c.AbstractConfigLocator ] [main] -
Using configuration file at
/usr/local/seatunnel/apache-seatunnel-2.3.13/config/seatunnel.yaml
2026-09-17 10:36:19,486 INFO [o.a.s.e.c.c.SeaTunnelConfig ] [main] -
seatunnel.home is /usr/local/seatunnel/apache-seatunnel-2.3.13
2026-09-17 10:36:19,872 INFO [amlSeaTunnelDomConfigProcessor] [main] -
Dynamic slot is enabled, the schedule strategy is set to REJECT
2026-09-17 10:36:19,873 INFO [c.h.i.c.AbstractConfigLocator ] [main] -
Loading configuration
'/usr/local/seatunnel/apache-seatunnel-2.3.13/config/hazelcast.yaml' from
System property 'hazelcast.config'
2026-09-17 10:36:19,874 INFO [c.h.i.c.AbstractConfigLocator ] [main] -
Using configuration file at
/usr/local/seatunnel/apache-seatunnel-2.3.13/config/hazelcast.yaml
2026-09-17 10:36:21,882 INFO [c.h.i.c.AbstractConfigLocator ] [main] -
Loading configuration
'/usr/local/seatunnel/apache-seatunnel-2.3.13/config/hazelcast-client.yaml'
from System property 'hazelcast.client.config'
2026-09-17 10:36:21,883 INFO [c.h.i.c.AbstractConfigLocator ] [main] -
Using configuration file at
/usr/local/seatunnel/apache-seatunnel-2.3.13/config/hazelcast-client.yaml
2026-09-17 10:36:21,971 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
2026-09-17 10:36:22,216 WARN [c.h.i.AddressPicker ] [main] -
[LOCAL] [seatunnel-791971] [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.
2026-09-17 10:36:22,219 INFO [c.h.i.AddressPicker ] [main] -
[LOCAL] [seatunnel-791971] [5.1] Resolving domain name 'localhost' to
address(es): [127.0.0.1, 0:0:0:0:0:0:0:1]
2026-09-17 10:36:22,220 INFO [c.h.i.AddressPicker ] [main] -
[LOCAL] [seatunnel-791971] [5.1] Interfaces is disabled, trying to pick one
address from TCP-IP config addresses: [localhost/127.0.0.1,
localhost/0:0:0:0:0:0:0:1]
2026-09-17 10:36:22,398 INFO [o.a.s.e.s.SeaTunnelServer ] [main] -
SeaTunnel server start...
2026-09-17 10:36:22,423 INFO [c.h.system ] [main] -
[localhost]:5801 [seatunnel-791971] [5.1] Based on Hazelcast IMDG version:
5.1.0 (20220228 - 21f20e7)
2026-09-17 10:36:22,428 INFO [c.h.system ] [main] -
[localhost]:5801 [seatunnel-791971] [5.1] Cluster name: seatunnel-791971
2026-09-17 10:36:22,430 INFO [c.h.system ] [main] -
[localhost]:5801 [seatunnel-791971] [5.1]
_____ _____ _
/ ___| |_ _| | |
\ `--. ___ __ _ | | _ _ _ __ _ __ ___ | |
`--. \ / _ \ / _` | | | | | | || '_ \ | '_ \ / _ \| |
/\__/ /| __/| (_| | | | | |_| || | | || | | || __/| |
\____/ \___| \__,_| \_/ \__,_||_| |_||_| |_| \___||_|
2026-09-17 10:36:22,430 INFO [c.h.system ] [main] -
[localhost]:5801 [seatunnel-791971] [5.1] Copyright © 2021-2024 The Apache
Software Foundation. Apache SeaTunnel, SeaTunnel, and its feather logo are
trademarks of The Apache Software Foundation.
2026-09-17 10:36:22,430 INFO [c.h.system ] [main] -
[localhost]:5801 [seatunnel-791971] [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)
2026-09-17 10:36:22,438 INFO [c.h.system ] [main] -
[localhost]:5801 [seatunnel-791971] [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)
2026-09-17 10:36:24,202 INFO [c.h.s.security ] [main] -
[localhost]:5801 [seatunnel-791971] [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.
2026-09-17 10:36:24,503 INFO [o.a.s.e.s.SeaTunnelNodeContext] [main] -
Using LiteNodeDropOutTcpIpJoiner TCP/IP discovery
2026-09-17 10:36:24,509 WARN [c.h.c.CPSubsystem ] [main] -
[localhost]:5801 [seatunnel-791971] [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.
2026-09-17 10:36:25,263 INFO [.c.c.DefaultClassLoaderService] [main] -
start classloader service with cache mode
2026-09-17 10:36:25,280 INFO [c.h.i.c.AbstractConfigLocator ] [main] -
Loading configuration
'/usr/local/seatunnel/apache-seatunnel-2.3.13/config/seatunnel.yaml' from
System property 'seatunnel.config'
2026-09-17 10:36:25,281 INFO [c.h.i.c.AbstractConfigLocator ] [main] -
Using configuration file at
/usr/local/seatunnel/apache-seatunnel-2.3.13/config/seatunnel.yaml
2026-09-17 10:36:25,333 INFO [amlSeaTunnelDomConfigProcessor] [main] -
Dynamic slot is enabled, the schedule strategy is set to REJECT
2026-09-17 10:36:25,334 INFO [c.h.i.c.AbstractConfigLocator ] [main] -
Loading configuration
'/usr/local/seatunnel/apache-seatunnel-2.3.13/config/hazelcast.yaml' from
System property 'hazelcast.config'
2026-09-17 10:36:25,334 INFO [c.h.i.c.AbstractConfigLocator ] [main] -
Using configuration file at
/usr/local/seatunnel/apache-seatunnel-2.3.13/config/hazelcast.yaml
2026-09-17 10:36:25,381 INFO [o.a.s.e.s.TaskExecutionService] [main] -
[localhost]:5801 [seatunnel-791971] [5.1] Created new BusWork : 1902094533
2026-09-17 10:36:25,390 WARN [o.a.s.e.s.TaskExecutionService]
[pool-3-thread-1] - [localhost]:5801 [seatunnel-791971] [5.1] The Node is not
ready yet, Node state STARTING,looking forward to the next scheduling
2026-09-17 10:36:25,493 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
2026-09-17 10:36:25,505 INFO [o.a.s.e.s.CoordinatorService ] [main] -
[localhost]:5801 [seatunnel-791971] [5.1] Start pending job schedule thread
2026-09-17 10:36:26,468 WARN [o.a.h.u.NativeCodeLoader ] [main] -
Unable to load native-hadoop library for your platform... using builtin-java
classes where applicable
2026-09-17 10:36:27,224 INFO [o.a.s.e.s.CoordinatorService ]
[pool-7-thread-1] - [localhost]:5801 [seatunnel-791971] [5.1]
***********************************************
CoordinatorService Thread Pool Status
***********************************************
activeCount : 1
corePoolSize : 10
maximumPoolSize : 2147483647
poolSize : 1
completedTaskCount : 0
taskCount : 1
***********************************************
2026-09-17 10:36:27,251 INFO [o.a.s.e.s.JettyService ] [main] -
SeaTunnel REST service will start on port 8090
2026-09-17 10:36:27,280 INFO [o.a.s.s.o.e.j.u.log ] [main] -
Logging initialized @13708ms to
org.apache.seatunnel.shade.org.eclipse.jetty.util.log.Slf4jLog
2026-09-17 10:36:27,508 WARN [a.s.s.o.e.j.s.h.ContextHandler] [main] -
Empty contextPath
2026-09-17 10:36:27,710 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 17.0.12+8-LTS-jvmci-23.0-b41
2026-09-17 10:36:27,785 INFO [o.a.s.s.o.e.j.s.session ] [main] -
DefaultSessionIdManager workerName=node0
2026-09-17 10:36:27,785 INFO [o.a.s.s.o.e.j.s.session ] [main] - No
SessionScavenger set, using defaults
2026-09-17 10:36:27,788 INFO [o.a.s.s.o.e.j.s.session ] [main] -
node0 Scavenging every 600000ms
2026-09-17 10:36:28,292 INFO [a.s.s.o.e.j.s.h.ContextHandler] [main] -
Started o.a.s.s.o.e.j.s.ServletContextHandler@118fbaf0{/,null,AVAILABLE}
2026-09-17 10:36:28,321 INFO [.s.s.o.e.j.s.AbstractConnector] [main] -
Started ServerConnector@6a4af081{HTTP/1.1, (http/1.1)}{0.0.0.0:8090}
2026-09-17 10:36:28,321 INFO [o.a.s.s.o.e.j.s.Server ] [main] -
Started @14752ms
2026-09-17 10:36:28,446 INFO [c.h.i.d.Diagnostics ] [main] -
[localhost]:5801 [seatunnel-791971] [5.1] Diagnostics disabled. To enable add
-Dhazelcast.diagnostics.enabled=true to the JVM arguments.
2026-09-17 10:36:28,466 INFO [c.h.c.LifecycleService ] [main] -
[localhost]:5801 [seatunnel-791971] [5.1] [localhost]:5801 is STARTING
2026-09-17 10:36:28,662 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-2] - [localhost]:5801 [seatunnel-791971] [5.1]
[localhost]:5821 is added to the blacklist.
2026-09-17 10:36:28,680 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-13] - [localhost]:5801 [seatunnel-791971] [5.1]
[localhost]:5829 is added to the blacklist.
2026-09-17 10:36:28,679 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-5] - [localhost]:5801 [seatunnel-791971] [5.1]
[localhost]:5815 is added to the blacklist.
2026-09-17 10:36:28,679 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-8] - [localhost]:5801 [seatunnel-791971] [5.1]
[localhost]:5817 is added to the blacklist.
2026-09-17 10:36:28,669 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-1] - [localhost]:5801 [seatunnel-791971] [5.1]
[localhost]:5827 is added to the blacklist.
2026-09-17 10:36:28,668 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-12] - [localhost]:5801 [seatunnel-791971] [5.1]
[localhost]:5808 is added to the blacklist.
2026-09-17 10:36:28,671 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-7] - [localhost]:5801 [seatunnel-791971] [5.1]
[localhost]:5819 is added to the blacklist.
2026-09-17 10:36:28,670 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-9] - [localhost]:5801 [seatunnel-791971] [5.1]
[localhost]:5806 is added to the blacklist.
2026-09-17 10:36:28,670 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-10] - [localhost]:5801 [seatunnel-791971] [5.1]
[localhost]:5804 is added to the blacklist.
2026-09-17 10:36:28,667 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-6] - [localhost]:5801 [seatunnel-791971] [5.1]
[localhost]:5813 is added to the blacklist.
2026-09-17 10:36:28,665 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-11] - [localhost]:5801 [seatunnel-791971] [5.1]
[localhost]:5810 is added to the blacklist.
2026-09-17 10:36:28,660 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-3] - [localhost]:5801 [seatunnel-791971] [5.1]
[localhost]:5823 is added to the blacklist.
2026-09-17 10:36:28,689 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-4] - [localhost]:5801 [seatunnel-791971] [5.1]
[localhost]:5825 is added to the blacklist.
2026-09-17 10:36:28,685 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-14] - [localhost]:5801 [seatunnel-791971] [5.1]
[localhost]:5802 is added to the blacklist.
2026-09-17 10:36:28,691 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-2] - [localhost]:5801 [seatunnel-791971] [5.1]
[localhost]:5822 is added to the blacklist.
2026-09-17 10:36:28,695 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-2] - [localhost]:5801 [seatunnel-791971] [5.1]
[localhost]:5820 is added to the blacklist.
2026-09-17 10:36:28,700 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-2] - [localhost]:5801 [seatunnel-791971] [5.1]
[localhost]:5824 is added to the blacklist.
2026-09-17 10:36:28,701 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-2] - [localhost]:5801 [seatunnel-791971] [5.1]
[localhost]:5814 is added to the blacklist.
2026-09-17 10:36:28,705 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-2] - [localhost]:5801 [seatunnel-791971] [5.1]
[localhost]:5818 is added to the blacklist.
2026-09-17 10:36:28,697 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-15] - [localhost]:5801 [seatunnel-791971] [5.1]
[localhost]:5826 is added to the blacklist.
2026-09-17 10:36:28,708 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-15] - [localhost]:5801 [seatunnel-791971] [5.1]
[localhost]:5807 is added to the blacklist.
2026-09-17 10:36:28,706 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-17] - [localhost]:5801 [seatunnel-791971] [5.1]
[localhost]:5812 is added to the blacklist.
2026-09-17 10:36:28,710 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-17] - [localhost]:5801 [seatunnel-791971] [5.1]
[localhost]:5811 is added to the blacklist.
2026-09-17 10:36:28,707 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-2] - [localhost]:5801 [seatunnel-791971] [5.1]
[localhost]:5816 is added to the blacklist.
2026-09-17 10:36:28,714 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-2] - [localhost]:5801 [seatunnel-791971] [5.1]
[localhost]:5809 is added to the blacklist.
2026-09-17 10:36:28,718 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-2] - [localhost]:5801 [seatunnel-791971] [5.1]
[localhost]:5828 is added to the blacklist.
2026-09-17 10:36:28,716 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-17] - [localhost]:5801 [seatunnel-791971] [5.1]
[localhost]:5830 is added to the blacklist.
2026-09-17 10:36:28,714 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-15] - [localhost]:5801 [seatunnel-791971] [5.1]
[localhost]:5805 is added to the blacklist.
2026-09-17 10:36:28,723 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-2] - [localhost]:5801 [seatunnel-791971] [5.1]
[localhost]:5803 is added to the blacklist.
2026-09-17 10:36:29,710 INFO [c.h.i.c.ClusterService ] [main] -
[localhost]:5801 [seatunnel-791971] [5.1]
Members {size:1, ver:1} [
Member [localhost]:5801 - 487df402-f7e6-430d-b170-e497eab0e0ac [master
node] [active master] this
]
2026-09-17 10:36:29,799 INFO [c.h.c.LifecycleService ] [main] -
[localhost]:5801 [seatunnel-791971] [5.1] [localhost]:5801 is STARTED
2026-09-17 10:36:29,803 INFO [o.a.s.e.s.CoordinatorService ]
[pool-5-thread-1] - [localhost]:5801 [seatunnel-791971] [5.1] This node become
a new active master node, begin init coordinator service
2026-09-17 10:36:29,854 INFO [c.h.i.d.HealthMonitor ]
[hz.main.HealthMonitor] - [localhost]:5801 [seatunnel-791971] [5.1]
processors=8, physical.memory.total=27.2G, physical.memory.free=367.2M,
swap.space.total=0, swap.space.free=0, heap.memory.used=98.8M,
heap.memory.free=157.2M, heap.memory.total=256.0M, heap.memory.max=512.0M,
heap.memory.used/total=38.48%, heap.memory.used/max=19.24%, minor.gc.count=4,
minor.gc.time=133ms, major.gc.count=0, major.gc.time=0ms, load.process=0.00%,
load.system=100.00%, load.systemAverage=20.29, thread.count=132,
thread.peakCount=132, cluster.timeDiff=0, event.q.size=0,
executor.q.async.size=0, executor.q.client.size=0,
executor.q.client.query.size=0, executor.q.client.blocking.size=0,
executor.q.query.size=0, executor.q.scheduled.size=0, executor.q.io.size=0,
executor.q.system.size=0, executor.q.operations.size=0,
executor.q.priorityOperation.size=0, operations.completed.count=2,
executor.q.mapLoad.size=0, executor.q.mapLoadAllKeys.size=
0, executor.q.cluster.size=0, executor.q.response.size=0,
operations.running.count=0, operations.pending.invocations.percentage=0.00%,
operations.pending.invocations.count=0, proxy.count=9, clientEndpoint.count=0,
connection.active.count=0, client.connection.count=0, connection.count=0
2026-09-17 10:36:29,884 INFO [o.a.s.e.s.CoordinatorService ]
[pool-5-thread-1] - [localhost]:5801 [seatunnel-791971] [5.1] Loaded event
handlers: [org.apache.seatunnel.api.event.LoggingEventHandler@639f9afd]
2026-09-17 10:36:29,961 INFO [.h.i.p.i.PartitionStateManager]
[seatunnel-coordinator-service-1] - [localhost]:5801 [seatunnel-791971] [5.1]
Initializing cluster partition table arrangement...
2026-09-17 10:36:30,046 INFO [.c.i.s.ClientInvocationService] [main] -
hz.client_1 [seatunnel-791971] [5.1] Running with 2 response threads,
dynamic=true
2026-09-17 10:36:30,137 INFO [c.h.c.LifecycleService ] [main] -
hz.client_1 [seatunnel-791971] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7)
is STARTING
2026-09-17 10:36:30,146 INFO [c.h.c.LifecycleService ] [main] -
hz.client_1 [seatunnel-791971] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7)
is STARTED
2026-09-17 10:36:30,209 INFO [.c.i.c.ClientConnectionManager] [main] -
hz.client_1 [seatunnel-791971] [5.1] Trying to connect to cluster:
seatunnel-791971
2026-09-17 10:36:30,212 INFO [.c.i.c.ClientConnectionManager] [main] -
hz.client_1 [seatunnel-791971] [5.1] Trying to connect to [localhost]:5801
2026-09-17 10:36:30,331 INFO [.p.t.AuthenticationMessageTask]
[hz.main.priority-generic-operation.thread-0] - [localhost]:5801
[seatunnel-791971] [5.1] Received auth from Connection[id=1,
/127.0.0.1:5801->/127.0.0.1:47583, qualifier=null, endpoint=[127.0.0.1]:47583,
remoteUuid=cac3c785-d373-4c57-a9cd-be64d0ccde80, alive=true,
connectionType=JVM, planeIndex=-1], successfully authenticated, clientUuid:
cac3c785-d373-4c57-a9cd-be64d0ccde80, client name: hz.client_1, client version:
5.1
2026-09-17 10:36:30,340 INFO [c.h.c.LifecycleService ] [main] -
hz.client_1 [seatunnel-791971] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7)
is CLIENT_CONNECTED
2026-09-17 10:36:30,344 INFO [.c.i.c.ClientConnectionManager] [main] -
hz.client_1 [seatunnel-791971] [5.1] Authenticated with server
[localhost]:5801:487df402-f7e6-430d-b170-e497eab0e0ac, server version: 5.1,
local address: /127.0.0.1:47583
2026-09-17 10:36:30,348 INFO [c.h.i.d.Diagnostics ] [main] -
hz.client_1 [seatunnel-791971] [5.1] Diagnostics disabled. To enable add
-Dhazelcast.diagnostics.enabled=true to the JVM arguments.
2026-09-17 10:36:30,393 INFO [c.h.c.i.s.ClientClusterService]
[hz.client_1.event-8] - hz.client_1 [seatunnel-791971] [5.1]
Members [1] {
Member [localhost]:5801 - 487df402-f7e6-430d-b170-e497eab0e0ac [master
node]
}
2026-09-17 10:36:30,490 INFO [.e.s.r.AbstractResourceManager]
[hz.main.generic-operation.thread-1] - Init ResourceManager
2026-09-17 10:36:30,501 INFO [.e.s.r.AbstractResourceManager]
[hz.main.generic-operation.thread-1] - initWorker...
2026-09-17 10:36:30,502 INFO [.e.s.r.AbstractResourceManager]
[hz.main.generic-operation.thread-1] - init live nodes: [[localhost]:5801]
2026-09-17 10:36:30,498 INFO [.c.i.s.ClientStatisticsService] [main] -
Client statistics is enabled with period 5 seconds.
2026-09-17 10:36:30,525 INFO [.e.s.r.AbstractResourceManager]
[hz.main.generic-operation.thread-1] - received new worker register:
[localhost]:5801
2026-09-17 10:36:30,526 INFO [.e.s.r.AbstractResourceManager]
[hz.main.generic-operation.thread-1] - 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)}
2026-09-17 10:36:30,664 INFO [o.a.s.c.s.u.ConfigBuilder ] [main] -
Loading config file from path: ./job/cdc_highgo_to_mysql.conf
2026-09-17 10:36:31,041 INFO [o.a.s.c.s.u.ConfigShadeUtils ] [main] - Load
config shade spi: [base64]
2026-09-17 10:36:31,227 INFO [o.a.s.c.s.u.ConfigBuilder ] [main] -
Parsed config file:
{
"env" : {
"parallelism" : 1,
"job.mode" : "STREAMING",
"checkpoint.interval" : 10000
},
"source" : [
{
"plugin_output" : "highgo_cdc",
"username" : "******",
"password" : "******",
"database-names" : [
"highgo"
],
"schema-names" : [
"testdb"
],
"table-names" : [
"highgo.testdb.test_a"
],
"snapshot" : {
"enabled" : true
},
"url" :
"jdbc:postgresql://172.16.100.202:5866/highgo?loggerLevel=OFF",
"plugin_name" : "Postgres-CDC"
}
],
"sink" : [
{
"plugin_input" : "highgo_cdc",
"url" :
"jdbc:mysql://172.16.100.201:13307/testdb?useSSL=false&serverTimezone=Asia/Shanghai&rewriteBatchedStatements=true",
"driver" : "com.mysql.cj.jdbc.Driver",
"username" : "******",
"password" : "******",
"generate_sink_sql" : true,
"database" : "sdr_platform",
"table" : "${table_name}",
"primary_keys" : [
"id"
],
"plugin_name" : "Jdbc"
}
],
"transform" : []
}
2026-09-17 10:36:31,262 INFO [p.MultipleTableJobConfigParser] [main] - add
common jar in plugins :[]
2026-09-17 10:36:31,351 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load
SeaTunnelSink Plugin from
/usr/local/seatunnel/apache-seatunnel-2.3.13/connectors
2026-09-17 10:36:31,366 INFO [.s.p.d.AbstractPluginDiscovery] [main] -
Discovery plugin jar for: PluginIdentifier{engineType='seatunnel',
pluginType='source', pluginName='Postgres-CDC'} at:
[file:/usr/local/seatunnel/apache-seatunnel-2.3.13/connectors/connector-cdc-base-2.3.13.jar,
file:/usr/local/seatunnel/apache-seatunnel-2.3.13/connectors/connector-cdc-postgres-2.3.13.jar]
2026-09-17 10:36:31,373 INFO [.s.p.d.AbstractPluginDiscovery] [main] - find
connector jar and dependency for PluginIdentifier{engineType='seatunnel',
pluginType='source', pluginName='Postgres-CDC'}:
[file:/usr/local/seatunnel/apache-seatunnel-2.3.13/connectors/connector-cdc-base-2.3.13.jar,
file:/usr/local/seatunnel/apache-seatunnel-2.3.13/connectors/connector-cdc-postgres-2.3.13.jar]
2026-09-17 10:36:31,405 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load
SeaTunnelSink Plugin from
/usr/local/seatunnel/apache-seatunnel-2.3.13/connectors
2026-09-17 10:36:31,451 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load
SeaTunnelSink Plugin from
/usr/local/seatunnel/apache-seatunnel-2.3.13/connectors
2026-09-17 10:36:31,453 INFO [.s.p.d.AbstractPluginDiscovery] [main] -
Discovery plugin jar for: PluginIdentifier{engineType='seatunnel',
pluginType='sink', pluginName='Jdbc'} at:
[file:/usr/local/seatunnel/apache-seatunnel-2.3.13/connectors/connector-jdbc-2.3.13.jar]
2026-09-17 10:36:31,453 INFO [.s.p.d.AbstractPluginDiscovery] [main] - find
connector jar and dependency for PluginIdentifier{engineType='seatunnel',
pluginType='sink', pluginName='Jdbc'}:
[file:/usr/local/seatunnel/apache-seatunnel-2.3.13/connectors/connector-jdbc-2.3.13.jar]
2026-09-17 10:36:31,480 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.
2026-09-17 10:36:31,482 INFO [p.MultipleTableJobConfigParser] [main] -
start generating all sources.
2026-09-17 10:36:31,980 INFO [.s.c.s.j.c.AbstractJdbcCatalog] [main] -
Catalog Postgres established connection to
jdbc:postgresql://172.16.100.202:5866/highgo?loggerLevel=OFF
2026-09-17 10:36:32,187 INFO [o.a.s.a.t.c.CatalogTableUtil ] [main] - Get
catalog tables, cost time: 496 ms
2026-09-17 10:36:32,194 INFO [.s.c.s.j.c.AbstractJdbcCatalog] [main] -
Catalog Postgres closing
2026-09-17 10:36:32,642 INFO [i.d.j.JdbcConnection ]
[pool-8-thread-1] - Connection gracefully closed
2026-09-17 10:36:32,821 WARN [i.d.c.p.TypeRegistry ] [main] -
Unknown OID 12942 requested
2026-09-17 10:36:32,999 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] - Read
list of available databases
2026-09-17 10:36:33,008 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
list of available databases is: [highgo, template1, template0, cflag]
2026-09-17 10:36:33,008 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] - Read
list of available tables in each database
2026-09-17 10:36:33,142 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casealkpld' is filtered out of capturing
2026-09-17 10:36:33,142 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casealkpld' is filtered out of capturing
2026-09-17 10:36:33,143 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casealkpld' is filtered out of capturing
2026-09-17 10:36:33,143 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casealkpld' is filtered out of capturing
2026-09-17 10:36:33,143 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casealkpld' is filtered out of capturing
2026-09-17 10:36:33,144 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casealkpld' is filtered out of capturing
2026-09-17 10:36:33,144 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casealkpld' is filtered out of capturing
2026-09-17 10:36:33,144 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casealkpld' is filtered out of capturing
2026-09-17 10:36:33,145 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casealkpld' is filtered out of capturing
2026-09-17 10:36:33,146 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casealkpld' is filtered out of capturing
2026-09-17 10:36:33,146 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casealkpld' is filtered out of capturing
2026-09-17 10:36:33,146 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casealkpld' is filtered out of capturing
2026-09-17 10:36:33,147 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casealkpld' is filtered out of capturing
2026-09-17 10:36:33,147 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casealkpld' is filtered out of capturing
2026-09-17 10:36:33,147 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casealkpld' is filtered out of capturing
2026-09-17 10:36:33,147 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casealkpld' is filtered out of capturing
2026-09-17 10:36:33,148 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casealkpld' is filtered out of capturing
2026-09-17 10:36:33,148 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casealkpld' is filtered out of capturing
2026-09-17 10:36:33,148 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casealkpld' is filtered out of capturing
2026-09-17 10:36:33,148 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casealkpld' is filtered out of capturing
2026-09-17 10:36:33,162 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casealkpld' is filtered out of capturing
2026-09-17 10:36:33,163 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casealkpld' is filtered out of capturing
2026-09-17 10:36:33,163 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casealkpld' is filtered out of capturing
2026-09-17 10:36:33,163 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casealkpld' is filtered out of capturing
2026-09-17 10:36:33,163 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casealkpld' is filtered out of capturing
2026-09-17 10:36:33,164 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casealkpld' is filtered out of capturing
2026-09-17 10:36:33,164 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casealkpld' is filtered out of capturing
2026-09-17 10:36:33,164 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_caseextend' is filtered out of capturing
2026-09-17 10:36:33,164 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_caseextend' is filtered out of capturing
2026-09-17 10:36:33,164 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_caseextend' is filtered out of capturing
2026-09-17 10:36:33,165 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_caseextend' is filtered out of capturing
2026-09-17 10:36:33,165 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_caseextend' is filtered out of capturing
2026-09-17 10:36:33,165 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_caseextend' is filtered out of capturing
2026-09-17 10:36:33,165 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_caseextend' is filtered out of capturing
2026-09-17 10:36:33,166 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_caseextend' is filtered out of capturing
2026-09-17 10:36:33,166 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_caseextend' is filtered out of capturing
2026-09-17 10:36:33,166 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_caseextend' is filtered out of capturing
2026-09-17 10:36:33,166 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_caseextend' is filtered out of capturing
2026-09-17 10:36:33,166 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_caseextend' is filtered out of capturing
2026-09-17 10:36:33,167 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_caseextend' is filtered out of capturing
2026-09-17 10:36:33,167 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_caseextend' is filtered out of capturing
2026-09-17 10:36:33,167 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_caseextend' is filtered out of capturing
2026-09-17 10:36:33,167 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_caseextend' is filtered out of capturing
2026-09-17 10:36:33,168 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_caseextend' is filtered out of capturing
2026-09-17 10:36:33,168 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_caseextend' is filtered out of capturing
2026-09-17 10:36:33,168 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefishs' is filtered out of capturing
2026-09-17 10:36:33,168 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefishs' is filtered out of capturing
2026-09-17 10:36:33,188 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefishs' is filtered out of capturing
2026-09-17 10:36:33,189 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefishs' is filtered out of capturing
2026-09-17 10:36:33,191 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefishs' is filtered out of capturing
2026-09-17 10:36:33,191 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefishs' is filtered out of capturing
2026-09-17 10:36:33,191 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefishs' is filtered out of capturing
2026-09-17 10:36:33,191 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefishs' is filtered out of capturing
2026-09-17 10:36:33,192 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefishs' is filtered out of capturing
2026-09-17 10:36:33,192 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefishs' is filtered out of capturing
2026-09-17 10:36:33,192 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefishs' is filtered out of capturing
2026-09-17 10:36:33,192 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefishs' is filtered out of capturing
2026-09-17 10:36:33,193 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefishs' is filtered out of capturing
2026-09-17 10:36:33,193 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefishs' is filtered out of capturing
2026-09-17 10:36:33,193 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefishs' is filtered out of capturing
2026-09-17 10:36:33,193 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefishs' is filtered out of capturing
2026-09-17 10:36:33,193 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefishs' is filtered out of capturing
2026-09-17 10:36:33,194 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefishs' is filtered out of capturing
2026-09-17 10:36:33,194 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefishs' is filtered out of capturing
2026-09-17 10:36:33,200 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefishs' is filtered out of capturing
2026-09-17 10:36:33,202 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbl' is filtered out of capturing
2026-09-17 10:36:33,202 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbl' is filtered out of capturing
2026-09-17 10:36:33,202 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbl' is filtered out of capturing
2026-09-17 10:36:33,202 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbl' is filtered out of capturing
2026-09-17 10:36:33,208 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbl' is filtered out of capturing
2026-09-17 10:36:33,209 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbl' is filtered out of capturing
2026-09-17 10:36:33,209 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbl' is filtered out of capturing
2026-09-17 10:36:33,209 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbl' is filtered out of capturing
2026-09-17 10:36:33,209 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbl' is filtered out of capturing
2026-09-17 10:36:33,210 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbl' is filtered out of capturing
2026-09-17 10:36:33,210 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbl' is filtered out of capturing
2026-09-17 10:36:33,210 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbl' is filtered out of capturing
2026-09-17 10:36:33,210 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbl' is filtered out of capturing
2026-09-17 10:36:33,210 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbl' is filtered out of capturing
2026-09-17 10:36:33,211 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbl' is filtered out of capturing
2026-09-17 10:36:33,211 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbl' is filtered out of capturing
2026-09-17 10:36:33,211 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbl' is filtered out of capturing
2026-09-17 10:36:33,211 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbl' is filtered out of capturing
2026-09-17 10:36:33,211 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbl' is filtered out of capturing
2026-09-17 10:36:33,212 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbl' is filtered out of capturing
2026-09-17 10:36:33,213 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbl' is filtered out of capturing
2026-09-17 10:36:33,213 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbl' is filtered out of capturing
2026-09-17 10:36:33,213 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbl' is filtered out of capturing
2026-09-17 10:36:33,214 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbl' is filtered out of capturing
2026-09-17 10:36:33,214 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbl' is filtered out of capturing
2026-09-17 10:36:33,214 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbl' is filtered out of capturing
2026-09-17 10:36:33,215 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbl' is filtered out of capturing
2026-09-17 10:36:33,215 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbl' is filtered out of capturing
2026-09-17 10:36:33,215 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbl' is filtered out of capturing
2026-09-17 10:36:33,215 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbl' is filtered out of capturing
2026-09-17 10:36:33,216 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbl' is filtered out of capturing
2026-09-17 10:36:33,216 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbldnz' is filtered out of capturing
2026-09-17 10:36:33,216 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbldnz' is filtered out of capturing
2026-09-17 10:36:33,216 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbldnz' is filtered out of capturing
2026-09-17 10:36:33,217 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbldnz' is filtered out of capturing
2026-09-17 10:36:33,217 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.xc-cflag-diagnose.biz_casefzbldnz' is filtered out of capturing
2026-09-17 10:36:34,156 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.cflag-diagnose.biz_casetcts' is filtered out of capturing
2026-09-17 10:36:34,156 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.cflag-diagnose.biz_casetcts' is filtered out of capturing
2026-09-17 10:36:34,156 INFO [.c.s.c.p.u.TableDiscoveryUtils] [main] -
'highgo.cflag-diagnose.biz_casetcts' is filtered out of capturing
2026-09-17 10:36:34,174 WARN [.c.s.c.p.u.TableDiscoveryUtils] [main] -
skipping database 'template1' due to error reading tables: 错误: 未实现跨数据库关联:
"template1.information_schema.tables"
位置：15
2026-09-17 10:36:34,177 WARN [.c.s.c.p.u.TableDiscoveryUtils] [main] -
skipping database 'template0' due to error reading tables: 错误: 未实现跨数据库关联:
"template0.information_schema.tables"
位置：15
2026-09-17 10:36:34,178 WARN [.c.s.c.p.u.TableDiscoveryUtils] [main] -
skipping database 'cflag' due to error reading tables: 错误: 未实现跨数据库关联:
"cflag.information_schema.tables"
位置：15
2026-09-17 10:36:34,214 INFO [i.d.j.JdbcConnection ]
[pool-9-thread-1] - Connection gracefully closed
2026-09-17 10:36:34,265 INFO [i.d.j.JdbcConnection ]
[pool-10-thread-1] - Connection gracefully closed
2026-09-17 10:36:34,421 WARN [i.d.c.p.TypeRegistry ] [main] -
Unknown OID 12942 requested
2026-09-17 10:36:34,647 INFO [.a.s.c.c.b.u.CatalogTableUtils] [main] -
Override primary key([id]) for catalog table testdb.test_a
2026-09-17 10:36:34,690 INFO [i.d.j.JdbcConnection ]
[pool-11-thread-1] - Connection gracefully closed
2026-09-17 10:36:34,703 INFO [c.h.c.LifecycleService ] [main] -
hz.client_1 [seatunnel-791971] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7)
is SHUTTING_DOWN
2026-09-17 10:36:34,731 INFO [.c.i.c.ClientConnectionManager] [main] -
hz.client_1 [seatunnel-791971] [5.1] Removed connection to endpoint:
[localhost]:5801:487df402-f7e6-430d-b170-e497eab0e0ac, connection:
ClientConnection{alive=false, connectionId=1,
channel=NioChannel{/127.0.0.1:47583->localhost/127.0.0.1:5801},
remoteAddress=[localhost]:5801, lastReadTime=2026-09-17 10:36:30.655,
lastWriteTime=2026-09-17 10:36:30.637, closedTime=2026-09-17 10:36:34.720,
connected server version=5.1}
2026-09-17 10:36:34,731 INFO [c.h.c.LifecycleService ] [main] -
hz.client_1 [seatunnel-791971] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7)
is CLIENT_DISCONNECTED
2026-09-17 10:36:34,732 INFO [c.h.i.s.t.TcpServerConnection ]
[hz.main.IO.thread-in-1] - [localhost]:5801 [seatunnel-791971] [5.1]
Connection[id=1, /127.0.0.1:5801->/127.0.0.1:47583, qualifier=null,
endpoint=[127.0.0.1]:47583, remoteUuid=cac3c785-d373-4c57-a9cd-be64d0ccde80,
alive=false, connectionType=JVM, planeIndex=-1] closed. Reason: Connection
closed by the other side
2026-09-17 10:36:34,742 INFO [c.h.c.i.ClientEndpointManager ]
[hz.main.event-4] - [localhost]:5801 [seatunnel-791971] [5.1] Destroying
ClientEndpoint{connection=Connection[id=1, /127.0.0.1:5801->/127.0.0.1:47583,
qualifier=null, endpoint=[127.0.0.1]:47583,
remoteUuid=cac3c785-d373-4c57-a9cd-be64d0ccde80, alive=false,
connectionType=JVM, planeIndex=-1],
clientUuid=cac3c785-d373-4c57-a9cd-be64d0ccde80, clientName=hz.client_1,
authenticated=true, clientVersion=5.1, creationTime=1789612590311, latest
clientAttributes=lastStatisticsCollectionTime=1789612590492,enterprise=false,clientType=JVM,clientVersion=5.1,clusterConnectionTimestamp=1789612590245,clientAddress=127.0.0.1,clientName=hz.client_1,credentials.principal=null,os.committedVirtualMemorySize=0,os.freePhysicalMemorySize=362663936,os.freeSwapSpaceSize=0,os.maxFileDescriptorCount=0,os.openFileDescriptorCount=0,os.processCpuTime=0,os.systemLoadAverage=20.29,os.totalPhysicalMemorySize=29206614016,os.totalSwapSpaceSize=0,runtime.a
vailableProcessors=8,runtime.freeMemory=146451648,runtime.maxMemory=536870912,runtime.totalMemory=268435456,runtime.uptime=17003,runtime.usedMemory=121983808,
labels=[]}
2026-09-17 10:36:34,862 INFO [c.h.c.LifecycleService ] [main] -
hz.client_1 [seatunnel-791971] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7)
is SHUTDOWN
2026-09-17 10:36:34,878 INFO [s.c.s.s.c.ClientExecuteCommand] [main] -
Closed SeaTunnel client......
2026-09-17 10:36:34,878 INFO [c.h.c.LifecycleService ] [main] -
[localhost]:5801 [seatunnel-791971] [5.1] [localhost]:5801 is SHUTTING_DOWN
2026-09-17 10:36:34,891 INFO [c.h.i.p.i.MigrationManager ]
[hz.main.cached.thread-3] - [localhost]:5801 [seatunnel-791971] [5.1] Shutdown
request of Member [localhost]:5801 - 487df402-f7e6-430d-b170-e497eab0e0ac
[master node] [active master] this is handled
2026-09-17 10:36:34,917 INFO [c.h.i.i.Node ] [main] -
[localhost]:5801 [seatunnel-791971] [5.1] Shutting down connection manager...
2026-09-17 10:36:34,957 INFO [c.h.i.i.Node ] [main] -
[localhost]:5801 [seatunnel-791971] [5.1] Shutting down node engine...
2026-09-17 10:36:35,001 INFO [o.a.s.e.s.CoordinatorService ]
[pool-5-thread-1] - [localhost]:5801 [seatunnel-791971] [5.1] This node become
leave active master node, begin clear coordinator service
2026-09-17 10:36:35,115 INFO [.s.s.o.e.j.s.AbstractConnector] [main] -
Stopped ServerConnector@6a4af081{HTTP/1.1, (http/1.1)}{0.0.0.0:8090}
2026-09-17 10:36:35,116 INFO [o.a.s.s.o.e.j.s.session ] [main] -
node0 Stopped scavenging
2026-09-17 10:36:35,118 INFO [a.s.s.o.e.j.s.h.ContextHandler] [main] -
Stopped o.a.s.s.o.e.j.s.ServletContextHandler@118fbaf0{/,null,STOPPED}
2026-09-17 10:36:35,133 INFO [.c.c.DefaultClassLoaderService] [main] -
close classloader service
2026-09-17 10:36:35,135 INFO [o.a.s.e.s.EventService ]
[event-forwarder-0] - Event forward thread interrupted
2026-09-17 10:36:36,934 INFO [c.h.i.i.NodeExtension ] [main] -
[localhost]:5801 [seatunnel-791971] [5.1] Destroying node NodeExtension.
2026-09-17 10:36:36,938 INFO [c.h.i.i.Node ] [main] -
[localhost]:5801 [seatunnel-791971] [5.1] Hazelcast Shutdown is completed in
2049 ms.
2026-09-17 10:36:36,939 INFO [c.h.c.LifecycleService ] [main] -
[localhost]:5801 [seatunnel-791971] [5.1] [localhost]:5801 is SHUTDOWN
2026-09-17 10:36:36,939 INFO [s.c.s.s.c.ClientExecuteCommand] [main] -
Closed HazelcastInstance ......
2026-09-17 10:36:36,939 ERROR [o.a.s.c.s.SeaTunnel ] [main] -
===============================================================================
2026-09-17 10:36:36,939 ERROR [o.a.s.c.s.SeaTunnel ] [main] -
Fatal Error,
2026-09-17 10:36:36,939 ERROR [o.a.s.c.s.SeaTunnel ] [main] -
Please submit bug report in https://github.com/apache/seatunnel/issues
2026-09-17 10:36:36,939 ERROR [o.a.s.c.s.SeaTunnel ] [main] -
Reason:SeaTunnel job executed failed
2026-09-17 10:36:36,949 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:266)
at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40)
at
org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:40)
Caused by: org.apache.seatunnel.api.table.factory.FactoryException:
ErrorCode:[API-06], ErrorDescription:[Factory initialize failed] - Unable to
create a source for identifier 'Postgres-CDC'.
at
org.apache.seatunnel.api.table.factory.FactoryUtil.restoreAndPrepareSource(FactoryUtil.java:168)
at
org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:86)
at
org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSource(MultipleTableJobConfigParser.java:397)
at
org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:247)
at
org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.getLogicalDag(ClientJobExecutionEnvironment.java:122)
at
org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.execute(ClientJobExecutionEnvironment.java:190)
at
org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:204)
... 2 more
Caused by: org.apache.seatunnel.common.utils.SeaTunnelException:
java.lang.IllegalStateException: Duplicate key highgo.testdb.test_a (attempted
merging values
Struct{type=CREATE,id="testdb"."test_a",table=Struct{primaryKeyColumnNames=[id],columns=[Struct{name=id,jdbcType=12,nativeType=1043,typeName=varchar,typeExpression=varchar,length=32,scale=0,position=1,optional=false,autoIncremented=false,generated=false},
Struct{name=name,jdbcType=12,nativeType=1043,typeName=varchar,typeExpression=varchar,length=255,scale=0,position=2,optional=true,autoIncremented=false,generated=false},
Struct{name=age,jdbcType=4,nativeType=23,typeName=int4,typeExpression=int4,length=10,scale=0,position=3,optional=true,autoIncremented=false,generated=false},
Struct{name=description,jdbcType=12,nativeType=1043,typeName=varchar,typeExpression=varchar,length=255,scale=0,position=4,optional=true,autoIncremented=false,generated=false},
Struct{name=create_time,jdbcType=93,nativeType=1114,typeName=timestamp,typeEx
pression=timestamp,length=29,scale=6,position=5,optional=true,autoIncremented=false,generated=false}]}}
and
Struct{type=CREATE,id="testdb"."test_a",table=Struct{primaryKeyColumnNames=[id],columns=[Struct{name=id,jdbcType=12,nativeType=1043,typeName=varchar,typeExpression=varchar,length=32,scale=0,position=1,optional=false,autoIncremented=false,generated=false},
Struct{name=name,jdbcType=12,nativeType=1043,typeName=varchar,typeExpression=varchar,length=255,scale=0,position=2,optional=true,autoIncremented=false,generated=false},
Struct{name=age,jdbcType=4,nativeType=23,typeName=int4,typeExpression=int4,length=10,scale=0,position=3,optional=true,autoIncremented=false,generated=false},
Struct{name=description,jdbcType=12,nativeType=1043,typeName=varchar,typeExpression=varchar,length=255,scale=0,position=4,optional=true,autoIncremented=false,generated=false},
Struct{name=create_time,jdbcType=93,nativeType=1114,typeName=timestamp,typeExpression=timestamp,length=29,scale=6,position=5,optio
nal=true,autoIncremented=false,generated=false}]}})
at
org.apache.seatunnel.connectors.seatunnel.cdc.postgres.source.PostgresIncrementalSource.tableChanges(PostgresIncrementalSource.java:155)
at
org.apache.seatunnel.connectors.seatunnel.cdc.postgres.source.PostgresIncrementalSource.createDebeziumDeserializationSchema(PostgresIncrementalSource.java:98)
at
org.apache.seatunnel.connectors.cdc.base.source.IncrementalSource.<init>(IncrementalSource.java:127)
at
org.apache.seatunnel.connectors.seatunnel.cdc.postgres.source.PostgresIncrementalSource.<init>(PostgresIncrementalSource.java:63)
at
org.apache.seatunnel.connectors.seatunnel.cdc.postgres.source.PostgresIncrementalSourceFactory.lambda$createSource$1(PostgresIncrementalSourceFactory.java:110)
at
org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:180)
at
org.apache.seatunnel.api.table.factory.FactoryUtil.restoreAndPrepareSource(FactoryUtil.java:136)
... 8 more
Caused by: java.lang.IllegalStateException: Duplicate key
highgo.testdb.test_a (attempted merging values
Struct{type=CREATE,id="testdb"."test_a",table=Struct{primaryKeyColumnNames=[id],columns=[Struct{name=id,jdbcType=12,nativeType=1043,typeName=varchar,typeExpression=varchar,length=32,scale=0,position=1,optional=false,autoIncremented=false,generated=false},
Struct{name=name,jdbcType=12,nativeType=1043,typeName=varchar,typeExpression=varchar,length=255,scale=0,position=2,optional=true,autoIncremented=false,generated=false},
Struct{name=age,jdbcType=4,nativeType=23,typeName=int4,typeExpression=int4,length=10,scale=0,position=3,optional=true,autoIncremented=false,generated=false},
Struct{name=description,jdbcType=12,nativeType=1043,typeName=varchar,typeExpression=varchar,length=255,scale=0,position=4,optional=true,autoIncremented=false,generated=false},
Struct{name=create_time,jdbcType=93,nativeType=1114,typeName=timestamp,typeExpression=timestamp,length=29,scale=6,position=5,option
al=true,autoIncremented=false,generated=false}]}} and
Struct{type=CREATE,id="testdb"."test_a",table=Struct{primaryKeyColumnNames=[id],columns=[Struct{name=id,jdbcType=12,nativeType=1043,typeName=varchar,typeExpression=varchar,length=32,scale=0,position=1,optional=false,autoIncremented=false,generated=false},
Struct{name=name,jdbcType=12,nativeType=1043,typeName=varchar,typeExpression=varchar,length=255,scale=0,position=2,optional=true,autoIncremented=false,generated=false},
Struct{name=age,jdbcType=4,nativeType=23,typeName=int4,typeExpression=int4,length=10,scale=0,position=3,optional=true,autoIncremented=false,generated=false},
Struct{name=description,jdbcType=12,nativeType=1043,typeName=varchar,typeExpression=varchar,length=255,scale=0,position=4,optional=true,autoIncremented=false,generated=false},
Struct{name=create_time,jdbcType=93,nativeType=1114,typeName=timestamp,typeExpression=timestamp,length=29,scale=6,position=5,optional=true,autoIncremented=false,generated=false}]}})
at
java.base/java.util.stream.Collectors.duplicateKeyException(Collectors.java:135)
at
java.base/java.util.stream.Collectors.lambda$uniqKeysMapAccumulator$1(Collectors.java:182)
at
java.base/java.util.stream.ReduceOps$3ReducingSink.accept(ReduceOps.java:169)
at
java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1625)
at
java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)
at
java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
at
java.base/java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:921)
at
java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
at
java.base/java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:682)
at
org.apache.seatunnel.connectors.seatunnel.cdc.postgres.source.PostgresIncrementalSource.tableChanges(PostgresIncrementalSource.java:142)
... 14 more
2026-09-17 10:36:36,950 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:266)
at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40)
at
org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:40)
Caused by: org.apache.seatunnel.api.table.factory.FactoryException:
ErrorCode:[API-06], ErrorDescription:[Factory initialize failed] - Unable to
create a source for identifier 'Postgres-CDC'.
at
org.apache.seatunnel.api.table.factory.FactoryUtil.restoreAndPrepareSource(FactoryUtil.java:168)
at
org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:86)
at
org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSource(MultipleTableJobConfigParser.java:397)
at
org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:247)
at
org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.getLogicalDag(ClientJobExecutionEnvironment.java:122)
at
org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.execute(ClientJobExecutionEnvironment.java:190)
at
org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:204)
... 2 more
Caused by: org.apache.seatunnel.common.utils.SeaTunnelException:
java.lang.IllegalStateException: Duplicate key highgo.testdb.test_a (attempted
merging values
Struct{type=CREATE,id="testdb"."test_a",table=Struct{primaryKeyColumnNames=[id],columns=[Struct{name=id,jdbcType=12,nativeType=1043,typeName=varchar,typeExpression=varchar,length=32,scale=0,position=1,optional=false,autoIncremented=false,generated=false},
Struct{name=name,jdbcType=12,nativeType=1043,typeName=varchar,typeExpression=varchar,length=255,scale=0,position=2,optional=true,autoIncremented=false,generated=false},
Struct{name=age,jdbcType=4,nativeType=23,typeName=int4,typeExpression=int4,length=10,scale=0,position=3,optional=true,autoIncremented=false,generated=false},
Struct{name=description,jdbcType=12,nativeType=1043,typeName=varchar,typeExpression=varchar,length=255,scale=0,position=4,optional=true,autoIncremented=false,generated=false},
Struct{name=create_time,jdbcType=93,nativeType=1114,typeName=timestamp,typeEx
pression=timestamp,length=29,scale=6,position=5,optional=true,autoIncremented=false,generated=false}]}}
and
Struct{type=CREATE,id="testdb"."test_a",table=Struct{primaryKeyColumnNames=[id],columns=[Struct{name=id,jdbcType=12,nativeType=1043,typeName=varchar,typeExpression=varchar,length=32,scale=0,position=1,optional=false,autoIncremented=false,generated=false},
Struct{name=name,jdbcType=12,nativeType=1043,typeName=varchar,typeExpression=varchar,length=255,scale=0,position=2,optional=true,autoIncremented=false,generated=false},
Struct{name=age,jdbcType=4,nativeType=23,typeName=int4,typeExpression=int4,length=10,scale=0,position=3,optional=true,autoIncremented=false,generated=false},
Struct{name=description,jdbcType=12,nativeType=1043,typeName=varchar,typeExpression=varchar,length=255,scale=0,position=4,optional=true,autoIncremented=false,generated=false},
Struct{name=create_time,jdbcType=93,nativeType=1114,typeName=timestamp,typeExpression=timestamp,length=29,scale=6,position=5,optio
nal=true,autoIncremented=false,generated=false}]}})
at
org.apache.seatunnel.connectors.seatunnel.cdc.postgres.source.PostgresIncrementalSource.tableChanges(PostgresIncrementalSource.java:155)
at
org.apache.seatunnel.connectors.seatunnel.cdc.postgres.source.PostgresIncrementalSource.createDebeziumDeserializationSchema(PostgresIncrementalSource.java:98)
at
org.apache.seatunnel.connectors.cdc.base.source.IncrementalSource.<init>(IncrementalSource.java:127)
at
org.apache.seatunnel.connectors.seatunnel.cdc.postgres.source.PostgresIncrementalSource.<init>(PostgresIncrementalSource.java:63)
at
org.apache.seatunnel.connectors.seatunnel.cdc.postgres.source.PostgresIncrementalSourceFactory.lambda$createSource$1(PostgresIncrementalSourceFactory.java:110)
at
org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:180)
at
org.apache.seatunnel.api.table.factory.FactoryUtil.restoreAndPrepareSource(FactoryUtil.java:136)
... 8 more
Caused by: java.lang.IllegalStateException: Duplicate key
highgo.testdb.test_a (attempted merging values
Struct{type=CREATE,id="testdb"."test_a",table=Struct{primaryKeyColumnNames=[id],columns=[Struct{name=id,jdbcType=12,nativeType=1043,typeName=varchar,typeExpression=varchar,length=32,scale=0,position=1,optional=false,autoIncremented=false,generated=false},
Struct{name=name,jdbcType=12,nativeType=1043,typeName=varchar,typeExpression=varchar,length=255,scale=0,position=2,optional=true,autoIncremented=false,generated=false},
Struct{name=age,jdbcType=4,nativeType=23,typeName=int4,typeExpression=int4,length=10,scale=0,position=3,optional=true,autoIncremented=false,generated=false},
Struct{name=description,jdbcType=12,nativeType=1043,typeName=varchar,typeExpression=varchar,length=255,scale=0,position=4,optional=true,autoIncremented=false,generated=false},
Struct{name=create_time,jdbcType=93,nativeType=1114,typeName=timestamp,typeExpression=timestamp,length=29,scale=6,position=5,option
al=true,autoIncremented=false,generated=false}]}} and
Struct{type=CREATE,id="testdb"."test_a",table=Struct{primaryKeyColumnNames=[id],columns=[Struct{name=id,jdbcType=12,nativeType=1043,typeName=varchar,typeExpression=varchar,length=32,scale=0,position=1,optional=false,autoIncremented=false,generated=false},
Struct{name=name,jdbcType=12,nativeType=1043,typeName=varchar,typeExpression=varchar,length=255,scale=0,position=2,optional=true,autoIncremented=false,generated=false},
Struct{name=age,jdbcType=4,nativeType=23,typeName=int4,typeExpression=int4,length=10,scale=0,position=3,optional=true,autoIncremented=false,generated=false},
Struct{name=description,jdbcType=12,nativeType=1043,typeName=varchar,typeExpression=varchar,length=255,scale=0,position=4,optional=true,autoIncremented=false,generated=false},
Struct{name=create_time,jdbcType=93,nativeType=1114,typeName=timestamp,typeExpression=timestamp,length=29,scale=6,position=5,optional=true,autoIncremented=false,generated=false}]}})
at
java.base/java.util.stream.Collectors.duplicateKeyException(Collectors.java:135)
at
java.base/java.util.stream.Collectors.lambda$uniqKeysMapAccumulator$1(Collectors.java:182)
at
java.base/java.util.stream.ReduceOps$3ReducingSink.accept(ReduceOps.java:169)
at
java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1625)
at
java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)
at
java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
at
java.base/java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:921)
at
java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
at
java.base/java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:682)
at
org.apache.seatunnel.connectors.seatunnel.cdc.postgres.source.PostgresIncrementalSource.tableChanges(PostgresIncrementalSource.java:142)
... 14 more
```
--
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]
