This is an automated email from the ASF dual-hosted git repository. hxd pushed a commit to branch fix_insertRecords_not_clear_0.11 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 5dc427e29ff0d71fb75d2d62b1cc8bfcec12f676 Author: xiangdong huang <[email protected]> AuthorDate: Sat Dec 5 02:30:19 2020 +0800 fix when one row failed, then insertRecords() does not clear the failed messages --- 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]));
