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 48ac2729aea6d4868e8c2ec43de26fc14de510db Author: shuwenwei <[email protected]> AuthorDate: Tue Feb 3 16:53:03 2026 +0800 fix --- .../org/apache/iotdb/relational/it/IoTDBShowDiskUsageTableIT.java | 2 +- .../queryengine/plan/planner/node/source/SourceNodeSerdeTest.java | 6 +++++- 2 files changed, 6 insertions(+), 2 deletions(-) diff --git a/integration-test/src/test/java/org/apache/iotdb/relational/it/IoTDBShowDiskUsageTableIT.java b/integration-test/src/test/java/org/apache/iotdb/relational/it/IoTDBShowDiskUsageTableIT.java index 58373fc7bfc..e63d6c0f3c7 100644 --- a/integration-test/src/test/java/org/apache/iotdb/relational/it/IoTDBShowDiskUsageTableIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/relational/it/IoTDBShowDiskUsageTableIT.java @@ -144,7 +144,7 @@ public class IoTDBShowDiskUsageTableIT { SessionDataSet.DataIterator iterator = sessionDataSet.iterator(); while (iterator.next()) { Assert.assertTrue( - iterator.getLong("time_partition") < 0 || iterator.getLong("node_id") >= 2); + iterator.getLong("time_partition") < 0 || iterator.getLong("datanode_id") >= 2); } } catch (Exception e) { e.printStackTrace(); diff --git a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/node/source/SourceNodeSerdeTest.java b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/node/source/SourceNodeSerdeTest.java index 6093184331d..78bd5ce49ef 100644 --- a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/node/source/SourceNodeSerdeTest.java +++ b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/node/source/SourceNodeSerdeTest.java @@ -154,6 +154,10 @@ public class SourceNodeSerdeTest { ByteBuffer byteBuffer = ByteBuffer.allocate(2048); node.serialize(byteBuffer); byteBuffer.flip(); - assertEquals(PlanNodeDeserializeHelper.deserialize(byteBuffer), node); + assertEquals( + ((TableDiskUsageInformationSchemaTableScanNode) + PlanNodeDeserializeHelper.deserialize(byteBuffer)) + .getRegions(), + node.getRegions()); } }
