You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2020/12/10 02:22:16 UTC
[iotdb] branch try_MC created (now 67a11d0)
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch try_MC
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
at 67a11d0 try to fix exception
This branch includes the following new commits:
new 67a11d0 try to fix exception
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[iotdb] 01/01: try to fix exception
Posted by ha...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch try_MC
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 67a11d055d431960d8e9d9f051ee0a654ca0249d
Author: HTHou <hh...@outlook.com>
AuthorDate: Thu Dec 10 10:20:21 2020 +0800
try to fix exception
---
.../iotdb/db/engine/storagegroup/TsFileProcessor.java | 16 ++++++++--------
1 file changed, 8 insertions(+), 8 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java
index a94021b..d68380f 100644
--- a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java
+++ b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java
@@ -218,15 +218,15 @@ public class TsFileProcessor {
workMemTable = new PrimitiveMemTable(enableMemControl);
}
- try {
- if (enableMemControl) {
- checkMemCostAndAddToTspInfo(insertTabletPlan, start, end);
- }
- } catch (WriteProcessException e) {
- for (int i = start; i < end; i++) {
- results[i] = RpcUtils.getStatus(TSStatusCode.WRITE_PROCESS_REJECT, e.getMessage());
+ if (enableMemControl) {
+ try {
+ checkMemCostAndAddToTspInfo(insertTabletPlan, start, end);
+ } catch (Exception e) {
+ for (int i = start; i < end; i++) {
+ results[i] = RpcUtils.getStatus(TSStatusCode.WRITE_PROCESS_REJECT, e.getMessage());
+ }
+ throw new WriteProcessRejectException(e.getMessage());
}
- throw new WriteProcessException(e);
}
try {
workMemTable.insertTablet(insertTabletPlan, start, end);