From 4ce8f84e7e9f8a0ed7a1a255df6a24bd67b57118 Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Sat, 25 Jul 2020 10:27:27 +0800
Subject: [PATCH] [td-225] fix bugs in non-blocking processing.

---
 src/query/src/qExecutor.c | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/src/query/src/qExecutor.c b/src/query/src/qExecutor.c
index 6de300400e..28d1c138f6 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) {
-- 
GitLab