[fix](forward) set error code for query state to handle exception of (#31975)

2024-03-08 22:50:17 +08:00
parent 1d094a46ec
commit 78feb7f519
2 changed files with 2 additions and 3 deletions
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/QueryState.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/QueryState.java
@ -93,8 +93,7 @@ public class QueryState {
    }

    public void setError(String errorMsg) {
-        this.stateType = MysqlStateType.ERR;
-        this.errorMessage = errorMsg;
+        this.setError(ErrorCode.ERR_UNKNOWN_ERROR, errorMsg);
    }

    public void setError(ErrorCode code, String msg) {