From 21f60d17849db897ddd479eb356bc4a8288ce621 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Wed, 28 Aug 2024 10:52:14 +0800 Subject: [PATCH] fix(query): set correct result ptr check. --- source/libs/executor/src/dynqueryctrloperator.c | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/source/libs/executor/src/dynqueryctrloperator.c b/source/libs/executor/src/dynqueryctrloperator.c index f0efa76639..a75bfb8f4b 100644 --- a/source/libs/executor/src/dynqueryctrloperator.c +++ b/source/libs/executor/src/dynqueryctrloperator.c @@ -879,7 +879,9 @@ static int32_t seqJoinLaunchNewRetrieve(SOperatorInfo* pOperator, SSDataBlock** } static FORCE_INLINE void seqStableJoinComposeRes(SStbJoinDynCtrlInfo* pStbJoin, SSDataBlock* pBlock) { - pBlock->info.id.blockId = pStbJoin->outputBlkId; + if (pBlock != NULL) { + pBlock->info.id.blockId = pStbJoin->outputBlkId; + } } int32_t seqStableJoin(SOperatorInfo* pOperator, SSDataBlock** pRes) { @@ -906,7 +908,7 @@ int32_t seqStableJoin(SOperatorInfo* pOperator, SSDataBlock** pRes) { } QRY_ERR_JRET(seqJoinContinueCurrRetrieve(pOperator, pRes)); - if (pRes) { + if (*pRes) { goto _return; }