diff --git a/src/query/src/qExecutor.c b/src/query/src/qExecutor.c
index 6de300400e53de5e0f517bd814700527ab2a187f..28d1c138f61cfa1c9b395bfc845ec2a6052094bc 100644
--- a/src/query/src/qExecutor.c
+++ b/src/query/src/qExecutor.c
@@ -6380,6 +6380,8 @@ int32_t qRetrieveQueryResultInfo(qinfo_t qinfo, bool* buildRes, void* pRspContex
   }
 
   *buildRes = false;
+  int32_t code = TSDB_CODE_SUCCESS;
+
   pthread_mutex_lock(&pQInfo->lock);
   if (pQInfo->dataReady == QUERY_RESULT_READY) {
     *buildRes = true;
@@ -6391,8 +6393,9 @@ int32_t qRetrieveQueryResultInfo(qinfo_t qinfo, bool* buildRes, void* pRspContex
     pQInfo->rspContext = pRspContext;
   }
 
+  code = pQInfo->code;
   pthread_mutex_unlock(&pQInfo->lock);
-  return pQInfo->code;
+  return code;
 }
 
 bool qHasMoreResultsToRetrieve(qinfo_t qinfo) {