(seatunnel) branch dev updated: [Improve][Oracle-CDC] Remove duplicate load table names (#9357)

[corgy]

This is an automated email from the ASF dual-hosted git repository.

corgy 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 90e88cafc5 [Improve][Oracle-CDC] Remove duplicate load table names 
(#9357)
90e88cafc5 is described below

commit 90e88cafc57e9d129f334e6f579c02d9bfc8b998
Author: hailin0 <wanghai...@apache.org>
AuthorDate: Wed May 28 22:15:43 2025 +0800

    [Improve][Oracle-CDC] Remove duplicate load table names (#9357)
---
 .../connectors/seatunnel/cdc/oracle/source/OracleDialect.java | 11 ++++-------
 1 file changed, 4 insertions(+), 7 deletions(-)

diff --git 
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/OracleDialect.java
 
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/OracleDialect.java
index b5baa33370..979e9cbdba 100644
--- 
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/OracleDialect.java
+++ 
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/OracleDialect.java
@@ -33,7 +33,6 @@ import 
org.apache.seatunnel.connectors.seatunnel.cdc.oracle.source.enumerator.Or
 import 
org.apache.seatunnel.connectors.seatunnel.cdc.oracle.source.reader.fetch.OracleSourceFetchTaskContext;
 import 
org.apache.seatunnel.connectors.seatunnel.cdc.oracle.source.reader.fetch.logminer.OracleRedoLogFetchTask;
 import 
org.apache.seatunnel.connectors.seatunnel.cdc.oracle.source.reader.fetch.scan.OracleSnapshotFetchTask;
-import 
org.apache.seatunnel.connectors.seatunnel.cdc.oracle.utils.OracleConnectionUtils;
 import org.apache.seatunnel.connectors.seatunnel.cdc.oracle.utils.OracleSchema;
 
 import io.debezium.connector.oracle.OracleConnection;
@@ -45,6 +44,7 @@ import java.sql.SQLException;
 import java.util.List;
 import java.util.Map;
 import java.util.Optional;
+import java.util.stream.Collectors;
 
 import static 
org.apache.seatunnel.connectors.seatunnel.cdc.oracle.utils.OracleConnectionUtils.createOracleConnection;
 
@@ -94,12 +94,9 @@ public class OracleDialect implements JdbcDataSourceDialect {
         OracleSourceConfig oracleSourceConfig = (OracleSourceConfig) 
sourceConfig;
         String database = 
oracleSourceConfig.getDbzConnectorConfig().getDatabaseName();
 
-        try (JdbcConnection jdbcConnection = openJdbcConnection(sourceConfig)) 
{
-            return OracleConnectionUtils.listTables(
-                    jdbcConnection, database, 
oracleSourceConfig.getTableFilters());
-        } catch (SQLException e) {
-            throw new SeaTunnelException("Error to discover tables: " + 
e.getMessage(), e);
-        }
+        return tableMap.keySet().stream()
+                .map(tableId -> new TableId(database, tableId.schema(), 
tableId.table()))
+                .collect(Collectors.toList());
     }
 
     @Override