From fda628120bc258daf7dbc9685504f38fd6810a64 Mon Sep 17 00:00:00 2001 From: mengqiu Date: Wed, 21 Oct 2020 11:04:59 +0800 Subject: [PATCH] =?UTF-8?q?DBZ-2683=20Support=20partition=20tables?= =?UTF-8?q?=E3=80=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/io/debezium/connector/oracle/logminer/SqlUtils.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 + ") "; } }