This is an automated email from the ASF dual-hosted git repository.
chl-wxp pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new 36122261f4 [BugFix][connector-cdc-oracle] Fix table or view doesn't
exist in multitables CDB+PDB mode (#10829)
36122261f4 is described below
commit 36122261f4ca5bb87cb9e31b15ee9baf84a8c67c
Author: xiaofu <[email protected]>
AuthorDate: Tue May 12 17:54:25 2026 +0800
[BugFix][connector-cdc-oracle] Fix table or view doesn't exist in
multitables CDB+PDB mode (#10829)
Co-authored-by: puhaiyang <“[email protected]”>
---
.../oracle/source/reader/fetch/scan/OracleSnapshotSplitReadTask.java | 5 +++++
1 file changed, 5 insertions(+)
diff --git
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/reader/fetch/scan/OracleSnapshotSplitReadTask.java
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/reader/fetch/scan/OracleSnapshotSplitReadTask.java
index ddbabc80b4..b90b0361fb 100644
---
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/reader/fetch/scan/OracleSnapshotSplitReadTask.java
+++
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/reader/fetch/scan/OracleSnapshotSplitReadTask.java
@@ -200,6 +200,11 @@ public class OracleSnapshotSplitReadTask
long exportStart = clock.currentTimeInMillis();
LOG.info("Exporting data from split '{}' of table {}",
snapshotSplit.splitId(), table.id());
+ // Switch to PDB context before executing snapshot query for
multi-table CDC
+ if (connectorConfig.getPdbName() != null) {
+ jdbcConnection.setSessionToPdb(connectorConfig.getPdbName());
+ LOG.info("Switched to PDB '{}' for table {}",
connectorConfig.getPdbName(), table.id());
+ }
final String selectSql =
OracleUtils.buildSplitScanQuery(
snapshotSplit.getTableId(),
