1362227089 commented on issue #12228:
URL: https://github.com/apache/seatunnel/issues/12228#issuecomment-5613817053
SeaTunnel version: 2.3.13
HighGo version: 4.5.8
configuration：
`env {
parallelism = 1
job.mode = "STREAMING"
checkpoint.interval = 10000
}
source {
Postgres-CDC {
plugin_output = "highgo_cdc"
driver = "com.highgo.jdbc.Driver"
url = "jdbc:highgo://xxxxxx:5866/testdb"
username = "username"
password = "pws"
database-names = ["testdb"]
schema-names = ["sdr_platform"]
table-names = [
"testdb.sdr_platform.disease_info",
"testdb.sdr_platform.enroll_condition_dict"
]
startup.mode = "initial"
slot.name = "seatunnel_highgo_slot"
decoding.plugin.name = "pgoutput"
debezium {
"publication.name" = "seatunnel_pub"
"publication.autocreate.mode" = "disabled"
}
}
}
sink {
Jdbc {
plugin_input = "highgo_cdc"
url =
"jdbc:mysql://xxxxx:3306/sdr_platform?useSSL=false&serverTimezone=Asia/Shanghai&rewriteBatchedStatements=true"
driver = "com.mysql.cj.jdbc.Driver"
username = "username"
password = "pwd"
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"
}
}`
error info：
===============================================================================
2026-09-10 13:37:33,826 ERROR [o.a.s.c.s.SeaTunnel ] [main] -
Fatal Error,
2026-09-10 13:37:33,826 ERROR [o.a.s.c.s.SeaTunnel ] [main] -
Please submit bug report in https://github.com/apache/seatunnel/issues
2026-09-10 13:37:33,827 ERROR [o.a.s.c.s.SeaTunnel ] [main] -
Reason:SeaTunnel job executed failed
2026-09-10 13:37:33,832 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: io.debezium.DebeziumException: Couldn't obtain encoding for
database cflag
at
io.debezium.connector.postgresql.connection.PostgresConnection.getDatabaseCharset(PostgresConnection.java:489)
at
org.apache.seatunnel.connectors.seatunnel.cdc.postgres.utils.PostgresConnectionUtils.newPostgresValueConverterBuilder(PostgresConnectionUtils.java:50)
at
org.apache.seatunnel.connectors.seatunnel.cdc.postgres.source.PostgresDialect.openJdbcConnection(PostgresDialect.java:93)
at
org.apache.seatunnel.connectors.seatunnel.cdc.postgres.source.PostgresDialect.discoverDataCollections(PostgresDialect.java:106)
at
org.apache.seatunnel.connectors.seatunnel.cdc.postgres.source.PostgresIncrementalSource.tableChanges(PostgresIncrementalSource.java:136)
at
org.apache.seatunnel.connectors.seatunnel.cdc.postgres.source.PostgresIncrementalSource.createDebeziumDeserializationSchema(PostgresIncrementalSource.java:98)
at
org.apache.seatunnel.connectors.cdc.base.source.IncrementalSource.<init>(IncrementalSource.java:127)
at
org.apache.seatunnel.connectors.seatunnel.cdc.postgres.source.PostgresIncrementalSource.<init>(PostgresIncrementalSource.java:63)
at
org.apache.seatunnel.connectors.seatunnel.cdc.postgres.source.PostgresIncrementalSourceFactory.lambda$createSource$1(PostgresIncrementalSourceFactory.java:110)
at
org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:180)
at
org.apache.seatunnel.api.table.factory.FactoryUtil.restoreAndPrepareSource(FactoryUtil.java:136)
... 8 more
Caused by: 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
io.debezium.jdbc.JdbcConnection.lambda$patternBasedFactory$1(JdbcConnection.java:244)
at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:888)
at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:883)
at
io.debezium.connector.postgresql.connection.PostgresConnection.getDatabaseCharset(PostgresConnection.java:486)
... 18 more
2026-09-10 13:37:33,833 ERROR [o.a.s.c.s.SeaTunnel ] [main] -
===============================================================================
--
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]
