[iotdb] 03/03: fix bug

[hu...@apache.org]

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

hui pushed a commit to branch lmh/intoType
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit 2e776409caee0ef7b125996ba9d980385b7ec83e
Author: Minghui Liu <li...@foxmail.com>
AuthorDate: Thu Jan 12 23:11:03 2023 +0800

    fix bug
---
 .../db/mpp/execution/operator/process/AbstractIntoOperator.java      | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/AbstractIntoOperator.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/AbstractIntoOperator.java
index e331bbcaa1..cc432f4103 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/AbstractIntoOperator.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/AbstractIntoOperator.java
@@ -406,8 +406,9 @@ public abstract class AbstractIntoOperator implements ProcessOperator {
         times[rowCount] = tsBlock.getTimeByIndex(lastReadIndex);
 
         for (int i = 0; i < measurements.length; ++i) {
-          Column valueColumn = tsBlock.getValueColumns()[inputLocations[i].getValueColumnIndex()];
-          Type sourceTypeConvertor = sourceTypeConvertors.get(i);
+          int valueColumnIndex = inputLocations[i].getValueColumnIndex();
+          Column valueColumn = tsBlock.getValueColumns()[valueColumnIndex];
+          Type sourceTypeConvertor = sourceTypeConvertors.get(valueColumnIndex);
 
           // if the value is NULL
           if (valueColumn.isNull(lastReadIndex)) {