fenger0888-a11y opened a new issue, #9729: URL: https://github.com/apache/seatunnel/issues/9729
### Search before asking - [x] I had searched in the [issues](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues. ### What happened 我使用 dolpinscheduler 3.1.9 采用cdc同步 Postgresql 到 MySQL seatunnel 版本为 2.3.11 和 2.3.9 两个版本都尝试。使用dolpinscheduler报错，但是直接运行dolpinscheduler 生成的 脚本，正常。 ### SeaTunnel Version 2.3.9 and 2.3.11 ### SeaTunnel Config ```conf env { execution.parallelism = 1 job.mode = "STREAMING" checkpoint.interval = 5000 read_limit.bytes_per_second=7000000 read_limit.rows_per_second=400 } sink { Jdbc { driver="com.mysql.cj.jdbc.Driver" password="xxxx" url="jdbc:mysql://xxxxx:33306/srt_cloud?serverTimezone=UTC&useUnicode=true&characterEncoding=utf8&useSSL=false" user=root generate_sink_sql = true database = test table = columns primary_keys = ["id"] field_ide = UPPERCASE schema_save_mode = "CREATE_SCHEMA_WHEN_NOT_EXIST" data_save_mode="APPEND_DATA" } } source { Postgres-CDC { driver="org.postgresql.Driver" password="xxxx" schema-names = ["middle_service_etl"] table-names=["srt_cloud.middle_service_etl.columns"] base-url="jdbc:postgresql://xxxxxxx.aliyuncs.com:5432/srt_cloud?loggerLevel=OFF" username="postgres" database-names = ["srt_cloud"] } } ``` ### Running Command ```shell 3.1.9 dolphin ``` ### Error Exception ```log LOG-PATH]: /data/soft/apache-dolphinscheduler-3.1.9-bin/standalone-server/logs/20250820/18642401605249_24-2397-2436.log, [HOST]: Host{address='172.17.246.197:1234', ip='172.17.246.197', port=1234} [INFO] 2025-08-20 01:26:14.124 +0000 - Begin to pulling task [INFO] 2025-08-20 01:26:14.126 +0000 - Begin to initialize task [INFO] 2025-08-20 01:26:14.127 +0000 - Set task startTime: Wed Aug 20 01:26:14 UTC 2025 [INFO] 2025-08-20 01:26:14.127 +0000 - Set task envFile: /data/soft/apache-dolphinscheduler-3.1.9-bin/standalone-server/conf/dolphinscheduler_env.sh [INFO] 2025-08-20 01:26:14.127 +0000 - Set task appId: 2397_2436 [INFO] 2025-08-20 01:26:14.127 +0000 - End initialize task [INFO] 2025-08-20 01:26:14.129 +0000 - Set task status to TaskExecutionStatus{code=1, desc='running'} [INFO] 2025-08-20 01:26:14.129 +0000 - TenantCode:admin check success [INFO] 2025-08-20 01:26:14.130 +0000 - ProcessExecDir:/data/dolphinscheduler/exec/process/admin/18585750364160/18642401605249_24/2397/2436 check success [INFO] 2025-08-20 01:26:14.130 +0000 - Resources:{} check success [INFO] 2025-08-20 01:26:14.130 +0000 - Task plugin: SEATUNNEL create success [INFO] 2025-08-20 01:26:14.130 +0000 - SeaTunnel task params {"localParams":[],"rawScript":"env {\n execution.parallelism = 1\n job.mode = \"STREAMING\"\n checkpoint.interval = 5000\n read_limit.bytes_per_second=7000000\n read_limit.rows_per_second=400\n}\nsink {\n Jdbc {\n driver=\"com.mysql.cj.jdbc.Driver\"\n password=\"Hny@20230926\"\n url=\"jdbc:mysql://xxxx:33306/srt_cloud?serverTimezone=UTC&useUnicode=true&characterEncoding=utf8&useSSL=false\"\n user=root\n generate_sink_sql = true\n database = test\n table = columns\n primary_keys = [\"id\"]\n field_ide = UPPERCASE\n schema_save_mode = \"CREATE_SCHEMA_WHEN_NOT_EXIST\"\n data_save_mode=\"APPEND_DATA\"\n }\n}\nsource {\n Postgres-CDC {\n driver=\"org.postgresql.Driver\"\n password=\"1qazXSW@\"\n schema-names = [\"middle_service_etl\"]\n table-names=[\"columns\"]\n base-url=\"jdbc:postgresql://pgm-uf6vp 437rk55012xko.pg.rds.aliyuncs.com:5432/srt_cloud?loggerLevel=OFF\"\n username=\"postgres\"\n database-names = [\"srt_cloud\"]\n }\n}\ntransform {}","resourceList":[],"startupScript":"seatunnel.sh","useCustom":true,"deployMode":"local","others":""} [INFO] 2025-08-20 01:26:14.130 +0000 - Success initialized task plugin instance success [INFO] 2025-08-20 01:26:14.131 +0000 - Success set taskVarPool: null [INFO] 2025-08-20 01:26:14.131 +0000 - raw custom config content : env { execution.parallelism = 1 job.mode = "STREAMING" checkpoint.interval = 5000 read_limit.bytes_per_second=7000000 read_limit.rows_per_second=400 } sink { Jdbc { driver="com.mysql.cj.jdbc.Driver" password="Hny@20230926" url="jdbc:mysql://39.106.46.125:33306/srt_cloud?serverTimezone=UTC&useUnicode=true&characterEncoding=utf8&useSSL=false" user=root generate_sink_sql = true database = test table = columns primary_keys = ["id"] field_ide = UPPERCASE schema_save_mode = "CREATE_SCHEMA_WHEN_NOT_EXIST" data_save_mode="APPEND_DATA" } } source { Postgres-CDC { driver="org.postgresql.Driver" password="1qazXSW@" schema-names = ["middle_service_etl"] table-names=["columns"] base-url="jdbc:postgresql://:5432/srt_cloud?loggerLevel=OFF" username="postgres" database-names = ["srt_cloud"] } } transform {} [INFO] 2025-08-20 01:26:14.131 +0000 - tenantCode :admin, task dir:/data/dolphinscheduler/exec/process/admin/18585750364160/18642401605249_24/2397/2436 [INFO] 2025-08-20 01:26:14.131 +0000 - generate script file:/data/dolphinscheduler/exec/process/admin/18585750364160/18642401605249_24/2397/2436/seatunnel_2397_2436.conf [INFO] 2025-08-20 01:26:14.132 +0000 - SeaTunnel task command: ${SEATUNNEL_HOME}/bin/seatunnel.sh --config /data/dolphinscheduler/exec/process/admin/18585750364160/18642401605249_24/2397/2436/seatunnel_2397_2436.conf --deploy-mode local [INFO] 2025-08-20 01:26:14.132 +0000 - Begin to create command file:/data/dolphinscheduler/exec/process/admin/18585750364160/18642401605249_24/2397/2436/2397_2436.command [INFO] 2025-08-20 01:26:14.132 +0000 - Success create command file, command: #!/bin/bash BASEDIR=$(cd `dirname $0`; pwd) cd $BASEDIR source /data/soft/apache-dolphinscheduler-3.1.9-bin/standalone-server/conf/dolphinscheduler_env.sh ${SEATUNNEL_HOME}/bin/seatunnel.sh --config /data/dolphinscheduler/exec/process/admin/18585750364160/18642401605249_24/2397/2436/seatunnel_2397_2436.conf --deploy-mode local [INFO] 2025-08-20 01:26:14.139 +0000 - task run command: sudo -u admin -i bash /data/dolphinscheduler/exec/process/admin/18585750364160/18642401605249_24/2397/2436/2397_2436.command [INFO] 2025-08-20 01:26:14.139 +0000 - process start, process id is: 9533 [INFO] 2025-08-20 01:26:15.140 +0000 - -> 2025-08-20 09:26:15,070 WARN [ommandArgs$MasterTypeValidator] [main] - ****************************************************************************************** -e and --deploy-mode deprecated in 2.3.1, please use -m and --master instead of it ****************************************************************************************** 2025-08-20 09:26:15,116 INFO [c.h.i.c.AbstractConfigLocator ] [main] - Loading configuration '/data/soft/apache-seatunnel-2.3.9/config/seatunnel.yaml' from System property 'seatunnel.config' 2025-08-20 09:26:15,116 INFO [c.h.i.c.AbstractConfigLocator ] [main] - Using configuration file at /data/soft/apache-seatunnel-2.3.9/config/seatunnel.yaml 2025-08-20 09:26:15,119 INFO [o.a.s.e.c.c.SeaTunnelConfig ] [main] - seatunnel.home is /data/dolphinscheduler/exec/process/admin/18585750364160/18642401605249_24/2397/2436 [INFO] 2025-08-20 01:26:16.146 +0000 - -> 2025-08-20 09:26:15,255 WARN [amlSeaTunnelDomConfigProcessor] [main] - Unrecognized element: log 2025-08-20 09:26:15,255 INFO [amlSeaTunnelDomConfigProcessor] [main] - Dynamic slot is enabled, the schedule strategy is set to REJECT 2025-08-20 09:26:15,256 INFO [c.h.i.c.AbstractConfigLocator ] [main] - Loading configuration '/data/soft/apache-seatunnel-2.3.9/config/hazelcast.yaml' from System property 'hazelcast.config' 2025-08-20 09:26:15,256 INFO [c.h.i.c.AbstractConfigLocator ] [main] - Using configuration file at /data/soft/apache-seatunnel-2.3.9/config/hazelcast.yaml 2025-08-20 09:26:15,902 INFO [c.h.i.c.AbstractConfigLocator ] [main] - Loading configuration '/data/soft/apache-seatunnel-2.3.9/config/hazelcast-client.yaml' from System property 'hazelcast.client.config' 2025-08-20 09:26:15,902 INFO [c.h.i.c.AbstractConfigLocator ] [main] - Using configuration file at /data/soft/apache-seatunnel-2.3.9/config/hazelcast-client.yaml 2025-08-20 09:26:15,985 WARN [c.h.i.AddressPicker ] [main] - [LOCAL] [seatunnel-726401] [5.1] You configured your member address as host name. Please be aware of that your dns can be spoofed. Make sure that your dns configurations are correct. 2025-08-20 09:26:15,985 INFO [c.h.i.AddressPicker ] [main] - [LOCAL] [seatunnel-726401] [5.1] Resolving domain name 'localhost' to address(es): [127.0.0.1, 0:0:0:0:0:0:0:1] 2025-08-20 09:26:15,986 INFO [c.h.i.AddressPicker ] [main] - [LOCAL] [seatunnel-726401] [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] 2025-08-20 09:26:16,016 INFO [o.a.s.e.s.SeaTunnelServer ] [main] - SeaTunnel server start... 2025-08-20 09:26:16,020 INFO [c.h.system ] [main] - [localhost]:15801 [seatunnel-726401] [5.1] Based on Hazelcast IMDG version: 5.1.0 (20220228 - 21f20e7) 2025-08-20 09:26:16,021 INFO [c.h.system ] [main] - [localhost]:15801 [seatunnel-726401] [5.1] Cluster name: seatunnel-726401 2025-08-20 09:26:16,021 INFO [c.h.system ] [main] - [localhost]:15801 [seatunnel-726401] [5.1] _____ _____ _ / ___| |_ _| | | \ `--. ___ __ _ | | _ _ _ __ _ __ ___ | | `--. \ / _ \ / _` | | | | | | || '_ \ | '_ \ / _ \| | /\__/ /| __/| (_| | | | | |_| || | | || | | || __/| | \____/ \___| \__,_| \_/ \__,_||_| |_||_| |_| \___||_| 2025-08-20 09:26:16,021 INFO [c.h.system ] [main] - [localhost]:15801 [seatunnel-726401] [5.1] Copyright © 2021-2024 The Apache Software Foundation. Apache SeaTunnel, SeaTunnel, and its feather logo are trademarks of The Apache Software Foundation. 2025-08-20 09:26:16,021 INFO [c.h.system ] [main] - [localhost]:15801 [seatunnel-726401] [5.1] Integrity Checker is disabled. Fail-fast on corrupted executables will not be performed. To enable integrity checker do one of the following: - Change member config using Java API: config.setIntegrityCheckerEnabled(true); - Change XML/YAML configuration property: Set hazelcast.integrity-checker.enabled to true - Add system property: -Dhz.integritychecker.enabled=true (for Hazelcast embedded, works only when loading config via Config.load) - Add environment variable: HZ_INTEGRITYCHECKER_ENABLED=true (recommended when running container image. For Hazelcast embedded, works only when loading config via Config.load) 2025-08-20 09:26:16,024 INFO [c.h.system ] [main] - [localhost]:15801 [seatunnel-726401] [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) [INFO] 2025-08-20 01:26:17.148 +0000 - -> 2025-08-20 09:26:16,730 INFO [c.h.s.security ] [main] - [localhost]:15801 [seatunnel-726401] [5.1] Enable DEBUG/FINE log level for log category com.hazelcast.system.security or use -Dhazelcast.security.recommendations system property to see 🔒 security recommendations and the status of current config. 2025-08-20 09:26:16,816 INFO [o.a.s.e.s.SeaTunnelNodeContext] [main] - Using LiteNodeDropOutTcpIpJoiner TCP/IP discovery 2025-08-20 09:26:16,818 WARN [c.h.c.CPSubsystem ] [main] - [localhost]:15801 [seatunnel-726401] [5.1] CP Subsystem is not enabled. CP data structures will operate in UNSAFE mode! Please note that UNSAFE mode will not provide strong consistency guarantees. 2025-08-20 09:26:17,023 INFO [.c.c.DefaultClassLoaderService] [main] - start classloader service with cache mode 2025-08-20 09:26:17,031 INFO [c.h.i.c.AbstractConfigLocator ] [main] - Loading configuration '/data/soft/apache-seatunnel-2.3.9/config/seatunnel.yaml' from System property 'seatunnel.config' 2025-08-20 09:26:17,031 INFO [c.h.i.c.AbstractConfigLocator ] [main] - Using configuration file at /data/soft/apache-seatunnel-2.3.9/config/seatunnel.yaml 2025-08-20 09:26:17,036 WARN [amlSeaTunnelDomConfigProcessor] [main] - Unrecognized element: log 2025-08-20 09:26:17,037 INFO [amlSeaTunnelDomConfigProcessor] [main] - Dynamic slot is enabled, the schedule strategy is set to REJECT 2025-08-20 09:26:17,037 INFO [c.h.i.c.AbstractConfigLocator ] [main] - Loading configuration '/data/soft/apache-seatunnel-2.3.9/config/hazelcast.yaml' from System property 'hazelcast.config' 2025-08-20 09:26:17,037 INFO [c.h.i.c.AbstractConfigLocator ] [main] - Using configuration file at /data/soft/apache-seatunnel-2.3.9/config/hazelcast.yaml 2025-08-20 09:26:17,059 WARN [o.a.s.e.s.TaskExecutionService] [pool-3-thread-1] - [localhost]:15801 [seatunnel-726401] [5.1] The Node is not ready yet, Node state STARTING,looking forward to the next scheduling 2025-08-20 09:26:17,059 INFO [o.a.s.e.s.TaskExecutionService] [main] - [localhost]:15801 [seatunnel-726401] [5.1] Created new BusWork : 794940817 2025-08-20 09:26:17,072 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]:15801 2025-08-20 09:26:17,075 INFO [o.a.s.e.s.CoordinatorService ] [main] - [localhost]:15801 [seatunnel-726401] [5.1] Start pending job schedule thread [INFO] 2025-08-20 01:26:18.148 +0000 - -> 2025-08-20 09:26:17,360 WARN [o.a.h.u.NativeCodeLoader ] [main] - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable 2025-08-20 09:26:17,642 INFO [o.a.s.e.s.CoordinatorService ] [pool-7-thread-1] - [localhost]:15801 [seatunnel-726401] [5.1] *********************************************** CoordinatorService Thread Pool Status *********************************************** activeCount : 1 corePoolSize : 10 maximumPoolSize : 2147483647 poolSize : 1 completedTaskCount : 0 taskCount : 1 *********************************************** 2025-08-20 09:26:17,649 INFO [o.a.s.e.s.JettyService ] [main] - SeaTunnel REST service will start on port 18080 2025-08-20 09:26:17,663 INFO [o.a.s.s.o.e.j.u.log ] [main] - Logging initialized @3427ms to org.apache.seatunnel.shade.org.eclipse.jetty.util.log.Slf4jLog 2025-08-20 09:26:17,759 WARN [a.s.s.o.e.j.s.h.ContextHandler] [main] - Empty contextPath 2025-08-20 09:26:17,780 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 1.8.0_333-b02 2025-08-20 09:26:17,819 INFO [o.a.s.s.o.e.j.s.session ] [main] - DefaultSessionIdManager workerName=node0 2025-08-20 09:26:17,819 INFO [o.a.s.s.o.e.j.s.session ] [main] - No SessionScavenger set, using defaults 2025-08-20 09:26:17,821 INFO [o.a.s.s.o.e.j.s.session ] [main] - node0 Scavenging every 660000ms 2025-08-20 09:26:17,990 INFO [a.s.s.o.e.j.s.h.ContextHandler] [main] - Started o.a.s.s.o.e.j.s.ServletContextHandler@20ab76ee{/,null,AVAILABLE} 2025-08-20 09:26:18,001 INFO [.s.s.o.e.j.s.AbstractConnector] [main] - Started ServerConnector@36aa52d2{HTTP/1.1, (http/1.1)}{0.0.0.0:18080} 2025-08-20 09:26:18,001 INFO [o.a.s.s.o.e.j.s.Server ] [main] - Started @3766ms 2025-08-20 09:26:18,045 INFO [c.h.i.d.Diagnostics ] [main] - [localhost]:15801 [seatunnel-726401] [5.1] Diagnostics disabled. To enable add -Dhazelcast.diagnostics.enabled=true to the JVM arguments. 2025-08-20 09:26:18,053 INFO [c.h.c.LifecycleService ] [main] - [localhost]:15801 [seatunnel-726401] [5.1] [localhost]:15801 is STARTING 2025-08-20 09:26:18,106 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-6] - [localhost]:15801 [seatunnel-726401] [5.1] [localhost]:15805 is added to the blacklist. 2025-08-20 09:26:18,106 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-4] - [localhost]:15801 [seatunnel-726401] [5.1] [localhost]:15809 is added to the blacklist. 2025-08-20 09:26:18,106 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-3] - [localhost]:15801 [seatunnel-726401] [5.1] [localhost]:15828 is added to the blacklist. 2025-08-20 09:26:18,107 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-6] - [localhost]:15801 [seatunnel-726401] [5.1] [localhost]:15817 is added to the blacklist. 2025-08-20 09:26:18,107 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-5] - [localhost]:15801 [seatunnel-726401] [5.1] [localhost]:15811 is added to the blacklist. 2025-08-20 09:26:18,106 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-7] - [localhost]:15801 [seatunnel-726401] [5.1] [localhost]:15807 is added to the blacklist. 2025-08-20 09:26:18,107 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-1] - [localhost]:15801 [seatunnel-726401] [5.1] [localhost]:15830 is added to the blacklist. 2025-08-20 09:26:18,108 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-3] - [localhost]:15801 [seatunnel-726401] [5.1] [localhost]:15813 is added to the blacklist. 2025-08-20 09:26:18,108 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-8] - [localhost]:15801 [seatunnel-726401] [5.1] [localhost]:15819 is added to the blacklist. 2025-08-20 09:26:18,110 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-2] - [localhost]:15801 [seatunnel-726401] [5.1] [localhost]:15803 is added to the blacklist. 2025-08-20 09:26:18,110 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-10] - [localhost]:15801 [seatunnel-726401] [5.1] [localhost]:15827 is added to the blacklist. 2025-08-20 09:26:18,110 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-3] - [localhost]:15801 [seatunnel-726401] [5.1] [localhost]:15821 is added to the blacklist. 2025-08-20 09:26:18,110 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-2] - [localhost]:15801 [seatunnel-726401] [5.1] [localhost]:15823 is added to the blacklist. 2025-08-20 09:26:18,110 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-6] - [localhost]:15801 [seatunnel-726401] [5.1] [localhost]:15815 is added to the blacklist. 2025-08-20 09:26:18,110 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-1] - [localhost]:15801 [seatunnel-726401] [5.1] [localhost]:15802 is added to the blacklist. 2025-08-20 09:26:18,111 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-10] - [localhost]:15801 [seatunnel-726401] [5.1] [localhost]:15829 is added to the blacklist. 2025-08-20 09:26:18,111 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-3] - [localhost]:15801 [seatunnel-726401] [5.1] [localhost]:15808 is added to the blacklist. 2025-08-20 09:26:18,110 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-8] - [localhost]:15801 [seatunnel-726401] [5.1] [localhost]:15825 is added to the blacklist. 2025-08-20 09:26:18,111 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-11] - [localhost]:15801 [seatunnel-726401] [5.1] [localhost]:15810 is added to the blacklist. 2025-08-20 09:26:18,112 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-7] - [localhost]:15801 [seatunnel-726401] [5.1] [localhost]:15804 is added to the blacklist. 2025-08-20 09:26:18,118 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-4] - [localhost]:15801 [seatunnel-726401] [5.1] [localhost]:15822 is added to the blacklist. 2025-08-20 09:26:18,118 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-7] - [localhost]:15801 [seatunnel-726401] [5.1] [localhost]:15806 is added to the blacklist. 2025-08-20 09:26:18,119 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-3] - [localhost]:15801 [seatunnel-726401] [5.1] [localhost]:15826 is added to the blacklist. 2025-08-20 09:26:18,119 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-5] - [localhost]:15801 [seatunnel-726401] [5.1] [localhost]:15824 is added to the blacklist. 2025-08-20 09:26:18,119 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-10] - [localhost]:15801 [seatunnel-726401] [5.1] [localhost]:15812 is added to the blacklist. 2025-08-20 09:26:18,120 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-1] - [localhost]:15801 [seatunnel-726401] [5.1] [localhost]:15814 is added to the blacklist. 2025-08-20 09:26:18,121 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-13] - [localhost]:15801 [seatunnel-726401] [5.1] [localhost]:15816 is added to the blacklist. 2025-08-20 09:26:18,121 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-8] - [localhost]:15801 [seatunnel-726401] [5.1] [localhost]:15818 is added to the blacklist. 2025-08-20 09:26:18,121 INFO [s.j.LiteNodeDropOutTcpIpJoiner] [hz.main.cached.thread-11] - [localhost]:15801 [seatunnel-726401] [5.1] [localhost]:15820 is added to the blacklist. [INFO] 2025-08-20 01:26:19.150 +0000 - -> 2025-08-20 09:26:19,124 INFO [c.h.i.c.ClusterService ] [main] - [localhost]:15801 [seatunnel-726401] [5.1] Members {size:1, ver:1} [ Member [localhost]:15801 - 9292e231-ac31-41a3-a702-463f09485245 [master node] [active master] this ] 2025-08-20 09:26:19,148 INFO [c.h.c.LifecycleService ] [main] - [localhost]:15801 [seatunnel-726401] [5.1] [localhost]:15801 is STARTED [INFO] 2025-08-20 01:26:20.150 +0000 - -> 2025-08-20 09:26:19,159 INFO [c.h.i.d.HealthMonitor ] [hz.main.HealthMonitor] - [localhost]:15801 [seatunnel-726401] [5.1] processors=8, physical.memory.total=30.3G, physical.memory.free=1.1G, swap.space.total=0, swap.space.free=0, heap.memory.used=83.8M, heap.memory.free=236.2M, heap.memory.total=320.0M, heap.memory.max=455.5M, heap.memory.used/total=26.20%, heap.memory.used/max=18.40%, minor.gc.count=3, minor.gc.time=59ms, major.gc.count=2, major.gc.time=102ms, load.process=42.86%, load.system=85.71%, load.systemAverage=4.21, thread.count=126, thread.peakCount=126, 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=0, executor.q.mapLo ad.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=0, clientEndpoint.count=0, connection.active.count=0, client.connection.count=0, connection.count=0 2025-08-20 09:26:19,175 INFO [o.a.s.e.s.CoordinatorService ] [pool-5-thread-1] - [localhost]:15801 [seatunnel-726401] [5.1] This node become a new active master node, begin init coordinator service 2025-08-20 09:26:19,200 INFO [.c.i.s.ClientInvocationService] [main] - hz.client_1 [seatunnel-726401] [5.1] Running with 2 response threads, dynamic=true 2025-08-20 09:26:19,225 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel-726401] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is STARTING 2025-08-20 09:26:19,227 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel-726401] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is STARTED 2025-08-20 09:26:19,229 INFO [o.a.s.e.s.CoordinatorService ] [pool-5-thread-1] - [localhost]:15801 [seatunnel-726401] [5.1] Loaded event handlers: [org.apache.seatunnel.api.event.LoggingEventHandler@6165246b] 2025-08-20 09:26:19,237 INFO [.c.i.c.ClientConnectionManager] [main] - hz.client_1 [seatunnel-726401] [5.1] Trying to connect to cluster: seatunnel-726401 2025-08-20 09:26:19,240 INFO [.c.i.c.ClientConnectionManager] [main] - hz.client_1 [seatunnel-726401] [5.1] Trying to connect to [localhost]:15801 2025-08-20 09:26:19,261 INFO [.h.i.p.i.PartitionStateManager] [seatunnel-coordinator-service-1] - [localhost]:15801 [seatunnel-726401] [5.1] Initializing cluster partition table arrangement... 2025-08-20 09:26:19,266 INFO [.p.t.AuthenticationMessageTask] [hz.main.generic-operation.thread-0] - [localhost]:15801 [seatunnel-726401] [5.1] Received auth from Connection[id=1, /127.0.0.1:15801->/127.0.0.1:33224, qualifier=null, endpoint=[127.0.0.1]:33224, remoteUuid=9beaed16-82ef-471e-a4bd-c7ace2379886, alive=true, connectionType=JVM, planeIndex=-1], successfully authenticated, clientUuid: 9beaed16-82ef-471e-a4bd-c7ace2379886, client name: hz.client_1, client version: 5.1 2025-08-20 09:26:19,270 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel-726401] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is CLIENT_CONNECTED 2025-08-20 09:26:19,270 INFO [.c.i.c.ClientConnectionManager] [main] - hz.client_1 [seatunnel-726401] [5.1] Authenticated with server [localhost]:15801:9292e231-ac31-41a3-a702-463f09485245, server version: 5.1, local address: /127.0.0.1:33224 2025-08-20 09:26:19,272 INFO [c.h.i.d.Diagnostics ] [main] - hz.client_1 [seatunnel-726401] [5.1] Diagnostics disabled. To enable add -Dhazelcast.diagnostics.enabled=true to the JVM arguments. 2025-08-20 09:26:19,293 INFO [c.h.c.i.s.ClientClusterService] [hz.client_1.event-6] - hz.client_1 [seatunnel-726401] [5.1] Members [1] { Member [localhost]:15801 - 9292e231-ac31-41a3-a702-463f09485245 [master node] } 2025-08-20 09:26:19,333 INFO [.c.i.s.ClientStatisticsService] [main] - Client statistics is enabled with period 5 seconds. 2025-08-20 09:26:19,478 INFO [o.a.s.c.s.u.ConfigBuilder ] [main] - Loading config file from path: /data/dolphinscheduler/exec/process/admin/18585750364160/18642401605249_24/2397/2436/seatunnel_2397_2436.conf 2025-08-20 09:26:19,621 INFO [o.a.s.c.s.u.ConfigShadeUtils ] [main] - Load config shade spi: [base64] 2025-08-20 09:26:19,690 INFO [o.a.s.c.s.u.ConfigBuilder ] [main] - Parsed config file: { "env" : { "execution.parallelism" : 1, "job.mode" : "STREAMING", "checkpoint.interval" : 5000, "read_limit.bytes_per_second" : 7000000, "read_limit.rows_per_second" : 400 }, "sink" : [ { "driver" : "com.mysql.cj.jdbc.Driver", "password" : "******", "url" : "jdbc:mysql://39.106.46.125:33306/srt_cloud?serverTimezone=UTC&useUnicode=true&characterEncoding=utf8&useSSL=false", "user" : "root", "generate_sink_sql" : true, "database" : "test", "table" : "columns", "primary_keys" : [ "id" ], "field_ide" : "UPPERCASE", "schema_save_mode" : "CREATE_SCHEMA_WHEN_NOT_EXIST", "data_save_mode" : "APPEND_DATA", "plugin_name" : "Jdbc" } ], "source" : [ { "driver" : "org.postgresql.Driver", "password" : "******", "schema-names" : [ "middle_service_etl" ], "table-names" : [ "columns" ], "base-url" : "jdbc:postgresql://pgm-uf6vp437rk55012xko.pg.rds.aliyuncs.com:5432/srt_cloud?loggerLevel=OFF", "username" : "******", "database-names" : [ "srt_cloud" ], "plugin_name" : "Postgres-CDC" } ], "transform" : [] } 2025-08-20 09:26:19,701 INFO [p.MultipleTableJobConfigParser] [main] - add common jar in plugins :[] 2025-08-20 09:26:19,717 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load SeaTunnelSink Plugin from /data/soft/apache-seatunnel-2.3.9/connectors 2025-08-20 09:26:19,722 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Discovery plugin jar for: PluginIdentifier{engineType='seatunnel', pluginType='source', pluginName='Postgres-CDC'} at: file:/data/soft/apache-seatunnel-2.3.9/connectors/connector-cdc-postgres-2.3.9.jar 2025-08-20 09:26:19,732 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load SeaTunnelSink Plugin from /data/soft/apache-seatunnel-2.3.9/connectors 2025-08-20 09:26:19,739 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load SeaTunnelSink Plugin from /data/soft/apache-seatunnel-2.3.9/connectors 2025-08-20 09:26:19,742 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Discovery plugin jar for: PluginIdentifier{engineType='seatunnel', pluginType='sink', pluginName='Jdbc'} at: file:/data/soft/apache-seatunnel-2.3.9/connectors/connector-jdbc-2.3.9.jar 2025-08-20 09:26:19,747 INFO [p.MultipleTableJobConfigParser] [main] - start generating all sources. 2025-08-20 09:26:20,056 INFO [.s.c.s.j.c.AbstractJdbcCatalog] [main] - Catalog Postgres established connection to jdbc:postgresql://pgm-uf6vp437rk55012xko.pg.rds.aliyuncs.com:5432/srt_cloud?loggerLevel=OFF [INFO] 2025-08-20 01:26:21.151 +0000 - -> 2025-08-20 09:26:20,195 INFO [.s.c.s.j.c.AbstractJdbcCatalog] [main] - Catalog Postgres closing 2025-08-20 09:26:20,196 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel-726401] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is SHUTTING_DOWN 2025-08-20 09:26:20,200 INFO [c.h.i.s.t.TcpServerConnection ] [hz.main.IO.thread-in-1] - [localhost]:15801 [seatunnel-726401] [5.1] Connection[id=1, /127.0.0.1:15801->/127.0.0.1:33224, qualifier=null, endpoint=[127.0.0.1]:33224, remoteUuid=9beaed16-82ef-471e-a4bd-c7ace2379886, alive=false, connectionType=JVM, planeIndex=-1] closed. Reason: Connection closed by the other side 2025-08-20 09:26:20,202 INFO [.c.i.c.ClientConnectionManager] [main] - hz.client_1 [seatunnel-726401] [5.1] Removed connection to endpoint: [localhost]:15801:9292e231-ac31-41a3-a702-463f09485245, connection: ClientConnection{alive=false, connectionId=1, channel=NioChannel{/127.0.0.1:33224->localhost/127.0.0.1:15801}, remoteAddress=[localhost]:15801, lastReadTime=2025-08-20 09:26:19.471, lastWriteTime=2025-08-20 09:26:19.461, closedTime=2025-08-20 09:26:20.197, connected server version=5.1} 2025-08-20 09:26:20,202 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel-726401] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is CLIENT_DISCONNECTED 2025-08-20 09:26:20,208 INFO [c.h.c.i.ClientEndpointManager ] [hz.main.event-5] - [localhost]:15801 [seatunnel-726401] [5.1] Destroying ClientEndpoint{connection=Connection[id=1, /127.0.0.1:15801->/127.0.0.1:33224, qualifier=null, endpoint=[127.0.0.1]:33224, remoteUuid=9beaed16-82ef-471e-a4bd-c7ace2379886, alive=false, connectionType=JVM, planeIndex=-1], clientUuid=9beaed16-82ef-471e-a4bd-c7ace2379886, clientName=hz.client_1, authenticated=true, clientVersion=5.1, creationTime=1755653179260, latest clientAttributes=lastStatisticsCollectionTime=1755653179334,enterprise=false,clientType=JVM,clientVersion=5.1,clusterConnectionTimestamp=1755653179242,clientAddress=127.0.0.1,clientName=hz.client_1,credentials.principal=null,os.committedVirtualMemorySize=6528442368,os.freePhysicalMemorySize=1152167936,os.freeSwapSpaceSize=0,os.maxFileDescriptorCount=65535,os.openFileDescriptorCount=66,os.processCpuTime=11530000000,os.systemLoadAverage=4.21,os.totalPhysicalMemorySize=32491126784,os.tot alSwapSpaceSize=0,runtime.availableProcessors=8,runtime.freeMemory=215470912,runtime.maxMemory=477626368,runtime.totalMemory=335544320,runtime.uptime=5173,runtime.usedMemory=120073408, labels=[]} 2025-08-20 09:26:20,208 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel-726401] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is SHUTDOWN 2025-08-20 09:26:20,209 INFO [s.c.s.s.c.ClientExecuteCommand] [main] - Closed SeaTunnel client...... 2025-08-20 09:26:20,210 INFO [c.h.c.LifecycleService ] [main] - [localhost]:15801 [seatunnel-726401] [5.1] [localhost]:15801 is SHUTTING_DOWN 2025-08-20 09:26:20,213 INFO [c.h.i.p.i.MigrationManager ] [hz.main.cached.thread-9] - [localhost]:15801 [seatunnel-726401] [5.1] Shutdown request of Member [localhost]:15801 - 9292e231-ac31-41a3-a702-463f09485245 [master node] [active master] this is handled 2025-08-20 09:26:20,219 INFO [c.h.i.i.Node ] [main] - [localhost]:15801 [seatunnel-726401] [5.1] Shutting down connection manager... 2025-08-20 09:26:20,222 INFO [c.h.i.i.Node ] [main] - [localhost]:15801 [seatunnel-726401] [5.1] Shutting down node engine... 2025-08-20 09:26:20,238 INFO [.s.s.o.e.j.s.AbstractConnector] [main] - Stopped ServerConnector@36aa52d2{HTTP/1.1, (http/1.1)}{0.0.0.0:18080} 2025-08-20 09:26:20,238 INFO [o.a.s.s.o.e.j.s.session ] [main] - node0 Stopped scavenging 2025-08-20 09:26:20,239 INFO [a.s.s.o.e.j.s.h.ContextHandler] [main] - Stopped o.a.s.s.o.e.j.s.ServletContextHandler@20ab76ee{/,null,STOPPED} 2025-08-20 09:26:20,242 INFO [.c.c.DefaultClassLoaderService] [main] - close classloader service 2025-08-20 09:26:20,272 INFO [o.a.s.e.s.EventService ] [event-forwarder-0] - Event forward thread interrupted [INFO] 2025-08-20 01:26:24.064 +0000 - process has exited. execute path:/data/dolphinscheduler/exec/process/admin/18585750364160/18642401605249_24/2397/2436, processId:9533 ,exitStatusCode:1 ,processWaitForStatus:true ,processExitValue:1 [INFO] 2025-08-20 01:26:24.066 +0000 - Send task execute result to master, the current task status: TaskExecutionStatus{code=6, desc='failure'} [INFO] 2025-08-20 01:26:24.067 +0000 - Remove the current task execute context from worker cache [INFO] 2025-08-20 01:26:24.067 +0000 - The current execute mode is develop mode, will not clear the task execute file: /data/dolphinscheduler/exec/process/admin/18585750364160/18642401605249_24/2397/2436 [INFO] 2025-08-20 01:26:24.152 +0000 - -> 2025-08-20 09:26:23,284 INFO [c.h.i.i.NodeExtension ] [main] - [localhost]:15801 [seatunnel-726401] [5.1] Destroying node NodeExtension. 2025-08-20 09:26:23,285 INFO [c.h.i.i.Node ] [main] - [localhost]:15801 [seatunnel-726401] [5.1] Hazelcast Shutdown is completed in 3072 ms. 2025-08-20 09:26:23,286 INFO [c.h.c.LifecycleService ] [main] - [localhost]:15801 [seatunnel-726401] [5.1] [localhost]:15801 is SHUTDOWN 2025-08-20 09:26:23,286 INFO [s.c.s.s.c.ClientExecuteCommand] [main] - Closed HazelcastInstance ...... 2025-08-20 09:26:23,286 ERROR [o.a.s.c.s.SeaTunnel ] [main] - =============================================================================== 2025-08-20 09:26:23,286 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Fatal Error, 2025-08-20 09:26:23,286 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Please submit bug report in https://github.com/apache/seatunnel/issues 2025-08-20 09:26:23,286 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Reason:SeaTunnel job executed failed 2025-08-20 09:26:23,288 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:228) at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40) at org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:34) Caused by: org.apache.seatunnel.api.table.factory.FactoryException: ErrorCode:[API-06], ErrorDescription:[Factory initialize failed] - Unable to create a source for identifier 'Postgres-CDC'. at org.apache.seatunnel.api.table.factory.FactoryUtil.restoreAndPrepareSource(FactoryUtil.java:119) at org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:68) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSource(MultipleTableJobConfigParser.java:404) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:236) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.getLogicalDag(ClientJobExecutionEnvironment.java:123) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.execute(ClientJobExecutionEnvironment.java:191) at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:165) ... 2 more Caused by: org.apache.seatunnel.api.table.catalog.exception.CatalogException: ErrorCode:[API-03], ErrorDescription:[Catalog initialize failed] - Failed connecting to jdbc:postgresql://pgm-uf6vp437rk55012xko.pg.rds.aliyuncs.com:5432/null?loggerLevel=OFF via JDBC. at org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.getConnection(AbstractJdbcCatalog.java:124) at org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.querySQLResultExists(AbstractJdbcCatalog.java:616) at org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.tableExists(AbstractJdbcCatalog.java:381) at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:174) at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193) at java.util.ArrayList$ArrayListSpliterator.tryAdvance(ArrayList.java:1361) at java.util.stream.StreamSpliterators$WrappingSpliterator.lambda$initPartialTraversalState$0(StreamSpliterators.java:294) at java.util.stream.StreamSpliterators$AbstractWrappingSpliterator.fillBuffer(StreamSpliterators.java:206) at java.util.stream.StreamSpliterators$AbstractWrappingSpliterator.doAdvance(StreamSpliterators.java:161) at java.util.stream.StreamSpliterators$WrappingSpliterator.tryAdvance(StreamSpliterators.java:300) at java.util.Spliterators$1Adapter.hasNext(Spliterators.java:681) at org.apache.seatunnel.api.table.catalog.Catalog.buildCatalogTablesWithErrorCheck(Catalog.java:183) at org.apache.seatunnel.api.table.catalog.Catalog.getTables(Catalog.java:155) at org.apache.seatunnel.api.table.catalog.CatalogTableUtil.lambda$getCatalogTables$0(CatalogTableUtil.java:124) at java.util.Optional.map(Optional.java:215) at org.apache.seatunnel.api.table.catalog.CatalogTableUtil.getCatalogTables(CatalogTableUtil.java:118) at org.apache.seatunnel.api.table.catalog.CatalogTableUtil.getCatalogTables(CatalogTableUtil.java:98) at org.apache.seatunnel.connectors.seatunnel.cdc.postgres.source.PostgresIncrementalSourceFactory.lambda$createSource$1(PostgresIncrementalSourceFactory.java:89) at org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:131) at org.apache.seatunnel.api.table.factory.FactoryUtil.restoreAndPrepareSource(FactoryUtil.java:91) ... 8 more Caused by: org.postgresql.util.PSQLException: FATAL: database "null" does not exist at org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2713) at org.postgresql.core.v3.QueryExecutorImpl.readStartupMessages(QueryExecutorImpl.java:2825) at org.postgresql.core.v3.QueryExecutorImpl.<init>(QueryExecutorImpl.java:175) at org.postgresql.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:313) at org.postgresql.core.ConnectionFactory.openConnection(ConnectionFactory.java:54) at org.postgresql.jdbc.PgConnection.<init>(PgConnection.java:263) at org.postgresql.Driver.makeConnection(Driver.java:443) at org.postgresql.Driver.connect(Driver.java:297) at java.sql.DriverManager.getConnection(DriverManager.java:664) at java.sql.DriverManager.getConnection(DriverManager.java:247) at org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.getConnection(AbstractJdbcCatalog.java:120) ... 27 more 2025-08-20 09:26:23,288 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:228) at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40) at org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:34) Caused by: org.apache.seatunnel.api.table.factory.FactoryException: ErrorCode:[API-06], ErrorDescription:[Factory initialize failed] - Unable to create a source for identifier 'Postgres-CDC'. at org.apache.seatunnel.api.table.factory.FactoryUtil.restoreAndPrepareSource(FactoryUtil.java:119) at org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:68) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSource(MultipleTableJobConfigParser.java:404) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:236) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.getLogicalDag(ClientJobExecutionEnvironment.java:123) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.execute(ClientJobExecutionEnvironment.java:191) at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:165) ... 2 more Caused by: org.apache.seatunnel.api.table.catalog.exception.CatalogException: ErrorCode:[API-03], ErrorDescription:[Catalog initialize failed] - Failed connecting to jdbc:postgresql://pgm-uf6vp437rk55012xko.pg.rds.aliyuncs.com:5432/null?loggerLevel=OFF via JDBC. at org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.getConnection(AbstractJdbcCatalog.java:124) at org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.querySQLResultExists(AbstractJdbcCatalog.java:616) at org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.tableExists(AbstractJdbcCatalog.java:381) at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:174) at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193) at java.util.ArrayList$ArrayListSpliterator.tryAdvance(ArrayList.java:1361) at java.util.stream.StreamSpliterators$WrappingSpliterator.lambda$initPartialTraversalState$0(StreamSpliterators.java:294) at java.util.stream.StreamSpliterators$AbstractWrappingSpliterator.fillBuffer(StreamSpliterators.java:206) at java.util.stream.StreamSpliterators$AbstractWrappingSpliterator.doAdvance(StreamSpliterators.java:161) at java.util.stream.StreamSpliterators$WrappingSpliterator.tryAdvance(StreamSpliterators.java:300) at java.util.Spliterators$1Adapter.hasNext(Spliterators.java:681) at org.apache.seatunnel.api.table.catalog.Catalog.buildCatalogTablesWithErrorCheck(Catalog.java:183) at org.apache.seatunnel.api.table.catalog.Catalog.getTables(Catalog.java:155) at org.apache.seatunnel.api.table.catalog.CatalogTableUtil.lambda$getCatalogTables$0(CatalogTableUtil.java:124) at java.util.Optional.map(Optional.java:215) at org.apache.seatunnel.api.table.catalog.CatalogTableUtil.getCatalogTables(CatalogTableUtil.java:118) at org.apache.seatunnel.api.table.catalog.CatalogTableUtil.getCatalogTables(CatalogTableUtil.java:98) at org.apache.seatunnel.connectors.seatunnel.cdc.postgres.source.PostgresIncrementalSourceFactory.lambda$createSource$1(PostgresIncrementalSourceFactory.java:89) at org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:131) at org.apache.seatunnel.api.table.factory.FactoryUtil.restoreAndPrepareSource(FactoryUtil.java:91) ... 8 more Caused by: org.postgresql.util.PSQLException: FATAL: database "null" does not exist at org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2713) at org.postgresql.core.v3.QueryExecutorImpl.readStartupMessages(QueryExecutorImpl.java:2825) at org.postgresql.core.v3.QueryExecutorImpl.<init>(QueryExecutorImpl.java:175) at org.postgresql.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:313) at org.postgresql.core.ConnectionFactory.openConnection(ConnectionFactory.java:54) at org.postgresql.jdbc.PgConnection.<init>(PgConnection.java:263) at org.postgresql.Driver.makeConnection(Driver.java:443) at org.postgresql.Driver.connect(Driver.java:297) at java.sql.DriverManager.getConnection(DriverManager.java:664) at java.sql.DriverManager.getConnection(DriverManager.java:247) at org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.getConnection(AbstractJdbcCatalog.java:120) ... 27 more [INFO] 2025-08-20 01:26:24.153 +0000 - FINALIZE_SESSION ``` ### Zeta or Flink or Spark Version zeta 2.3.9 and 2.3.11 ### Java or Scala Version jdk 1.8 ### Screenshots <img width="683" height="664" alt="Image" src="https://github.com/user-attachments/assets/c702565e-b6fe-47ee-a7be-d4d236ca5e31"; /> ### Are you willing to submit PR? - [x] Yes I am willing to submit a PR! ### Code of Conduct - [x] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
