You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ro...@apache.org on 2021/06/03 08:15:00 UTC
[iotdb] branch rel/0.12 updated: [IOTDB-1412] Unclear exception
message thrown when executing empty InsertTabletPlan (#3296) (#3320)
This is an automated email from the ASF dual-hosted git repository.
rong pushed a commit to branch rel/0.12
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/rel/0.12 by this push:
new b9d5cb8 [IOTDB-1412] Unclear exception message thrown when executing empty InsertTabletPlan (#3296) (#3320)
b9d5cb8 is described below
commit b9d5cb89adcc686ac5a012c47da26b3a2dcc4dbb
Author: Steve Yurong Su (宇荣) <ro...@apache.org>
AuthorDate: Thu Jun 3 03:04:01 2021 -0500
[IOTDB-1412] Unclear exception message thrown when executing empty InsertTabletPlan (#3296) (#3320)
(cherry picked from commit e19ad0575d597bcd0a6dd74ea54a1bc7fcfe5e3d)
---
.../src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java | 6 ++++++
1 file changed, 6 insertions(+)
diff --git a/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java b/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java
index ff2e37b..6063796 100644
--- a/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java
+++ b/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java
@@ -1151,6 +1151,9 @@ public class PlanExecutor implements IPlanExecutor {
@Override
public void insert(InsertRowsOfOneDevicePlan insertRowsOfOneDevicePlan)
throws QueryProcessException {
+ if (insertRowsOfOneDevicePlan.getRowPlans().length == 0) {
+ return;
+ }
try {
for (InsertRowPlan plan : insertRowsOfOneDevicePlan.getRowPlans()) {
plan.setMeasurementMNodes(new MeasurementMNode[plan.getMeasurements().length]);
@@ -1265,6 +1268,9 @@ public class PlanExecutor implements IPlanExecutor {
@Override
public void insertTablet(InsertTabletPlan insertTabletPlan) throws QueryProcessException {
+ if (insertTabletPlan.getRowCount() == 0) {
+ return;
+ }
try {
insertTabletPlan.setMeasurementMNodes(
new MeasurementMNode[insertTabletPlan.getMeasurements().length]);