diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java b/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java index 975ad36bcc..37c188377e 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java +++ b/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java @@ -1248,10 +1248,15 @@ public class StmtExecutor implements ProfileWriter { coord.exec(); - coord.join(context.getSessionVariable().getQueryTimeoutS()); + boolean notTimeout = coord.join(context.getSessionVariable().getQueryTimeoutS()); if (!coord.isDone()) { coord.cancel(); - ErrorReport.reportDdlException(ErrorCode.ERR_EXECUTE_TIMEOUT); + if (notTimeout) { + errMsg = coord.getExecStatus().getErrorMsg(); + ErrorReport.reportDdlException("There exists unhealthy backend. " + errMsg, ErrorCode.ERR_FAILED_WHEN_INSERT); + } else { + ErrorReport.reportDdlException(ErrorCode.ERR_EXECUTE_TIMEOUT); + } } if (!coord.getExecStatus().ok()) {