diff --git 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
index a5f52f2628..8d66fd957b 100644
--- 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) {
diff --git a/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlErrPacketTest.java b/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlErrPacketTest.java
index 0a296a324f..a57e6d669a 100644
--- a/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlErrPacketTest.java
+++ b/fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlErrPacketTest.java
@@ -46,7 +46,7 @@ public class MysqlErrPacketTest {
         // assert indicator
         Assert.assertEquals(0xff, MysqlProto.readInt1(buffer));
         // error code
-        Assert.assertEquals(1064, MysqlProto.readInt2(buffer));
+        Assert.assertEquals(1105, MysqlProto.readInt2(buffer));
         // sql state marker
         Assert.assertEquals('#', MysqlProto.readInt1(buffer));
         // sql state