(iotdb) branch master updated: Resolve the problem that will write empty DataPartitionTable object to consensus when not found any data partition in the CN (#18104)

[yongzao]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 453cb6e51fd Resolve the problem that will write empty 
DataPartitionTable object to consensus when not found any data partition in the 
CN (#18104)
453cb6e51fd is described below

commit 453cb6e51fdc4af14d4fb71c5cdc2524e8105045
Author: libo <zerolbs...@163.com>
AuthorDate: Fri Jul 3 15:55:12 2026 +0800

    Resolve the problem that will write empty DataPartitionTable object to 
consensus when not found any data partition in the CN (#18104)
---
 .../DataPartitionTableIntegrityCheckProcedure.java | 33 +++++++++++-----------
 1 file changed, 16 insertions(+), 17 deletions(-)

diff --git 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/partition/DataPartitionTableIntegrityCheckProcedure.java
 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/partition/DataPartitionTableIntegrityCheckProcedure.java
index 50f13039cc6..2b248edf3be 100644
--- 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/partition/DataPartitionTableIntegrityCheckProcedure.java
+++ 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/partition/DataPartitionTableIntegrityCheckProcedure.java
@@ -687,25 +687,24 @@ public class DataPartitionTableIntegrityCheckProcedure
         LOG.warn(
             "[DataPartitionIntegrity] No data partition table related to 
database {} was found from the ConfigNode, use data partition table of DataNode 
directly",
             database);
-        continue;
+      } else {
+        localDataPartitionTableMap
+            .values()
+            .forEach(
+                map ->
+                    map.forEach(
+                        (tSeriesPartitionSlot, seriesPartitionTableMap) -> {
+                          if (tSeriesPartitionSlot == null
+                              || seriesPartitionTableMap == null
+                              || seriesPartitionTableMap.isEmpty()) {
+                            return;
+                          }
+                          finalDataPartitionMap.computeIfAbsent(
+                              tSeriesPartitionSlot,
+                              k -> new 
SeriesPartitionTable(seriesPartitionTableMap));
+                        }));
       }
 
-      localDataPartitionTableMap
-          .values()
-          .forEach(
-              map ->
-                  map.forEach(
-                      (tSeriesPartitionSlot, seriesPartitionTableMap) -> {
-                        if (tSeriesPartitionSlot == null
-                            || seriesPartitionTableMap == null
-                            || seriesPartitionTableMap.isEmpty()) {
-                          return;
-                        }
-                        finalDataPartitionMap.computeIfAbsent(
-                            tSeriesPartitionSlot,
-                            k -> new 
SeriesPartitionTable(seriesPartitionTableMap));
-                      }));
-
       dataPartitionTables.forEach(
           (k, v) ->
               v.forEach(