[iotdb] branch master updated: fix when one row failed, then insertRecords() does not clear the failed messages (#2191)

[qiaojialin]

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

qiaojialin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 605a752  fix when one row failed, then insertRecords() does not clear 
the failed messages (#2191)
605a752 is described below

commit 605a7529a20862e69734ed373f959cfe4c28888f
Author: Xiangdong Huang <h...@apache.org>
AuthorDate: Sat Dec 5 10:02:56 2020 +0800

    fix when one row failed, then insertRecords() does not clear the failed 
messages (#2191)
    
    Co-authored-by: xiangdong huang <saint...@gmail.com>
---
 server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java 
b/server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java
index a075813..5d31794 100644
--- a/server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java
+++ b/server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java
@@ -1236,10 +1236,11 @@ public class TSServiceImpl implements TSIService.Iface, 
ServerContext {
     }
 
     List<TSStatus> statusList = new ArrayList<>();
-    InsertRowPlan plan = new InsertRowPlan();
+
     boolean isAllSuccessful = true;
     for (int i = 0; i < req.deviceIds.size(); i++) {
       try {
+        InsertRowPlan plan = new InsertRowPlan();
         plan.setDeviceId(new PartialPath(req.getDeviceIds().get(i)));
         plan.setTime(req.getTimestamps().get(i));
         plan.setMeasurements(req.getMeasurementsList().get(i).toArray(new 
String[0]));