Refactor CDCSchemaTableUtils to fix E2E (#33878)

menghaoranss · web-flow · commit 60fae79ffe31 · 2024-12-02T14:55:41.000+08:00
diff --git a/kernel/data-pipeline/scenario/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/util/CDCSchemaTableUtils.java b/kernel/data-pipeline/scenario/cdc/core/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;

Original file line number	Diff line number	Diff line change
`@@ -81,7 +81,7 @@ private static Map<String, Set<String>> parseTableExpressionWithAllTables(final`
`81`	`81`	`Map<String, Set<String>> result = new HashMap<>(database.getAllSchemas().size(), 1F);`
`82`	`82`	`for (ShardingSphereSchema schema : database.getAllSchemas()) {`
`83`	`83`	`if (!systemSchemas.contains(schema.getName())) {`
`84`		`- schema.getAllTables().forEach(each -> result.computeIfAbsent(each.getName(), ignored -> new HashSet<>()).add(each.getName()));`
	`84`	`+ schema.getAllTables().forEach(each -> result.computeIfAbsent(schema.getName(), ignored -> new HashSet<>()).add(each.getName()));`
`85`	`85`	`}`
`86`	`86`	`}`
`87`	`87`	`return result;`