tool
/
starrocks
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[BugFix] fix statistics collection error message (backport #62533) (#62568) 

Signed-off-by: stephen <stephen5217@163.com>
Co-authored-by: stephen <91597003+stephen-shelby@users.noreply.github.com>
This commit is contained in:
mergify[bot] 2025-09-01 14:55:53 +08:00 committed by GitHub
parent 82b8a41e2f
commit 4c14589c24
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
fe/fe-core/src/main/java/com/starrocks/statistic/StatisticExecutor.java
View File

@ -16,6 +16,7 @@ package com.starrocks.statistic;
import com.google.common.base.Preconditions;
import com.google.common.base.Stopwatch;
import com.google.common.base.Strings;
import com.google.common.collect.ImmutableSet;
import com.google.common.collect.Lists;
import com.google.common.collect.Maps;
@ -694,8 +695,12 @@ public class StatisticExecutor {
context.getSessionVariable().setEnableMaterializedViewRewrite(false);
Pair<List<TResultBatch>, Status> sqlResult = executor.executeStmtWithExecPlan(context, execPlan);
if (!sqlResult.second.ok()) {
String errorMsg = context.getState().getErrorMessage();
if (Strings.isNullOrEmpty(errorMsg) && executor.getCoordinator() != null) {
errorMsg = executor.getCoordinator().getExecStatus().getErrorMsg();
}
throw new SemanticException("Statistics query fail | Error Message [%s] | QueryId [%s] | SQL [%s]",
context.getState().getErrorMessage(), DebugUtil.printId(context.getQueryId()), sql);
errorMsg, DebugUtil.printId(context.getQueryId()), sql);
} else {
AuditLog.getStatisticAudit().info("statistic execute query | QueryId [{}] | SQL: {}",
DebugUtil.printId(context.getQueryId()), sql);