1362227089 commented on issue #12267:
URL: https://github.com/apache/seatunnel/issues/12267#issuecomment-5658449393
Thank you for your reply. I was completely confused by this database. I
added both HgdbJdbc-6.2.5.jar and postgresql-42.7.13.jar libraries
simultaneously in /apache-seatunnel-2.3.13/lib, and
connector-cdc-postgres-2.3.13.jar in /apache-seatunnel-2.3.13/connectors.
I want to confirm whether HigGo db 4.5.8 supports PostgreSQL. If not, do I
need to develop it myself?
Have the actual documentation examples been tested?
Here is the complete log:
`WARNING: sun.reflect.Reflection.getCallerClass is not supported. This will
impact performance.
2026-09-14 10:54:04,371 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-14 10:54:04,380 INFO [c.h.i.c.AbstractConfigLocator ] [main] -
Using configuration file at
/usr/local/seatunnel/apache-seatunnel-2.3.13/config/seatunnel.yaml
2026-09-14 10:54:04,386 INFO [o.a.s.e.c.c.SeaTunnelConfig ] [main] -
seatunnel.home is /usr/local/seatunnel/apache-seatunnel-2.3.13
2026-09-14 10:54:04,631 INFO [amlSeaTunnelDomConfigProcessor] [main] -
Dynamic slot is enabled, the schedule strategy is set to REJECT
2026-09-14 10:54:04,633 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-14 10:54:04,634 INFO [c.h.i.c.AbstractConfigLocator ] [main] -
Using configuration file at
/usr/local/seatunnel/apache-seatunnel-2.3.13/config/hazelcast.yaml
2026-09-14 10:54:05,590 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-14 10:54:05,591 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-14 10:54:05,636 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-14 10:54:05,759 WARN [c.h.i.AddressPicker ] [main] -
[LOCAL] [seatunnel-68020] [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-14 10:54:05,759 INFO [c.h.i.AddressPicker ] [main] -
[LOCAL] [seatunnel-68020] [5.1] Resolving domain name 'localhost' to
address(es): [127.0.0.1, 0:0:0:0:0:0:0:1]
2026-09-14 10:54:05,760 INFO [c.h.i.AddressPicker ] [main] -
[LOCAL] [seatunnel-68020] [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-14 10:54:05,857 INFO [o.a.s.e.s.SeaTunnelServer ] [main] -
SeaTunnel server start...
2026-09-14 10:54:05,862 INFO [c.h.system ] [main] -
[localhost]:5801 [seatunnel-68020] [5.1] Based on Hazelcast IMDG version: 5.1.0
(20220228 - 21f20e7)
2026-09-14 10:54:05,863 INFO [c.h.system ] [main] -
[localhost]:5801 [seatunnel-68020] [5.1] Cluster name: seatunnel-68020
2026-09-14 10:54:05,863 INFO [c.h.system ] [main] -
[localhost]:5801 [seatunnel-68020] [5.1]
_____ _____ _
/ ___| |_ _| | |
\ `--. ___ __ _ | | _ _ _ __ _ __ ___ | |
`--. \ / _ \ / _` | | | | | | || '_ \ | '_ \ / _ \| |
/\__/ /| __/| (_| | | | | |_| || | | || | | || __/| |
\____/ \___| \__,_| \_/ \__,_||_| |_||_| |_| \___||_|
2026-09-14 10:54:05,864 INFO [c.h.system ] [main] -
[localhost]:5801 [seatunnel-68020] [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-14 10:54:05,865 INFO [c.h.system ] [main] -
[localhost]:5801 [seatunnel-68020] [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-14 10:54:05,870 INFO [c.h.system ] [main] -
[localhost]:5801 [seatunnel-68020] [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-14 10:54:06,900 INFO [c.h.s.security ] [main] -
[localhost]:5801 [seatunnel-68020] [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-14 10:54:07,079 INFO [o.a.s.e.s.SeaTunnelNodeContext] [main] -
Using LiteNodeDropOutTcpIpJoiner TCP/IP discovery
2026-09-14 10:54:07,084 WARN [c.h.c.CPSubsystem ] [main] -
[localhost]:5801 [seatunnel-68020] [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-14 10:54:07,515 INFO [.c.c.DefaultClassLoaderService] [main] -
start classloader service with cache mode
2026-09-14 10:54:07,529 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-14 10:54:07,530 INFO [c.h.i.c.AbstractConfigLocator ] [main] -
Using configuration file at
/usr/local/seatunnel/apache-seatunnel-2.3.13/config/seatunnel.yaml
2026-09-14 10:54:07,543 INFO [amlSeaTunnelDomConfigProcessor] [main] -
Dynamic slot is enabled, the schedule strategy is set to REJECT
2026-09-14 10:54:07,544 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-14 10:54:07,545 INFO [c.h.i.c.AbstractConfigLocator ] [main] -
Using configuration file at
/usr/local/seatunnel/apache-seatunnel-2.3.13/config/hazelcast.yaml
2026-09-14 10:54:07,573 INFO [o.a.s.e.s.TaskExecutionService] [main] -
[localhost]:5801 [seatunnel-68020] [5.1] Created new BusWork : 102946788
2026-09-14 10:54:07,574 WARN [o.a.s.e.s.TaskExecutionService]
[pool-3-thread-1] - [localhost]:5801 [seatunnel-68020] [5.1] The Node is not
ready yet, Node state STARTING,looking forward to the next scheduling
2026-09-14 10:54:07,638 INFO [o.a.s.e.s.CoordinatorService ] [main] -
[localhost]:5801 [seatunnel-68020] [5.1] Start pending job schedule thread
2026-09-14 10:54:07,642 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-14 10:54:08,125 WARN [o.a.h.u.NativeCodeLoader ] [main] -
Unable to load native-hadoop library for your platform... using builtin-java
classes where applicable
2026-09-14 10:54:08,491 INFO [o.a.s.e.s.CoordinatorService ]
[pool-7-thread-1] - [localhost]:5801 [seatunnel-68020] [5.1]
***********************************************
CoordinatorService Thread Pool Status
***********************************************
activeCount : 1
corePoolSize : 10
maximumPoolSize : 2147483647
poolSize : 1
completedTaskCount : 0
taskCount : 1
***********************************************
2026-09-14 10:54:08,505 INFO [o.a.s.e.s.JettyService ] [main] -
SeaTunnel REST service will start on port 8090
2026-09-14 10:54:08,525 INFO [o.a.s.s.o.e.j.u.log ] [main] -
Logging initialized @6817ms to
org.apache.seatunnel.shade.org.eclipse.jetty.util.log.Slf4jLog
2026-09-14 10:54:08,637 WARN [a.s.s.o.e.j.s.h.ContextHandler] [main] -
Empty contextPath
2026-09-14 10:54:08,739 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-14 10:54:08,792 INFO [o.a.s.s.o.e.j.s.session ] [main] -
DefaultSessionIdManager workerName=node0
2026-09-14 10:54:08,792 INFO [o.a.s.s.o.e.j.s.session ] [main] - No
SessionScavenger set, using defaults
2026-09-14 10:54:08,796 INFO [o.a.s.s.o.e.j.s.session ] [main] -
node0 Scavenging every 660000ms
2026-09-14 10:54:09,080 INFO [a.s.s.o.e.j.s.h.ContextHandler] [main] -
Started o.a.s.s.o.e.j.s.ServletContextHandler@38054d01{/,null,AVAILABLE}
2026-09-14 10:54:09,100 INFO [.s.s.o.e.j.s.AbstractConnector] [main] -
Started ServerConnector@3b770d07{HTTP/1.1, (http/1.1)}{0.0.0.0:8090}
2026-09-14 10:54:09,101 INFO [o.a.s.s.o.e.j.s.Server ] [main] -
Started @7395ms
2026-09-14 10:54:09,204 INFO [c.h.i.d.Diagnostics ] [main] -
[localhost]:5801 [seatunnel-68020] [5.1] Diagnostics disabled. To enable add
-Dhazelcast.diagnostics.enabled=true to the JVM arguments.
2026-09-14 10:54:09,216 INFO [c.h.c.LifecycleService ] [main] -
[localhost]:5801 [seatunnel-68020] [5.1] [localhost]:5801 is STARTING
2026-09-14 10:54:09,312 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-2] - [localhost]:5801 [seatunnel-68020] [5.1]
[localhost]:5823 is added to the blacklist.
2026-09-14 10:54:09,312 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-5] - [localhost]:5801 [seatunnel-68020] [5.1]
[localhost]:5815 is added to the blacklist.
2026-09-14 10:54:09,312 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-7] - [localhost]:5801 [seatunnel-68020] [5.1]
[localhost]:5813 is added to the blacklist.
2026-09-14 10:54:09,312 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-8] - [localhost]:5801 [seatunnel-68020] [5.1]
[localhost]:5817 is added to the blacklist.
2026-09-14 10:54:09,314 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-8] - [localhost]:5801 [seatunnel-68020] [5.1]
[localhost]:5814 is added to the blacklist.
2026-09-14 10:54:09,312 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-3] - [localhost]:5801 [seatunnel-68020] [5.1]
[localhost]:5821 is added to the blacklist.
2026-09-14 10:54:09,312 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-1] - [localhost]:5801 [seatunnel-68020] [5.1]
[localhost]:5827 is added to the blacklist.
2026-09-14 10:54:09,312 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-10] - [localhost]:5801 [seatunnel-68020] [5.1]
[localhost]:5804 is added to the blacklist.
2026-09-14 10:54:09,314 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-2] - [localhost]:5801 [seatunnel-68020] [5.1]
[localhost]:5826 is added to the blacklist.
2026-09-14 10:54:09,314 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-5] - [localhost]:5801 [seatunnel-68020] [5.1]
[localhost]:5824 is added to the blacklist.
2026-09-14 10:54:09,312 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-14] - [localhost]:5801 [seatunnel-68020] [5.1]
[localhost]:5802 is added to the blacklist.
2026-09-14 10:54:09,316 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-13] - [localhost]:5801 [seatunnel-68020] [5.1]
[localhost]:5829 is added to the blacklist.
2026-09-14 10:54:09,317 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-10] - [localhost]:5801 [seatunnel-68020] [5.1]
[localhost]:5805 is added to the blacklist.
2026-09-14 10:54:09,317 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-8] - [localhost]:5801 [seatunnel-68020] [5.1]
[localhost]:5818 is added to the blacklist.
2026-09-14 10:54:09,317 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-2] - [localhost]:5801 [seatunnel-68020] [5.1]
[localhost]:5811 is added to the blacklist.
2026-09-14 10:54:09,318 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-10] - [localhost]:5801 [seatunnel-68020] [5.1]
[localhost]:5828 is added to the blacklist.
2026-09-14 10:54:09,316 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-16] - [localhost]:5801 [seatunnel-68020] [5.1]
[localhost]:5820 is added to the blacklist.
2026-09-14 10:54:09,316 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-7] - [localhost]:5801 [seatunnel-68020] [5.1]
[localhost]:5812 is added to the blacklist.
2026-09-14 10:54:09,318 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-8] - [localhost]:5801 [seatunnel-68020] [5.1]
[localhost]:5803 is added to the blacklist.
2026-09-14 10:54:09,312 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-12] - [localhost]:5801 [seatunnel-68020] [5.1]
[localhost]:5810 is added to the blacklist.
2026-09-14 10:54:09,313 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-6] - [localhost]:5801 [seatunnel-68020] [5.1]
[localhost]:5819 is added to the blacklist.
2026-09-14 10:54:09,316 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-3] - [localhost]:5801 [seatunnel-68020] [5.1]
[localhost]:5816 is added to the blacklist.
2026-09-14 10:54:09,316 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-1] - [localhost]:5801 [seatunnel-68020] [5.1]
[localhost]:5807 is added to the blacklist.
2026-09-14 10:54:09,318 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-5] - [localhost]:5801 [seatunnel-68020] [5.1]
[localhost]:5809 is added to the blacklist.
2026-09-14 10:54:09,318 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-14] - [localhost]:5801 [seatunnel-68020] [5.1]
[localhost]:5830 is added to the blacklist.
2026-09-14 10:54:09,320 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-11] - [localhost]:5801 [seatunnel-68020] [5.1]
[localhost]:5808 is added to the blacklist.
2026-09-14 10:54:09,313 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-4] - [localhost]:5801 [seatunnel-68020] [5.1]
[localhost]:5825 is added to the blacklist.
2026-09-14 10:54:09,319 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-15] - [localhost]:5801 [seatunnel-68020] [5.1]
[localhost]:5822 is added to the blacklist.
2026-09-14 10:54:09,319 INFO [s.j.LiteNodeDropOutTcpIpJoiner]
[hz.main.cached.thread-9] - [localhost]:5801 [seatunnel-68020] [5.1]
[localhost]:5806 is added to the blacklist.
2026-09-14 10:54:10,311 INFO [c.h.i.c.ClusterService ] [main] -
[localhost]:5801 [seatunnel-68020] [5.1]
Members {size:1, ver:1} [
Member [localhost]:5801 - cda60d1e-81bf-4d7a-9ba0-579a3de777fc [master
node] [active master] this
]
2026-09-14 10:54:10,338 INFO [c.h.c.LifecycleService ] [main] -
[localhost]:5801 [seatunnel-68020] [5.1] [localhost]:5801 is STARTED
2026-09-14 10:54:10,338 INFO [o.a.s.e.s.CoordinatorService ]
[pool-5-thread-1] - [localhost]:5801 [seatunnel-68020] [5.1] This node become a
new active master node, begin init coordinator service
2026-09-14 10:54:10,377 INFO [o.a.s.e.s.CoordinatorService ]
[pool-5-thread-1] - [localhost]:5801 [seatunnel-68020] [5.1] Loaded event
handlers: [org.apache.seatunnel.api.event.LoggingEventHandler@320433ce]
2026-09-14 10:54:10,414 INFO [.h.i.p.i.PartitionStateManager]
[hz.main.cached.thread-7] - [localhost]:5801 [seatunnel-68020] [5.1]
Initializing cluster partition table arrangement...
2026-09-14 10:54:10,426 INFO [.c.i.s.ClientInvocationService] [main] -
hz.client_1 [seatunnel-68020] [5.1] Running with 2 response threads,
dynamic=true
2026-09-14 10:54:10,453 INFO [c.h.c.LifecycleService ] [main] -
hz.client_1 [seatunnel-68020] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is
STARTING
2026-09-14 10:54:10,455 INFO [c.h.c.LifecycleService ] [main] -
hz.client_1 [seatunnel-68020] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is
STARTED
2026-09-14 10:54:10,477 INFO [.c.i.c.ClientConnectionManager] [main] -
hz.client_1 [seatunnel-68020] [5.1] Trying to connect to cluster:
seatunnel-68020
2026-09-14 10:54:10,481 INFO [.c.i.c.ClientConnectionManager] [main] -
hz.client_1 [seatunnel-68020] [5.1] Trying to connect to [localhost]:5801
2026-09-14 10:54:10,520 INFO [.p.t.AuthenticationMessageTask]
[hz.main.priority-generic-operation.thread-0] - [localhost]:5801
[seatunnel-68020] [5.1] Received auth from Connection[id=1,
/127.0.0.1:5801->/127.0.0.1:60289, qualifier=null, endpoint=[127.0.0.1]:60289,
remoteUuid=169087a6-c64d-453a-aa27-86b518177e7b, alive=true,
connectionType=JVM, planeIndex=-1], successfully authenticated, clientUuid:
169087a6-c64d-453a-aa27-86b518177e7b, client name: hz.client_1, client version:
5.1
2026-09-14 10:54:10,528 INFO [c.h.c.LifecycleService ] [main] -
hz.client_1 [seatunnel-68020] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is
CLIENT_CONNECTED
2026-09-14 10:54:10,530 INFO [.c.i.c.ClientConnectionManager] [main] -
hz.client_1 [seatunnel-68020] [5.1] Authenticated with server
[localhost]:5801:cda60d1e-81bf-4d7a-9ba0-579a3de777fc, server version: 5.1,
local address: /127.0.0.1:60289
2026-09-14 10:54:10,534 INFO [c.h.i.d.Diagnostics ] [main] -
hz.client_1 [seatunnel-68020] [5.1] Diagnostics disabled. To enable add
-Dhazelcast.diagnostics.enabled=true to the JVM arguments.
2026-09-14 10:54:10,555 INFO [c.h.c.i.s.ClientClusterService]
[hz.client_1.event-7] - hz.client_1 [seatunnel-68020] [5.1]
Members [1] {
Member [localhost]:5801 - cda60d1e-81bf-4d7a-9ba0-579a3de777fc [master
node]
}
2026-09-14 10:54:10,616 INFO [.c.i.s.ClientStatisticsService] [main] -
Client statistics is enabled with period 5 seconds.
2026-09-14 10:54:10,700 INFO [o.a.s.c.s.u.ConfigBuilder ] [main] -
Loading config file from path: ./job/cdc_highgo_to_mysql.conf
2026-09-14 10:54:10,935 INFO [o.a.s.c.s.u.ConfigShadeUtils ] [main] - Load
config shade spi: [base64]
2026-09-14 10:54:11,009 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,highgo.testdb.test_b"
],
"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-14 10:54:11,030 INFO [p.MultipleTableJobConfigParser] [main] - add
common jar in plugins :[]
2026-09-14 10:54:11,070 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load
SeaTunnelSink Plugin from
/usr/local/seatunnel/apache-seatunnel-2.3.13/connectors
2026-09-14 10:54:11,079 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-14 10:54:11,081 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-14 10:54:11,098 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load
SeaTunnelSink Plugin from
/usr/local/seatunnel/apache-seatunnel-2.3.13/connectors
2026-09-14 10:54:11,116 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load
SeaTunnelSink Plugin from
/usr/local/seatunnel/apache-seatunnel-2.3.13/connectors
2026-09-14 10:54:11,118 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-14 10:54:11,119 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-14 10:54:11,128 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-14 10:54:11,130 INFO [p.MultipleTableJobConfigParser] [main] -
start generating all sources.
2026-09-14 10:54:11,340 INFO [.s.c.s.j.c.AbstractJdbcCatalog] [main] -
Catalog Postgres closing
2026-09-14 10:54:11,342 INFO [c.h.c.LifecycleService ] [main] -
hz.client_1 [seatunnel-68020] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is
SHUTTING_DOWN
2026-09-14 10:54:11,346 INFO [c.h.i.s.t.TcpServerConnection ]
[hz.main.IO.thread-in-1] - [localhost]:5801 [seatunnel-68020] [5.1]
Connection[id=1, /127.0.0.1:5801->/127.0.0.1:60289, qualifier=null,
endpoint=[127.0.0.1]:60289, remoteUuid=169087a6-c64d-453a-aa27-86b518177e7b,
alive=false, connectionType=JVM, planeIndex=-1] closed. Reason: Connection
closed by the other side
2026-09-14 10:54:11,349 INFO [.c.i.c.ClientConnectionManager] [main] -
hz.client_1 [seatunnel-68020] [5.1] Removed connection to endpoint:
[localhost]:5801:cda60d1e-81bf-4d7a-9ba0-579a3de777fc, connection:
ClientConnection{alive=false, connectionId=1,
channel=NioChannel{/127.0.0.1:60289->localhost/127.0.0.1:5801},
remoteAddress=[localhost]:5801, lastReadTime=2026-09-14 10:54:10.691,
lastWriteTime=2026-09-14 10:54:10.686, closedTime=2026-09-14 10:54:11.343,
connected server version=5.1}
2026-09-14 10:54:11,349 INFO [c.h.c.LifecycleService ] [main] -
hz.client_1 [seatunnel-68020] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is
CLIENT_DISCONNECTED
2026-09-14 10:54:11,354 INFO [c.h.c.i.ClientEndpointManager ]
[hz.main.event-5] - [localhost]:5801 [seatunnel-68020] [5.1] Destroying
ClientEndpoint{connection=Connection[id=1, /127.0.0.1:5801->/127.0.0.1:60289,
qualifier=null, endpoint=[127.0.0.1]:60289,
remoteUuid=169087a6-c64d-453a-aa27-86b518177e7b, alive=false,
connectionType=JVM, planeIndex=-1],
clientUuid=169087a6-c64d-453a-aa27-86b518177e7b, clientName=hz.client_1,
authenticated=true, clientVersion=5.1, creationTime=1789354450512, latest
clientAttributes=lastStatisticsCollectionTime=1789354450616,enterprise=false,clientType=JVM,clientVersion=5.1,clusterConnectionTimestamp=1789354450483,clientAddress=127.0.0.1,clientName=hz.client_1,credentials.principal=null,os.committedVirtualMemorySize=0,os.freePhysicalMemorySize=421453824,os.freeSwapSpaceSize=0,os.maxFileDescriptorCount=0,os.openFileDescriptorCount=0,os.processCpuTime=0,os.systemLoadAverage=2.47,os.totalPhysicalMemorySize=29206614016,os.totalSwapSpaceSize=0,runtime.ava
ilableProcessors=8,runtime.freeMemory=147937728,runtime.maxMemory=536870912,runtime.totalMemory=268435456,runtime.uptime=8958,runtime.usedMemory=120497728,
labels=[]}
2026-09-14 10:54:11,360 INFO [c.h.c.LifecycleService ] [main] -
hz.client_1 [seatunnel-68020] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is
SHUTDOWN
2026-09-14 10:54:11,361 INFO [s.c.s.s.c.ClientExecuteCommand] [main] -
Closed SeaTunnel client......
2026-09-14 10:54:11,361 INFO [c.h.c.LifecycleService ] [main] -
[localhost]:5801 [seatunnel-68020] [5.1] [localhost]:5801 is SHUTTING_DOWN
2026-09-14 10:54:11,376 INFO [c.h.i.p.i.MigrationManager ]
[hz.main.cached.thread-11] - [localhost]:5801 [seatunnel-68020] [5.1] Shutdown
request of Member [localhost]:5801 - cda60d1e-81bf-4d7a-9ba0-579a3de777fc
[master node] [active master] this is handled
2026-09-14 10:54:11,388 INFO [c.h.i.i.Node ] [main] -
[localhost]:5801 [seatunnel-68020] [5.1] Shutting down connection manager...
2026-09-14 10:54:11,392 INFO [c.h.i.i.Node ] [main] -
[localhost]:5801 [seatunnel-68020] [5.1] Shutting down node engine...
2026-09-14 10:54:11,425 INFO [.s.s.o.e.j.s.AbstractConnector] [main] -
Stopped ServerConnector@3b770d07{HTTP/1.1, (http/1.1)}{0.0.0.0:8090}
2026-09-14 10:54:11,425 INFO [o.a.s.s.o.e.j.s.session ] [main] -
node0 Stopped scavenging
2026-09-14 10:54:11,428 INFO [a.s.s.o.e.j.s.h.ContextHandler] [main] -
Stopped o.a.s.s.o.e.j.s.ServletContextHandler@38054d01{/,null,STOPPED}
2026-09-14 10:54:11,434 INFO [.c.c.DefaultClassLoaderService] [main] -
close classloader service
2026-09-14 10:54:11,445 INFO [o.a.s.e.s.EventService ]
[event-forwarder-0] - Event forward thread interrupted
2026-09-14 10:54:14,525 INFO [c.h.i.i.NodeExtension ] [main] -
[localhost]:5801 [seatunnel-68020] [5.1] Destroying node NodeExtension.
2026-09-14 10:54:14,526 INFO [c.h.i.i.Node ] [main] -
[localhost]:5801 [seatunnel-68020] [5.1] Hazelcast Shutdown is completed in
3152 ms.
2026-09-14 10:54:14,527 INFO [c.h.c.LifecycleService ] [main] -
[localhost]:5801 [seatunnel-68020] [5.1] [localhost]:5801 is SHUTDOWN
2026-09-14 10:54:14,528 INFO [s.c.s.s.c.ClientExecuteCommand] [main] -
Closed HazelcastInstance ......
2026-09-14 10:54:14,528 ERROR [o.a.s.c.s.SeaTunnel ] [main] -
===============================================================================
2026-09-14 10:54:14,528 ERROR [o.a.s.c.s.SeaTunnel ] [main] -
Fatal Error,
2026-09-14 10:54:14,528 ERROR [o.a.s.c.s.SeaTunnel ] [main] -
Please submit bug report in https://github.com/apache/seatunnel/issues
2026-09-14 10:54:14,529 ERROR [o.a.s.c.s.SeaTunnel ] [main] -
Reason:SeaTunnel job executed failed
2026-09-14 10:54:14,534 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.api.table.catalog.exception.CatalogException:
ErrorCode:[API-03], ErrorDescription:[Catalog initialize failed] - Failed
connecting to jdbc:postgresql://172.16.100.202:5866/highgo?loggerLevel=OFF via
JDBC.
at
org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.getConnection(AbstractJdbcCatalog.java:155)
at
org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.open(AbstractJdbcCatalog.java:172)
at
org.apache.seatunnel.api.table.catalog.CatalogTableUtil.lambda$getCatalogTables$0(CatalogTableUtil.java:121)
at java.base/java.util.Optional.map(Optional.java:260)
at
org.apache.seatunnel.api.table.catalog.CatalogTableUtil.getCatalogTables(CatalogTableUtil.java:117)
at
org.apache.seatunnel.api.table.catalog.CatalogTableUtil.getCatalogTables(CatalogTableUtil.java:97)
at
org.apache.seatunnel.connectors.seatunnel.cdc.postgres.source.PostgresIncrementalSourceFactory.lambda$createSource$1(PostgresIncrementalSourceFactory.java:99)
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: org.postgresql.util.PSQLException: 不支援 13 验证类型。请核对您已经组态
pg_hba.conf 文件包含客户端的IP位址或网路区段，以及驱动程序所支援的验证架构模式已被支援。
at
org.postgresql.core.v3.ConnectionFactoryImpl.doAuthentication(ConnectionFactoryImpl.java:1052)
at
org.postgresql.core.v3.ConnectionFactoryImpl.tryConnect(ConnectionFactoryImpl.java:309)
at
org.postgresql.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:367)
at
org.postgresql.core.ConnectionFactory.openConnection(ConnectionFactory.java:52)
at org.postgresql.jdbc.PgConnection.<init>(PgConnection.java:295)
at org.postgresql.Driver.makeConnection(Driver.java:437)
at org.postgresql.Driver.connect(Driver.java:305)
at java.sql/java.sql.DriverManager.getConnection(DriverManager.java:681)
at java.sql/java.sql.DriverManager.getConnection(DriverManager.java:190)
at
org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.getConnection(AbstractJdbcCatalog.java:151)
... 16 more
2026-09-14 10:54:14,541 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.api.table.catalog.exception.CatalogException:
ErrorCode:[API-03], ErrorDescription:[Catalog initialize failed] - Failed
connecting to jdbc:postgresql://172.16.100.202:5866/highgo?loggerLevel=OFF via
JDBC.
at
org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.getConnection(AbstractJdbcCatalog.java:155)
at
org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.open(AbstractJdbcCatalog.java:172)
at
org.apache.seatunnel.api.table.catalog.CatalogTableUtil.lambda$getCatalogTables$0(CatalogTableUtil.java:121)
at java.base/java.util.Optional.map(Optional.java:260)
at
org.apache.seatunnel.api.table.catalog.CatalogTableUtil.getCatalogTables(CatalogTableUtil.java:117)
at
org.apache.seatunnel.api.table.catalog.CatalogTableUtil.getCatalogTables(CatalogTableUtil.java:97)
at
org.apache.seatunnel.connectors.seatunnel.cdc.postgres.source.PostgresIncrementalSourceFactory.lambda$createSource$1(PostgresIncrementalSourceFactory.java:99)
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: org.postgresql.util.PSQLException: 不支援 13 验证类型。请核对您已经组态
pg_hba.conf 文件包含客户端的IP位址或网路区段，以及驱动程序所支援的验证架构模式已被支援。
at
org.postgresql.core.v3.ConnectionFactoryImpl.doAuthentication(ConnectionFactoryImpl.java:1052)
at
org.postgresql.core.v3.ConnectionFactoryImpl.tryConnect(ConnectionFactoryImpl.java:309)
at
org.postgresql.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:367)
at
org.postgresql.core.ConnectionFactory.openConnection(ConnectionFactory.java:52)
at org.postgresql.jdbc.PgConnection.<init>(PgConnection.java:295)
at org.postgresql.Driver.makeConnection(Driver.java:437)
at org.postgresql.Driver.connect(Driver.java:305)
at java.sql/java.sql.DriverManager.getConnection(DriverManager.java:681)
at java.sql/java.sql.DriverManager.getConnection(DriverManager.java:190)
at
org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.getConnection(AbstractJdbcCatalog.java:151)
... 16 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]
