This is an automated email from the ASF dual-hosted git repository.
rong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new 006ea2af65a Load: add detailed exception message in rpc returned
status (#13493)
006ea2af65a is described below
commit 006ea2af65acafdb743d7f9e104c2defe0d08596
Author: Zhenyu Luo <[email protected]>
AuthorDate: Thu Sep 12 19:40:57 2024 +0800
Load: add detailed exception message in rpc returned status (#13493)
---
.../iotdb/db/queryengine/plan/analyze/LoadTsFileAnalyzer.java | 11 +++--------
1 file changed, 3 insertions(+), 8 deletions(-)
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/LoadTsFileAnalyzer.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/LoadTsFileAnalyzer.java
index 05ff28b6a8c..d58eeaf0bb7 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/LoadTsFileAnalyzer.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/LoadTsFileAnalyzer.java
@@ -216,12 +216,7 @@ public class LoadTsFileAnalyzer implements AutoCloseable {
e.getMessage() == null ? e.getClass().getName() :
e.getMessage());
LOGGER.warn(exceptionMessage, e);
analysis.setFinishQueryAfterAnalyze(true);
- analysis.setFailStatus(
- RpcUtils.getStatus(
- TSStatusCode.LOAD_FILE_ERROR,
- String.format(
- "Auto create or verify schema error when executing statement
%s.",
- loadTsFileStatement)));
+ analysis.setFailStatus(RpcUtils.getStatus(TSStatusCode.LOAD_FILE_ERROR,
exceptionMessage));
return analysis;
}
@@ -460,8 +455,8 @@ public class LoadTsFileAnalyzer implements AutoCloseable {
LOGGER.warn("Auto create or verify schema error.", e);
throw new SemanticException(
String.format(
- "Auto create or verify schema error when executing statement
%s.",
- loadTsFileStatement));
+ "Auto create or verify schema error when executing statement
%s. Detail: %s.",
+ loadTsFileStatement, e.getMessage()));
}
}