(shardingsphere) branch master updated: Refactor CDCSchemaTableUtils to fix E2E (#33878)

[sunnianjun]

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

sunnianjun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git


The following commit(s) were added to refs/heads/master by this push:
     new 60fae79ffe3 Refactor CDCSchemaTableUtils to fix E2E (#33878)
60fae79ffe3 is described below

commit 60fae79ffe31886755a960cce7fc5be02c04f508
Author: Haoran Meng <menghaora...@gmail.com>
AuthorDate: Mon Dec 2 14:55:41 2024 +0800

    Refactor CDCSchemaTableUtils to fix E2E (#33878)
---
 .../shardingsphere/data/pipeline/cdc/util/CDCSchemaTableUtils.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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
index e0ebecfed5d..760e36bc9a0 100644
--- 
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 @@ public final class CDCSchemaTableUtils {
         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;