diff --git a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/SqlUtils.java b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/SqlUtils.java index a4eb67c48..03d9daa48 100644 --- a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/SqlUtils.java +++ b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/SqlUtils.java @@ -129,6 +129,6 @@ private static String buildTableInPredicate(List tables) { StringJoiner tableNames = new StringJoiner(","); tables.forEach(table -> tableNames.add("'" + table + "'")); - return " AND table_name IN (" + tableNames + ") AND SEG_NAME IN (" + tableNames + ") "; + return " AND table_name IN (" + tableNames + ") "; } }