This is an automated email from the ASF dual-hosted git repository. qiaojialin pushed a commit to branch fix_exception in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
commit d2e5860234cc595f7975ce7674625a577247a4a0 Author: qiaojialin <[email protected]> AuthorDate: Fri Mar 20 17:12:31 2020 +0800 add write process error code --- .../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),
