You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by w4...@apache.org on 2024/10/31 02:33:52 UTC
(doris) branch master updated: [chore](restore) Save restore stmt to the resp if RestoreSnapshot failed (#42933)
This is an automated email from the ASF dual-hosted git repository.
w41ter pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 193c0d09ba5 [chore](restore) Save restore stmt to the resp if RestoreSnapshot failed (#42933)
193c0d09ba5 is described below
commit 193c0d09ba521d497843183bd1e1bc533e2d11b4
Author: walter <w4...@gmail.com>
AuthorDate: Thu Oct 31 10:33:46 2024 +0800
[chore](restore) Save restore stmt to the resp if RestoreSnapshot failed (#42933)
---
.../java/org/apache/doris/service/FrontendServiceImpl.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java b/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java
index f592a20f84d..cd1af82563d 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java
@@ -3026,7 +3026,7 @@ public class FrontendServiceImpl implements FrontendService.Iface {
RestoreStmt restoreStmt = new RestoreStmt(label, repoName, restoreTableRefClause, properties, request.getMeta(),
request.getJobInfo());
restoreStmt.setIsBeingSynced();
- LOG.trace("restore snapshot info, restoreStmt: {}", restoreStmt);
+ LOG.debug("restore snapshot info, restoreStmt: {}", restoreStmt);
try {
ConnectContext ctx = new ConnectContext();
ctx.setQualifiedUser(request.getUser());
@@ -3037,13 +3037,13 @@ public class FrontendServiceImpl implements FrontendService.Iface {
restoreStmt.analyze(analyzer);
DdlExecutor.execute(Env.getCurrentEnv(), restoreStmt);
} catch (UserException e) {
- LOG.warn("failed to restore: {}", e.getMessage(), e);
+ LOG.warn("failed to restore: {}, stmt: {}", e.getMessage(), restoreStmt, e);
status.setStatusCode(TStatusCode.ANALYSIS_ERROR);
- status.addToErrorMsgs(e.getMessage());
+ status.addToErrorMsgs(e.getMessage() + ", stmt: " + restoreStmt.toString());
} catch (Throwable e) {
- LOG.warn("catch unknown result.", e);
+ LOG.warn("catch unknown result. stmt: {}", restoreStmt, e);
status.setStatusCode(TStatusCode.INTERNAL_ERROR);
- status.addToErrorMsgs(Strings.nullToEmpty(e.getMessage()));
+ status.addToErrorMsgs(Strings.nullToEmpty(e.getMessage()) + ", stmt: " + restoreStmt.toString());
} finally {
ConnectContext.remove();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org