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

caogaofei pushed a commit to branch beyyes/fix_input_location
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit d021bc5e61cfc3140f14877aa95731cf3e7a149b
Author: Beyyes <[email protected]>
AuthorDate: Wed Jul 24 11:06:52 2024 +0800

    fix inputLocation size usage
---
 .../iotdb/db/queryengine/plan/planner/OperatorTreeGenerator.java      | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/OperatorTreeGenerator.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/OperatorTreeGenerator.java
index 05425c23b2b..a9e4b1b00c2 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/OperatorTreeGenerator.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/OperatorTreeGenerator.java
@@ -1524,7 +1524,7 @@ public class OperatorTreeGenerator extends 
PlanVisitor<Operator, LocalExecutionP
               ImmutableMap.of(),
               ImmutableList.of(),
               inputDataTypes,
-              inputLocations.size() - 1,
+              inputLocations.size(),
               null);
 
       for (Expression expression : projectExpressions) {
@@ -1692,7 +1692,7 @@ public class OperatorTreeGenerator extends 
PlanVisitor<Operator, LocalExecutionP
               filterExpressionColumnTransformerMap,
               commonTransformerList,
               filterOutputDataTypes,
-              inputLocations.size() - 1,
+              inputLocations.size(),
               null);
 
       for (Expression expression : projectExpressions) {

Reply via email to