You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2020/11/13 03:33:04 UTC
[iotdb] 01/02: add missing error message
This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a commit to branch add_missing_message
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 555467fb111a4e5cbf9212db6b5dd88dc319250e
Author: jt <jt...@163.com>
AuthorDate: Fri Nov 13 11:17:37 2020 +0800
add missing error message
---
.../org/apache/iotdb/db/service/TSServiceImpl.java | 20 ++++++++++----------
1 file changed, 10 insertions(+), 10 deletions(-)
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 9a55444..b1c76b1 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
@@ -1322,7 +1322,7 @@ public class TSServiceImpl implements TSIService.Iface, ServerContext {
} catch (Exception e) {
logger.error("meet error when insert in batch", e);
isAllSuccessful = false;
- statusList.add(RpcUtils.getStatus(TSStatusCode.INTERNAL_SERVER_ERROR));
+ statusList.add(RpcUtils.getStatus(TSStatusCode.INTERNAL_SERVER_ERROR, e.getMessage()));
}
}
@@ -1396,8 +1396,8 @@ public class TSServiceImpl implements TSIService.Iface, ServerContext {
return executeNonQueryPlan(plan);
} catch (Exception e) {
logger.error("meet error when insert", e);
+ return RpcUtils.getStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR, e.getMessage());
}
- return RpcUtils.getStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR);
}
@Override
@@ -1426,12 +1426,12 @@ public class TSServiceImpl implements TSIService.Iface, ServerContext {
return executeNonQueryPlan(plan);
} catch (Exception e) {
logger.error("meet error when insert", e);
+ return RpcUtils.getStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR, e.getMessage());
}
- return RpcUtils.getStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR);
}
@Override
- public TSStatus deleteData(TSDeleteDataReq req) throws TException {
+ public TSStatus deleteData(TSDeleteDataReq req) {
try {
if (!checkLogin(req.getSessionId())) {
logger.info(INFO_NOT_LOGIN, IoTDBConstant.GLOBAL_DB_NAME);
@@ -1454,8 +1454,8 @@ public class TSServiceImpl implements TSIService.Iface, ServerContext {
return new TSStatus(executeNonQueryPlan(plan));
} catch (Exception e) {
logger.error("meet error when delete data", e);
+ return RpcUtils.getStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR, e.getMessage());
}
- return RpcUtils.getStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR);
}
@Override
@@ -1553,8 +1553,8 @@ public class TSServiceImpl implements TSIService.Iface, ServerContext {
return new TSStatus(executeNonQueryPlan(plan));
} catch (Exception e) {
logger.error("meet error when set storage group", e);
+ return RpcUtils.getStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR, e.getMessage());
}
- return RpcUtils.getStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR);
}
@Override
@@ -1576,8 +1576,8 @@ public class TSServiceImpl implements TSIService.Iface, ServerContext {
return new TSStatus(executeNonQueryPlan(plan));
} catch (Exception e) {
logger.error("meet error when delete storage groups", e);
+ return RpcUtils.getStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR, e.getMessage());
}
- return RpcUtils.getStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR);
}
@Override
@@ -1603,8 +1603,8 @@ public class TSServiceImpl implements TSIService.Iface, ServerContext {
return executeNonQueryPlan(plan);
} catch (Exception e) {
logger.error("meet error when create timeseries", e);
+ return RpcUtils.getStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR, e.getMessage());
}
- return RpcUtils.getStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR);
}
@SuppressWarnings("squid:S3776") // Suppress high Cognitive Complexity warning
@@ -1713,8 +1713,8 @@ public class TSServiceImpl implements TSIService.Iface, ServerContext {
}
} catch (Exception e) {
logger.error("meet error when create multi timeseries", e);
+ return RpcUtils.getStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR, e.getMessage());
}
- return RpcUtils.getStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR);
}
@Override
@@ -1736,8 +1736,8 @@ public class TSServiceImpl implements TSIService.Iface, ServerContext {
return executeNonQueryPlan(plan);
} catch (Exception e) {
logger.error("meet error when delete timeseries", e);
+ return RpcUtils.getStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR, e.getMessage());
}
- return RpcUtils.getStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR);
}
@Override