This is an automated email from the ASF dual-hosted git repository. Wei-hao-Li pushed a commit to branch lwh/move in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit b928e1c62e93f0f55d437aaf47d35ee6c72e589f Author: Weihao Li <[email protected]> AuthorDate: Thu Jun 11 18:12:09 2026 +0800 fix Signed-off-by: Weihao Li <[email protected]> --- .../plan/relational/planner/RelationPlanner.java | 25 ++++++++++++---------- .../plan/planner/plan/node/PlanNodeType.java | 4 +++- 2 files changed, 17 insertions(+), 12 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/RelationPlanner.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/RelationPlanner.java index bf09235c5c2..6acc8ca55cc 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/RelationPlanner.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/RelationPlanner.java @@ -343,17 +343,7 @@ public class RelationPlanner implements AstVisitor<RelationPlan, Void> { final ImmutableList.Builder<Symbol> outputSymbolsBuilder = ImmutableList.builder(); final ImmutableMap.Builder<Symbol, ColumnSchema> symbolToColumnSchema = ImmutableMap.builder(); final Collection<Field> fields = scope.getRelationType().getAllFields(); - final QualifiedName qualifiedName = analysis.getRelationName(table); - - if (!qualifiedName.getPrefix().isPresent()) { - throw new IllegalStateException( - DataNodeQueryMessages.TABLE + table.getName() + " has no prefix!"); - } - - final QualifiedObjectName qualifiedObjectName = - new QualifiedObjectName( - qualifiedName.getPrefix().map(QualifiedName::toString).orElse(null), - qualifiedName.getSuffix()); + final QualifiedObjectName qualifiedObjectName = getQualifiedObjectName(table, analysis); // on the basis of that the order of fields is same with the column category order of segments // in DeviceEntry @@ -411,6 +401,19 @@ public class RelationPlanner implements AstVisitor<RelationPlan, Void> { return new RelationPlan(tableScanNode, scope, outputSymbols, outerContext); } + public static QualifiedObjectName getQualifiedObjectName(Table table, Analysis analysis) { + final QualifiedName qualifiedName = analysis.getRelationName(table); + if (!qualifiedName.getPrefix().isPresent()) { + throw new IllegalStateException("Table " + table.getName() + " has no prefix!"); + } + + final QualifiedObjectName qualifiedObjectName = + new QualifiedObjectName( + qualifiedName.getPrefix().map(QualifiedName::toString).orElse(null), + qualifiedName.getSuffix()); + return qualifiedObjectName; + } + @Override public RelationPlan visitQuerySpecification(final QuerySpecification node, final Void context) { return new QueryPlanner( diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/queryengine/plan/planner/plan/node/PlanNodeType.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/queryengine/plan/planner/plan/node/PlanNodeType.java index 76a3b2f5e28..265aeef2097 100644 --- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/queryengine/plan/planner/plan/node/PlanNodeType.java +++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/queryengine/plan/planner/plan/node/PlanNodeType.java @@ -200,7 +200,9 @@ public enum PlanNodeType { TABLE_DISK_USAGE_INFORMATION_SCHEMA_TABLE_SCAN_NODE((short) 1040), ALIGNED_AGGREGATION_TREE_DEVICE_VIEW_SCAN_NODE((short) 1041), NON_ALIGNED_AGGREGATION_TREE_DEVICE_VIEW_SCAN_NODE((short) 1042), - TABLE_NEXT_FILL_NODE((short) 1043), + EVENT_SCAN_NODE((short) 1043), + SESSION_SCAN_NODE((short) 1044), + TABLE_NEXT_FILL_NODE((short) 1045), RELATIONAL_INSERT_TABLET((short) 2000), RELATIONAL_INSERT_ROW((short) 2001),
