This is an automated email from the ASF dual-hosted git repository.
menghaoran 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 f58e00eee63 Fix TableRowDataPersistService to load table data from
registry (#37971)
f58e00eee63 is described below
commit f58e00eee63a934c2f3102fef3ae030978f1b078
Author: Haoran Meng <[email protected]>
AuthorDate: Fri Feb 6 20:18:34 2026 +0800
Fix TableRowDataPersistService to load table data from registry (#37971)
---
.../metadata/persist/metadata/service/TableRowDataPersistService.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/persist/metadata/service/TableRowDataPersistService.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/persist/metadata/service/TableRowDataPersistService.java
index 833b301b83e..3d1a0fd7203 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/persist/metadata/service/TableRowDataPersistService.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/persist/metadata/service/TableRowDataPersistService.java
@@ -80,8 +80,8 @@ public final class TableRowDataPersistService {
public TableStatistics load(final String databaseName, final String
schemaName, final ShardingSphereTable table) {
TableStatistics result = new TableStatistics(table.getName());
YamlRowStatisticsSwapper swapper = new YamlRowStatisticsSwapper(new
ArrayList<>(table.getAllColumns()));
- for (String each :
repository.getChildrenKeys(NodePathGenerator.toPath(new
StatisticsTableNodePath(databaseName, schemaName, table.getName())))) {
- String yamlRow = repository.query(NodePathGenerator.toPath(new
StatisticsDataNodePath(databaseName, schemaName, table.getName(), each)));
+ for (String each :
repository.getChildrenKeys(NodePathGenerator.toPath(new
StatisticsTableNodePath(databaseName, schemaName,
table.getName().toLowerCase())))) {
+ String yamlRow = repository.query(NodePathGenerator.toPath(new
StatisticsDataNodePath(databaseName, schemaName, table.getName().toLowerCase(),
each)));
if (!Strings.isNullOrEmpty(yamlRow)) {
result.getRows().add(swapper.swapToObject(YamlEngine.unmarshal(yamlRow,
YamlRowStatistics.class)));
}