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
commit eda148d3624afbe8d8ed9d7ec2a9280d34b7dd68 Author: shuwenwei <[email protected]> AuthorDate: Tue Feb 3 18:00:22 2026 +0800 fix bug --- .../InformationSchemaContentSupplierFactory.java | 25 ++++++++++++---------- .../plan/planner/plan/node/PlanNodeType.java | 2 +- 2 files changed, 15 insertions(+), 12 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/InformationSchemaContentSupplierFactory.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/InformationSchemaContentSupplierFactory.java index d39143c173c..380485954f7 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/InformationSchemaContentSupplierFactory.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/InformationSchemaContentSupplierFactory.java @@ -1378,7 +1378,7 @@ public class InformationSchemaContentSupplierFactory { long maxRuntime = OperatorContext.getMaxRunTime().roundTo(TimeUnit.NANOSECONDS); long start = System.nanoTime(); - long prevStageEndTime; + long prevStageEndTime = start; try { try { @@ -1386,8 +1386,9 @@ public class InformationSchemaContentSupplierFactory { return null; } } finally { - prevStageEndTime = System.nanoTime(); - prepareCacheReaderCostInNS += prevStageEndTime - start; + long now = System.nanoTime(); + prepareCacheReaderCostInNS += now - prevStageEndTime; + prevStageEndTime = now; } try { @@ -1395,8 +1396,9 @@ public class InformationSchemaContentSupplierFactory { return null; } } finally { - prevStageEndTime = System.nanoTime(); - loadObjectFileCostInNS += prevStageEndTime - start; + long now = System.nanoTime(); + loadObjectFileCostInNS += now - prevStageEndTime; + prevStageEndTime = now; } try { @@ -1404,8 +1406,9 @@ public class InformationSchemaContentSupplierFactory { return null; } } finally { - prevStageEndTime = System.nanoTime(); - prepareCachedTsFileIDCostInNS += prevStageEndTime - start; + long now = System.nanoTime(); + prepareCachedTsFileIDCostInNS += now - prevStageEndTime; + prevStageEndTime = now; } try { @@ -1413,8 +1416,9 @@ public class InformationSchemaContentSupplierFactory { return null; } } finally { - prevStageEndTime = System.nanoTime(); - checkAllFilesInTsFileManagerCostInNS += prevStageEndTime - start; + long now = System.nanoTime(); + checkAllFilesInTsFileManagerCostInNS += now - prevStageEndTime; + prevStageEndTime = now; } try { @@ -1423,8 +1427,7 @@ public class InformationSchemaContentSupplierFactory { return null; } } finally { - prevStageEndTime = System.nanoTime(); - readTsFileCacheValueFilesCostInNS += prevStageEndTime - start; + readTsFileCacheValueFilesCostInNS += System.nanoTime() - prevStageEndTime; } return buildTsBlock(); diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/PlanNodeType.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/PlanNodeType.java index 6418d783c4e..dfa2d7c4496 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/PlanNodeType.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/PlanNodeType.java @@ -738,7 +738,7 @@ public enum PlanNodeType { case 1039: return ValuesNode.deserialize(buffer); case 1040: - return TableDiskUsageInformationSchemaTableScanNode.deserialize(buffer); + return TableDiskUsageInformationSchemaTableScanNode.deserialize(buffer); case 2000: return RelationalInsertTabletNode.deserialize(buffer); case 2001:
