1362227089 commented on issue #12267:
URL: https://github.com/apache/seatunnel/issues/12267#issuecomment-5707214576
Thank you for your guidance.
We have reproduced the initialization failure in the logical-replication
test and captured the full sanitized exception stack trace.
Key information as requested:
- Database name: `highgo`
- Schema name: `testdb`
- Table name: `test_a`
- Fully qualified table name: `highgo.testdb.test_a`
The error message:
```
Table highgo.testdb.test_a does not have a full replica identity, please
execute: ALTER TABLE highgo.testdb.test_a REPLICA IDENTITY FULL;
```
The table `testdb.test_a` has a valid primary key, and `relreplident = 'd'`.
Detailed error message information is as follows:
`2026-09-17 09:45:49,466 WARN [.c.s.c.p.u.TableDiscoveryUtils] [main] -
skipping database 'template1' due to error reading tables: 错误: 未实现跨数据库关联:
"template1.information_schema.tables"
位置：15
2026-09-17 09:45:49,474 WARN [.c.s.c.p.u.TableDiscoveryUtils] [main] -
skipping database 'template0' due to error reading tables: 错误: 未实现跨数据库关联:
"template0.information_schema.tables"
位置：15
2026-09-17 09:45:49,485 WARN [.c.s.c.p.u.TableDiscoveryUtils] [main] -
skipping database 'cflag' due to error reading tables: 错误: 未实现跨数据库关联:
"cflag.information_schema.tables"
位置：15
2026-09-17 09:45:49,543 INFO [i.d.j.JdbcConnection ]
[pool-9-thread-1] - Connection gracefully closed
2026-09-17 09:45:49,548 INFO [c.h.c.LifecycleService ] [main] -
hz.client_1 [seatunnel-833098] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7)
is SHUTTING_DOWN
2026-09-17 09:45:49,565 INFO [.c.i.c.ClientConnectionManager] [main] -
hz.client_1 [seatunnel-833098] [5.1] Removed connection to endpoint:
[localhost]:5801:4e960a8f-fce1-4710-b4e8-0720791a3b77, connection:
ClientConnection{alive=false, connectionId=1,
channel=NioChannel{/127.0.0.1:44417->localhost/127.0.0.1:5801},
remoteAddress=[localhost]:5801, lastReadTime=2026-09-17 09:45:45.091,
lastWriteTime=2026-09-17 09:45:45.083, closedTime=2026-09-17 09:45:49.555,
connected server version=5.1}
2026-09-17 09:45:49,566 INFO [c.h.c.LifecycleService ] [main] -
hz.client_1 [seatunnel-833098] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7)
is CLIENT_DISCONNECTED
2026-09-17 09:45:49,566 INFO [c.h.i.s.t.TcpServerConnection ]
[hz.main.IO.thread-in-1] - [localhost]:5801 [seatunnel-833098] [5.1]
Connection[id=1, /127.0.0.1:5801->/127.0.0.1:44417, qualifier=null,
endpoint=[127.0.0.1]:44417, remoteUuid=43ed1ea7-a1fa-424b-ad22-453db5fb667d,
alive=false, connectionType=JVM, planeIndex=-1] closed. Reason: Connection
closed by the other side
2026-09-17 09:45:49,607 INFO [c.h.c.i.ClientEndpointManager ]
[hz.main.event-3] - [localhost]:5801 [seatunnel-833098] [5.1] Destroying
ClientEndpoint{connection=Connection[id=1, /127.0.0.1:5801->/127.0.0.1:44417,
qualifier=null, endpoint=[127.0.0.1]:44417,
remoteUuid=43ed1ea7-a1fa-424b-ad22-453db5fb667d, alive=false,
connectionType=JVM, planeIndex=-1],
clientUuid=43ed1ea7-a1fa-424b-ad22-453db5fb667d, clientName=hz.client_1,
authenticated=true, clientVersion=5.1, creationTime=1789609544800, latest
clientAttributes=lastStatisticsCollectionTime=1789609544989,enterprise=false,clientType=JVM,clientVersion=5.1,clusterConnectionTimestamp=1789609544753,clientAddress=127.0.0.1,clientName=hz.client_1,credentials.principal=null,os.committedVirtualMemorySize=0,os.freePhysicalMemorySize=655360000,os.freeSwapSpaceSize=0,os.maxFileDescriptorCount=0,os.openFileDescriptorCount=0,os.processCpuTime=0,os.systemLoadAverage=8.9,os.totalPhysicalMemorySize=29206614016,os.totalSwapSpaceSize=0,runtime.ava
ilableProcessors=8,runtime.freeMemory=144755296,runtime.maxMemory=536870912,runtime.totalMemory=268435456,runtime.uptime=14366,runtime.usedMemory=123680160,
labels=[]}
2026-09-17 09:45:49,608 INFO [c.h.c.LifecycleService ] [main] -
hz.client_1 [seatunnel-833098] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7)
is SHUTDOWN
2026-09-17 09:45:49,619 INFO [s.c.s.s.c.ClientExecuteCommand] [main] -
Closed SeaTunnel client......
2026-09-17 09:45:49,619 INFO [c.h.c.LifecycleService ] [main] -
[localhost]:5801 [seatunnel-833098] [5.1] [localhost]:5801 is SHUTTING_DOWN
2026-09-17 09:45:49,646 INFO [c.h.i.p.i.MigrationManager ]
[hz.main.cached.thread-11] - [localhost]:5801 [seatunnel-833098] [5.1] Shutdown
request of Member [localhost]:5801 - 4e960a8f-fce1-4710-b4e8-0720791a3b77
[master node] [active master] this is handled
2026-09-17 09:45:49,761 INFO [o.a.s.e.s.CoordinatorService ]
[pool-5-thread-1] - [localhost]:5801 [seatunnel-833098] [5.1] This node become
leave active master node, begin clear coordinator service
2026-09-17 09:45:49,754 INFO [c.h.i.i.Node ] [main] -
[localhost]:5801 [seatunnel-833098] [5.1] Shutting down connection manager...
2026-09-17 09:45:49,777 INFO [c.h.i.i.Node ] [main] -
[localhost]:5801 [seatunnel-833098] [5.1] Shutting down node engine...
2026-09-17 09:45:50,024 INFO [.s.s.o.e.j.s.AbstractConnector] [main] -
Stopped ServerConnector@4d25f816{HTTP/1.1, (http/1.1)}{0.0.0.0:8090}
2026-09-17 09:45:50,025 INFO [o.a.s.s.o.e.j.s.session ] [main] -
node0 Stopped scavenging
2026-09-17 09:45:50,027 INFO [a.s.s.o.e.j.s.h.ContextHandler] [main] -
Stopped o.a.s.s.o.e.j.s.ServletContextHandler@74bbc273{/,null,STOPPED}
2026-09-17 09:45:50,037 INFO [.c.c.DefaultClassLoaderService] [main] -
close classloader service
2026-09-17 09:45:50,041 INFO [o.a.s.e.s.EventService ]
[event-forwarder-0] - Event forward thread interrupted
2026-09-17 09:45:51,265 INFO [c.h.i.i.NodeExtension ] [main] -
[localhost]:5801 [seatunnel-833098] [5.1] Destroying node NodeExtension.
2026-09-17 09:45:51,269 INFO [c.h.i.i.Node ] [main] -
[localhost]:5801 [seatunnel-833098] [5.1] Hazelcast Shutdown is completed in
1624 ms.
2026-09-17 09:45:51,269 INFO [c.h.c.LifecycleService ] [main] -
[localhost]:5801 [seatunnel-833098] [5.1] [localhost]:5801 is SHUTDOWN
2026-09-17 09:45:51,270 INFO [s.c.s.s.c.ClientExecuteCommand] [main] -
Closed HazelcastInstance ......
2026-09-17 09:45:51,270 ERROR [o.a.s.c.s.SeaTunnel ] [main] -
===============================================================================
2026-09-17 09:45:51,270 ERROR [o.a.s.c.s.SeaTunnel ] [main] -
Fatal Error,
2026-09-17 09:45:51,270 ERROR [o.a.s.c.s.SeaTunnel ] [main] -
Please submit bug report in https://github.com/apache/seatunnel/issues
2026-09-17 09:45:51,270 ERROR [o.a.s.c.s.SeaTunnel ] [main] -
Reason:SeaTunnel job executed failed
2026-09-17 09:45:51,273 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.common.utils.SeaTunnelException: Table
highgo.testdb.test_a does not have a full replica identity, please execute:
ALTER TABLE highgo.testdb.test_a REPLICA IDENTITY FULL;
at
org.apache.seatunnel.connectors.seatunnel.cdc.postgres.source.PostgresDialect.checkAllTablesEnabledCapture(PostgresDialect.java:126)
at
org.apache.seatunnel.connectors.seatunnel.cdc.postgres.source.PostgresDialect.discoverDataCollections(PostgresDialect.java:110)
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
2026-09-17 09:45:51,273 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.common.utils.SeaTunnelException: Table
highgo.testdb.test_a does not have a full replica identity, please execute:
ALTER TABLE highgo.testdb.test_a REPLICA IDENTITY FULL;
at
org.apache.seatunnel.connectors.seatunnel.cdc.postgres.source.PostgresDialect.checkAllTablesEnabledCapture(PostgresDialect.java:126)
at
org.apache.seatunnel.connectors.seatunnel.cdc.postgres.source.PostgresDialect.discoverDataCollections(PostgresDialect.java:110)
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
`
--
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]
