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 2020/12/05 02:01:28 UTC
[iotdb] branch rel/0.11 updated: fix when one row failed,
then insertRecords() does not clear the failed messages (#2190)
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 <hx...@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 <sa...@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]));