You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2021/12/19 01:47:22 UTC
[iotdb] branch TestVersion created (now 262257c)
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch TestVersion
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
at 262257c add some logs
This branch includes the following new commits:
new 262257c add some logs
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[iotdb] 01/01: add some logs
Posted by ja...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch TestVersion
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 262257c02b78158409252c0e722cb2e988d483db
Author: JackieTien97 <Ja...@foxmail.com>
AuthorDate: Sun Dec 19 09:46:24 2021 +0800
add some logs
---
.../iotdb/db/qp/physical/crud/InsertRowPlan.java | 71 +++++++++++++---------
1 file changed, 42 insertions(+), 29 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertRowPlan.java b/server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertRowPlan.java
index 5faea8b..2ae05d7 100644
--- a/server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertRowPlan.java
+++ b/server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertRowPlan.java
@@ -407,36 +407,49 @@ public class InsertRowPlan extends InsertPlan {
/** Make sure the values is already inited before calling this */
public void fillValues(ByteBuffer buffer) throws QueryProcessException {
for (int i = 0; i < measurements.length; i++) {
- // types are not determined, the situation mainly occurs when the plan uses string values
- // and is forwarded to other nodes
- byte typeNum = (byte) ReadWriteIOUtils.read(buffer);
- if (typeNum == TYPE_RAW_STRING) {
- values[i] = ReadWriteIOUtils.readString(buffer);
- continue;
- }
+ byte typeNum = -2;
+ try {
+ // types are not determined, the situation mainly occurs when the plan uses string values
+ // and is forwarded to other nodes
+ typeNum = (byte) ReadWriteIOUtils.read(buffer);
+ if (typeNum == TYPE_RAW_STRING) {
+ values[i] = ReadWriteIOUtils.readString(buffer);
+ continue;
+ }
- dataTypes[i] = TSDataType.values()[typeNum];
- switch (dataTypes[i]) {
- case BOOLEAN:
- values[i] = ReadWriteIOUtils.readBool(buffer);
- break;
- case INT32:
- values[i] = ReadWriteIOUtils.readInt(buffer);
- break;
- case INT64:
- values[i] = ReadWriteIOUtils.readLong(buffer);
- break;
- case FLOAT:
- values[i] = ReadWriteIOUtils.readFloat(buffer);
- break;
- case DOUBLE:
- values[i] = ReadWriteIOUtils.readDouble(buffer);
- break;
- case TEXT:
- values[i] = ReadWriteIOUtils.readBinary(buffer);
- break;
- default:
- throw new QueryProcessException("Unsupported data type:" + dataTypes[i]);
+ dataTypes[i] = TSDataType.values()[typeNum];
+ switch (dataTypes[i]) {
+ case BOOLEAN:
+ values[i] = ReadWriteIOUtils.readBool(buffer);
+ break;
+ case INT32:
+ values[i] = ReadWriteIOUtils.readInt(buffer);
+ break;
+ case INT64:
+ values[i] = ReadWriteIOUtils.readLong(buffer);
+ break;
+ case FLOAT:
+ values[i] = ReadWriteIOUtils.readFloat(buffer);
+ break;
+ case DOUBLE:
+ values[i] = ReadWriteIOUtils.readDouble(buffer);
+ break;
+ case TEXT:
+ values[i] = ReadWriteIOUtils.readBinary(buffer);
+ break;
+ default:
+ throw new QueryProcessException("Unsupported data type:" + dataTypes[i]);
+ }
+ } catch (Exception e) {
+ logger.error(
+ "something wrong happened, while filling values, type is {}, current index is {}, values length is {}, dataTypes length is {}, measurements length is {}",
+ typeNum,
+ i,
+ values.length,
+ dataTypes.length,
+ measurements.length,
+ e);
+ throw e;
}
}
}