This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch mc_insert_block_11 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit da3547f03a9265a439cfd13dc55e9d680d2be98d Author: HTHou <[email protected]> AuthorDate: Tue Dec 1 17:49:38 2020 +0800 fix review --- .../apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java index 2c4e09f..609f625 100755 --- a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java +++ b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java @@ -699,17 +699,19 @@ public class StorageGroupProcessor { */ @SuppressWarnings("squid:S3776") // Suppress high Cognitive Complexity warning public void insertTablet(InsertTabletPlan insertTabletPlan) throws BatchInsertionException { - TSStatus[] results = new TSStatus[insertTabletPlan.getRowCount()]; - Arrays.fill(results, RpcUtils.SUCCESS_STATUS); if (enableMemControl) { try { blockInsertionIfReject(); } catch (WriteProcessException e) { + TSStatus[] results = new TSStatus[insertTabletPlan.getRowCount()]; + Arrays.fill(results, RpcUtils.SUCCESS_STATUS); throw new BatchInsertionException(results); } } writeLock(); try { + TSStatus[] results = new TSStatus[insertTabletPlan.getRowCount()]; + Arrays.fill(results, RpcUtils.SUCCESS_STATUS); boolean noFailure = true; /*
