Refactor CDCSchemaTableUtils to fix E2E (#33878)

apache · Dec 2, 2024 · 60fae79 · 60fae79
1 parent 77841b5
commit 60fae79
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...e/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/util/CDCSchemaTableUtils.java b/...e/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/util/CDCSchemaTableUtils.java
@@ -81,7 +81,7 @@ private static Map<String, Set<String>> parseTableExpressionWithAllTables(final
         Map<String, Set<String>> result = new HashMap<>(database.getAllSchemas().size(), 1F);
         for (ShardingSphereSchema schema : database.getAllSchemas()) {
             if (!systemSchemas.contains(schema.getName())) {
-                schema.getAllTables().forEach(each -> result.computeIfAbsent(each.getName(), ignored -> new HashSet<>()).add(each.getName()));
+                schema.getAllTables().forEach(each -> result.computeIfAbsent(schema.getName(), ignored -> new HashSet<>()).add(each.getName()));
             }
         }
         return result;