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 11:27:23 UTC
(doris) branch branch-2.0 updated: [chore](restore) Save restore stmt to the resp if RestoreSnapshot failed #42933 (#42984)
This is an automated email from the ASF dual-hosted git repository.
w41ter pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new 867fafb99cd [chore](restore) Save restore stmt to the resp if RestoreSnapshot failed #42933 (#42984)
867fafb99cd is described below
commit 867fafb99cd3d84fc3f03245ad46d46ac27a5ad2
Author: walter <w4...@gmail.com>
AuthorDate: Thu Oct 31 19:27:14 2024 +0800
[chore](restore) Save restore stmt to the resp if RestoreSnapshot failed #42933 (#42984)
cherry pick from #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 d5aef9a78e3..9dbd0afd1c3 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
@@ -2928,7 +2928,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 = ConnectContext.get();
if (ctx == null) {
@@ -2946,13 +2946,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());
}
return result;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org