1362227089 opened a new issue, #12267:
URL: https://github.com/apache/seatunnel/issues/12267
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://172.16.100.202:5866/sdr_platform 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_platform" 不存在
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.<init>(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.<init>(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://172.16.100.202:5866/sdr_platform 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_platform" 不存在
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.<init>(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.<init>(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 {
parallelism = 1
job.mode = "STREAMING"
checkpoint.interval = 10000
}
source {
Postgres-CDC {
plugin_output = "highgo_cdc"
url = "jdbc:highgo://127.0.0.1:5866/testdb"
username = "xxx"
password = "xxxxxx"
database-names = ["testdb"]
schema-names = ["sdr"]
table-names = ["sdr.disease_info", "sdr.enroll_condition_dict"]
startup.mode = "initial"
slot.name = "seatunnel_highgo_slot"
decoding.plugin.name = "pgoutput"
}
}
sink {
Jdbc {
plugin_input = "highgo_cdc"
url =
"jdbc:mysql://127.0.0.1:3306/sdr?useSSL=false&serverTimezone=Asia/Shanghai&rewriteBatchedStatements=true"
driver = "com.mysql.cj.jdbc.Driver"
username = "xxx"
password = "xxxxxx"
generate_sink_sql = true
database = "sdr_platform"
table = "${table_name}"
primary_keys = ["id"]
# is_exactly_once = true
# xa_data_source_class_name = "com.mysql.cj.jdbc.MysqlXADataSource"
}
}`
I suspect that the HighGo database is incompatible with the PostgreSQL
database driver. Therefore, the PostgreSQL CDC provided by
connector-cdc-postgre does not support HighGo. However, when I tested
end-to-end real-time synchronization using MySQL CDC, there were no issues at
all.
--
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]
