[incubator-iotdb] branch master updated: add write process error code (#928)

[ji...@apache.org]

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

jiangtian pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 03fbb9e  add write process error code (#928)
03fbb9e is described below

commit 03fbb9e7e1c729547cee2cf6fd840707f8ff70b7
Author: Jialin Qiao <qj...@mails.tsinghua.edu.cn>
AuthorDate: Fri Mar 20 17:15:59 2020 +0800

    add write process error code (#928)
---
 .../org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java  | 4 ++--
 .../java/org/apache/iotdb/db/exception/WriteProcessException.java | 8 ++++++--
 service-rpc/src/main/java/org/apache/iotdb/rpc/TSStatusCode.java  | 1 +
 3 files changed, 9 insertions(+), 4 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 9776844..392e2dc 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
@@ -166,8 +166,8 @@ public class TsFileProcessor {
       try {
         getLogNode().write(insertPlan);
       } catch (Exception e) {
-        throw new WriteProcessException(String.format("%s: %s write WAL failed, because %s",
-            storageGroupName, tsFileResource.getFile().getAbsolutePath(), e.getMessage()));
+        throw new WriteProcessException(String.format("%s: %s write WAL failed",
+            storageGroupName, tsFileResource.getFile().getAbsolutePath()), e);
       }
     }
 
diff --git a/server/src/main/java/org/apache/iotdb/db/exception/WriteProcessException.java b/server/src/main/java/org/apache/iotdb/db/exception/WriteProcessException.java
index dde7735..02aaad9 100644
--- a/server/src/main/java/org/apache/iotdb/db/exception/WriteProcessException.java
+++ b/server/src/main/java/org/apache/iotdb/db/exception/WriteProcessException.java
@@ -26,15 +26,19 @@ public class WriteProcessException extends IoTDBException {
   private static final long serialVersionUID = 7082567513626836322L;
 
   public WriteProcessException(String message) {
-    super(message, TSStatusCode.STORAGE_GROUP_ERROR.getStatusCode());
+    super(message, TSStatusCode.WRITE_PROCESS_ERROR.getStatusCode());
   }
 
   public WriteProcessException(String message, int errorCode) {
     super(message, errorCode);
   }
 
+  public WriteProcessException(String message, Throwable cause) {
+    super(message, cause, TSStatusCode.WRITE_PROCESS_ERROR.getStatusCode());
+  }
+
   public WriteProcessException(Exception exception) {
-    super(exception, TSStatusCode.STORAGE_GROUP_PROCESSOR_ERROR.getStatusCode());
+    super(exception, TSStatusCode.WRITE_PROCESS_ERROR.getStatusCode());
   }
 
 }
diff --git a/service-rpc/src/main/java/org/apache/iotdb/rpc/TSStatusCode.java b/service-rpc/src/main/java/org/apache/iotdb/rpc/TSStatusCode.java
index fb307df..74710cd 100644
--- a/service-rpc/src/main/java/org/apache/iotdb/rpc/TSStatusCode.java
+++ b/service-rpc/src/main/java/org/apache/iotdb/rpc/TSStatusCode.java
@@ -52,6 +52,7 @@ public enum TSStatusCode {
   UNSUPPORTED_FILL_TYPE_ERROR(409),
   PATH_ERROR(410),
   QUERY_PROCESS_ERROR(411),
+  WRITE_PROCESS_ERROR(412),
 
   INTERNAL_SERVER_ERROR(500),
   CLOSE_OPERATION_ERROR(501),