(iotdb) branch table_disk_usage_statistics_with_cache updated: fix bug

[shuwenwei]

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

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


The following commit(s) were added to 
refs/heads/table_disk_usage_statistics_with_cache by this push:
     new 8ea69e719b4 fix bug
8ea69e719b4 is described below

commit 8ea69e719b47f56537e9ff44c020cfbdc221219a
Author: shuwenwei <s13979062...@gmail.com>
AuthorDate: Wed Feb 4 16:47:52 2026 +0800

    fix bug
---
 .../planner/distribute/TableDistributedPlanGenerator.java | 15 +++++++++++++++
 1 file changed, 15 insertions(+)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/distribute/TableDistributedPlanGenerator.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/distribute/TableDistributedPlanGenerator.java
index 2ef838d5d65..dcc7c65b120 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/distribute/TableDistributedPlanGenerator.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/distribute/TableDistributedPlanGenerator.java
@@ -33,6 +33,7 @@ import org.apache.iotdb.commons.utils.TimePartitionUtils;
 import org.apache.iotdb.confignode.rpc.thrift.TRegionInfo;
 import org.apache.iotdb.db.conf.IoTDBDescriptor;
 import org.apache.iotdb.db.exception.sql.SemanticException;
+import org.apache.iotdb.db.queryengine.common.DataNodeEndPoints;
 import org.apache.iotdb.db.queryengine.common.MPPQueryContext;
 import org.apache.iotdb.db.queryengine.common.QueryId;
 import org.apache.iotdb.db.queryengine.plan.ClusterTopology;
@@ -1071,6 +1072,20 @@ public class TableDistributedPlanGenerator
                 regionIds));
       }
     }
+    if (result.isEmpty()) {
+      result.add(
+          new TableDiskUsageInformationSchemaTableScanNode(
+              queryId.genPlanNodeId(),
+              node.getQualifiedObjectName(),
+              node.getOutputSymbols(),
+              node.getAssignments(),
+              node.getPushDownPredicate(),
+              node.getPushDownLimit(),
+              node.getPushDownOffset(),
+              new TRegionReplicaSet(
+                  null, 
ImmutableList.of(DataNodeEndPoints.getLocalDataNodeLocation())),
+              Collections.emptyList()));
+    }
     return result;
   }