Got an error when performing CDC write operations using HighGo DB

SeaTunnel version: 2.3.13 connector-cdc-postgres: 2.3.13 HighGo version: 4.5.8 HighGo jdbc version: HgdbJdbc-6.2.5.jar error message： `2026-09-11 10:22:31,068 INFO [p.MultipleTableJobConfigParser] [main] - add common jar in plugins :[] 2026-09-11 10:22:31,103 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load SeaTunnelSink Plugin from /usr/local/seatunnel/apache-seatunnel-2.3.13/connectors 2026-09-11 10:22:31,113 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-11 10:22:31,114 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-11 10:22:31,130 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load SeaTunnelSink Plugin from /usr/local/seatunnel/apache-seatunnel-2.3.13/connectors 2026-09-11 10:22:31,145 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load SeaTunnelSink Plugin from /usr/local/seatunnel/apache-seatunnel-2.3.13/connectors 2026-09-11 10:22:31,147 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-11 10:22:31,148 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-11 10:22:31,157 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-11 10:22:31,159 INFO [p.MultipleTableJobConfigParser] [main] - start generating all sources. 2026-09-11 10:22:31,231 WARN [stgresIncrementalSourceFactory] [main] - Failed to load JDBC driver org.postgresql.Driver java.lang.ClassNotFoundException: org.postgresql.Driver at java.net.URLClassLoader.findClass(URLClassLoader.java:445) ~[?:?] at java.lang.ClassLoader.loadClass(ClassLoader.java:592) ~[?:?] at org.apache.seatunnel.engine.common.loader.SeaTunnelBaseClassLoader.loadClassWithoutExceptionHandling(SeaTunnelBaseClassLoader.java:56) ~[seatunnel-starter.jar:2.3.13] at org.apache.seatunnel.engine.common.loader.SeaTunnelChildFirstClassLoader.loadClassWithoutExceptionHandling(SeaTunnelChildFirstClassLoader.java:97) ~[seatunnel-starter.jar:2.3.13] at org.apache.seatunnel.engine.common.loader.SeaTunnelBaseClassLoader.loadClass(SeaTunnelBaseClassLoader.java:47) ~[seatunnel-starter.jar:2.3.13] at java.lang.ClassLoader.loadClass(ClassLoader.java:525) ~[?:?] at java.lang.Class.forName0(Native Method) ~[?:?] at java.lang.Class.forName(Class.java:375) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.cdc.postgres.source.PostgresIncrementalSourceFactory.lambda$createSource$1(PostgresIncrementalSourceFactory.java:94) ~[connector-cdc-postgres-2.3.13.jar:2.3.13] at org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:180) [seatunnel-starter.jar:2.3.13] at org.apache.seatunnel.api.table.factory.FactoryUtil.restoreAndPrepareSource(FactoryUtil.java:136) [seatunnel-starter.jar:2.3.13] at org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:86) [seatunnel-starter.jar:2.3.13] at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSource(MultipleTableJobConfigParser.java:397) [seatunnel-starter.jar:2.3.13] at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:247) [seatunnel-starter.jar:2.3.13] at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.getLogicalDag(ClientJobExecutionEnvironment.java:122) [seatunnel-starter.jar:2.3.13] at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.execute(ClientJobExecutionEnvironment.java:190) [seatunnel-starter.jar:2.3.13] at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:204) [seatunnel-starter.jar:2.3.13] at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40) [seatunnel-starter.jar:2.3.13] at org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:40) [seatunnel-starter.jar:2.3.13] 2026-09-11 10:22:31,413 INFO [.s.c.s.j.c.AbstractJdbcCatalog] [main] - Catalog Postgres established connection to jdbc:highgo://172.16.100.202:5866/cflag 2026-09-11 10:22:31,452 INFO [.s.c.s.j.c.AbstractJdbcCatalog] [main] - Catalog Postgres closing 2026-09-11 10:22:31,454 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel-272325] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is SHUTTING_DOWN 2026-09-11 10:22:31,460 INFO [c.h.i.s.t.TcpServerConnection ] [hz.main.IO.thread-in-1] - [localhost]:5801 [seatunnel-272325] [5.1] Connection[id=1, /127.0.0.1:5801->/127.0.0.1:48913, qualifier=null, endpoint=[127.0.0.1]:48913, remoteUuid=9f5f7a34-3985-4505-a9dc-77488d686f32, alive=false, connectionType=JVM, planeIndex=-1] closed. Reason: Connection closed by the other side 2026-09-11 10:22:31,461 INFO [.c.i.c.ClientConnectionManager] [main] - hz.client_1 [seatunnel-272325] [5.1] Removed connection to endpoint: [localhost]:5801:22400a55-3f18-4eae-b71b-e8db08e35468, connection: ClientConnection{alive=false, connectionId=1, channel=NioChannel{/127.0.0.1:48913->localhost/127.0.0.1:5801}, remoteAddress=[localhost]:5801, lastReadTime=2026-09-11 10:22:30.770, lastWriteTime=2026-09-11 10:22:30.765, closedTime=2026-09-11 10:22:31.456, connected server version=5.1} 2026-09-11 10:22:31,461 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel-272325] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is CLIENT_DISCONNECTED 2026-09-11 10:22:31,465 INFO [c.h.c.i.ClientEndpointManager ] [hz.main.event-4] - [localhost]:5801 [seatunnel-272325] [5.1] Destroying ClientEndpoint{connection=Connection[id=1, /127.0.0.1:5801->/127.0.0.1:48913, qualifier=null, endpoint=[127.0.0.1]:48913, remoteUuid=9f5f7a34-3985-4505-a9dc-77488d686f32, alive=false, connectionType=JVM, planeIndex=-1], clientUuid=9f5f7a34-3985-4505-a9dc-77488d686f32, clientName=hz.client_1, authenticated=true, clientVersion=5.1, creationTime=1789093350614, latest clientAttributes=lastStatisticsCollectionTime=1789093350699,enterprise=false,clientType=JVM,clientVersion=5.1,clusterConnectionTimestamp=1789093350590,clientAddress=127.0.0.1,clientName=hz.client_1,credentials.principal=null,os.committedVirtualMemorySize=0,os.freePhysicalMemorySize=15857844224,os.freeSwapSpaceSize=0,os.maxFileDescriptorCount=0,os.openFileDescriptorCount=0,os.processCpuTime=0,os.systemLoadAverage=1.63,os.totalPhysicalMemorySize=29206614016,os.totalSwapSpaceSize=0,runtime.availableProcessors=8,runtime.freeMemory=149121680,runtime.maxMemory=536870912,runtime.totalMemory=268435456,runtime.uptime=7945,runtime.usedMemory=119313776, labels=[]} 2026-09-11 10:22:31,473 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel-272325] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is SHUTDOWN 2026-09-11 10:22:31,474 INFO [s.c.s.s.c.ClientExecuteCommand] [main] - Closed SeaTunnel client...... 2026-09-11 10:22:31,475 INFO [c.h.c.LifecycleService ] [main] - [localhost]:5801 [seatunnel-272325] [5.1] [localhost]:5801 is SHUTTING_DOWN 2026-09-11 10:22:31,483 INFO [c.h.i.p.i.MigrationManager ] [hz.main.cached.thread-7] - [localhost]:5801 [seatunnel-272325] [5.1] Shutdown request of Member [localhost]:5801 - 22400a55-3f18-4eae-b71b-e8db08e35468 [master node] [active master] this is handled 2026-09-11 10:22:31,500 INFO [c.h.i.i.Node ] [main] - [localhost]:5801 [seatunnel-272325] [5.1] Shutting down connection manager... 2026-09-11 10:22:31,506 INFO [c.h.i.i.Node ] [main] - [localhost]:5801 [seatunnel-272325] [5.1] Shutting down node engine... 2026-09-11 10:22:31,540 INFO [.s.s.o.e.j.s.AbstractConnector] [main] - Stopped ServerConnector@3ea48c37{HTTP/1.1, (http/1.1)}{0.0.0.0:8080} 2026-09-11 10:22:31,540 INFO [o.a.s.s.o.e.j.s.session ] [main] - node0 Stopped scavenging 2026-09-11 10:22:31,542 INFO [a.s.s.o.e.j.s.h.ContextHandler] [main] - Stopped o.a.s.s.o.e.j.s.ServletContextHandler@15f519f7{/,null,STOPPED} 2026-09-11 10:22:31,548 INFO [.c.c.DefaultClassLoaderService] [main] - close classloader service 2026-09-11 10:22:31,556 INFO [o.a.s.e.s.EventService ] [event-forwarder-0] - Event forward thread interrupted 2026-09-11 10:22:34,570 INFO [c.h.i.i.NodeExtension ] [main] - [localhost]:5801 [seatunnel-272325] [5.1] Destroying node NodeExtension. 2026-09-11 10:22:34,571 INFO [c.h.i.i.Node ] [main] - [localhost]:5801 [seatunnel-272325] [5.1] Hazelcast Shutdown is completed in 3090 ms. 2026-09-11 10:22:34,572 INFO [c.h.c.LifecycleService ] [main] - [localhost]:5801 [seatunnel-272325] [5.1] [localhost]:5801 is SHUTDOWN 2026-09-11 10:22:34,572 INFO [s.c.s.s.c.ClientExecuteCommand] [main] - Closed HazelcastInstance ...... 2026-09-11 10:22:34,573 ERROR [o.a.s.c.s.SeaTunnel ] [main] -

===============================================================================

2026-09-11 10:22:34,573 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Fatal Error,

2026-09-11 10:22:34,573 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Please submit bug report in https://github.com/apache/seatunnel/issues

2026-09-11 10:22:34,573 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Reason:SeaTunnel job executed failed

2026-09-11 10:22:34,577 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:highgo://127.0.0.1:5866/sdr via JDBC. at org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.getConnection(AbstractJdbcCatalog.java:155) at org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.querySQLResultExists(AbstractJdbcCatalog.java:656) at org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.tableExists(AbstractJdbcCatalog.java:421) at java.base/java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:178) at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197) at java.base/java.util.ArrayList$ArrayListSpliterator.tryAdvance(ArrayList.java:1602) at java.base/java.util.stream.StreamSpliterators$WrappingSpliterator.lambda$initPartialTraversalState$0(StreamSpliterators.java:292) at java.base/java.util.stream.StreamSpliterators$AbstractWrappingSpliterator.fillBuffer(StreamSpliterators.java:206) at java.base/java.util.stream.StreamSpliterators$AbstractWrappingSpliterator.doAdvance(StreamSpliterators.java:161) at java.base/java.util.stream.StreamSpliterators$WrappingSpliterator.tryAdvance(StreamSpliterators.java:298) at java.base/java.util.Spliterators$1Adapter.hasNext(Spliterators.java:681) at org.apache.seatunnel.api.table.catalog.Catalog.buildCatalogTablesWithErrorCheck(Catalog.java:209) at org.apache.seatunnel.api.table.catalog.Catalog.getTables(Catalog.java:157) at org.apache.seatunnel.api.table.catalog.CatalogTableUtil.lambda$getCatalogTables$0(CatalogTableUtil.java:123) 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: com.highgo.jdbc.util.PSQLException: 致命错误: 数据库 "sdr" 不存在 at com.highgo.jdbc.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:3099) at com.highgo.jdbc.core.v3.QueryExecutorImpl.readStartupMessages(QueryExecutorImpl.java:3211) at com.highgo.jdbc.core.v3.QueryExecutorImpl.(QueryExecutorImpl.java:164) at com.highgo.jdbc.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:290) at com.highgo.jdbc.core.ConnectionFactory.openConnection(ConnectionFactory.java:51) at com.highgo.jdbc.jdbc.PgConnection.(PgConnection.java:249) at com.highgo.jdbc.Driver.makeConnection(Driver.java:547) at com.highgo.jdbc.Driver.connect(Driver.java:273) 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) ... 27 more

2026-09-11 10:22:34,578 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:highgo://127.0.0.1:5866/tesedb via JDBC. at org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.getConnection(AbstractJdbcCatalog.java:155) at org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.querySQLResultExists(AbstractJdbcCatalog.java:656) at org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.tableExists(AbstractJdbcCatalog.java:421) at java.base/java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:178) at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197) at java.base/java.util.ArrayList$ArrayListSpliterator.tryAdvance(ArrayList.java:1602) at java.base/java.util.stream.StreamSpliterators$WrappingSpliterator.lambda$initPartialTraversalState$0(StreamSpliterators.java:292) at java.base/java.util.stream.StreamSpliterators$AbstractWrappingSpliterator.fillBuffer(StreamSpliterators.java:206) at java.base/java.util.stream.StreamSpliterators$AbstractWrappingSpliterator.doAdvance(StreamSpliterators.java:161) at java.base/java.util.stream.StreamSpliterators$WrappingSpliterator.tryAdvance(StreamSpliterators.java:298) at java.base/java.util.Spliterators$1Adapter.hasNext(Spliterators.java:681) at org.apache.seatunnel.api.table.catalog.Catalog.buildCatalogTablesWithErrorCheck(Catalog.java:209) at org.apache.seatunnel.api.table.catalog.Catalog.getTables(Catalog.java:157) at org.apache.seatunnel.api.table.catalog.CatalogTableUtil.lambda$getCatalogTables$0(CatalogTableUtil.java:123) 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: com.highgo.jdbc.util.PSQLException: 致命错误: 数据库 "sdr" 不存在 at com.highgo.jdbc.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:3099) at com.highgo.jdbc.core.v3.QueryExecutorImpl.readStartupMessages(QueryExecutorImpl.java:3211) at com.highgo.jdbc.core.v3.QueryExecutorImpl.(QueryExecutorImpl.java:164) at com.highgo.jdbc.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:290) at com.highgo.jdbc.core.ConnectionFactory.openConnection(ConnectionFactory.java:51) at com.highgo.jdbc.jdbc.PgConnection.(PgConnection.java:249) at com.highgo.jdbc.Driver.makeConnection(Driver.java:547) at com.highgo.jdbc.Driver.connect(Driver.java:273) 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) ... 27 more configuration files：env