[iotdb] branch rel/0.11 updated: fix when one row failed, then insertRecords() does not clear the failed messages (#2190)

[jackietien]

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

jackietien pushed a commit to branch rel/0.11
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/rel/0.11 by this push:
     new 4b06652  fix when one row failed, then insertRecords() does not clear 
the failed messages (#2190)
4b06652 is described below

commit 4b0665201e1c2267cb228c8526dab6524b9c5e6d
Author: Xiangdong Huang <h...@apache.org>
AuthorDate: Sat Dec 5 10:01:10 2020 +0800

    fix when one row failed, then insertRecords() does not clear the failed 
messages (#2190)
    
    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 3f0fa48..76f4f59 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
@@ -1253,9 +1253,10 @@ public class TSServiceImpl implements TSIService.Iface, 
ServerContext {
     }
 
     List<TSStatus> statusList = new ArrayList<>();
-    InsertRowPlan plan = new InsertRowPlan();
+
     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]));