From bf3b2e8dde1de6dde43c4ae74d02c3b91e47f22a Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Sun, 28 Jul 2024 01:26:47 +0800
Subject: [PATCH] fix(query): fix error.

---
 source/libs/executor/src/mergejoin.c | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/source/libs/executor/src/mergejoin.c b/source/libs/executor/src/mergejoin.c
index 7bab656e1b..e59010f27f 100755
--- a/source/libs/executor/src/mergejoin.c
+++ b/source/libs/executor/src/mergejoin.c
@@ -2837,11 +2837,12 @@ static int32_t mWinJoinCloneCacheBlk(SMJoinWindowCtx* pCtx) {
 
   if (!pGrp->clonedBlk) {
     if (0 == pGrp->beginIdx) {
-      pGrp->blk = NULL;
-      int32_t code = createOneDataBlock(pGrp->blk, true, &pGrp->blk);
+      SSDataBlock* p = NULL;
+      int32_t code = createOneDataBlock(pGrp->blk, true, &p);
       if (code) {
         MJ_ERR_RET(code);
       }
+      pGrp->blk = p;
     } else {
       pGrp->blk = blockDataExtractBlock(pGrp->blk, pGrp->beginIdx, pGrp->blk->info.rows - pGrp->beginIdx);
       pGrp->endIdx -= pGrp->beginIdx;