From 2522e9d3b8753274fd6d5f522a0663c963e71d3c Mon Sep 17 00:00:00 2001
From: 54liuyao <54liuyao>
Date: Tue, 23 Jul 2024 11:33:00 +0800
Subject: [PATCH] adj query operator result

---
 source/libs/executor/src/exchangeoperator.c | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/source/libs/executor/src/exchangeoperator.c b/source/libs/executor/src/exchangeoperator.c
index 87b5b3c4ec..421fc562a4 100644
--- a/source/libs/executor/src/exchangeoperator.c
+++ b/source/libs/executor/src/exchangeoperator.c
@@ -337,7 +337,7 @@ static int32_t initExchangeOperator(SExchangePhysiNode* pExNode, SExchangeInfo*
     SExchangeSrcIndex idx = {.srcIdx = i, .inUseIdx = -1};
     int32_t           code =
         tSimpleHashPut(pInfo->pHashSources, &pNode->addr.nodeId, sizeof(pNode->addr.nodeId), &idx, sizeof(idx));
-    if (code != TSDB_CODE_SUCCESS) {
+    if (pInfo->pHashSources && code != TSDB_CODE_SUCCESS) {
       qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(code));
       return code;
     }