fix(query): set correct result ptr check.
This commit is contained in:
parent
adca73d237
commit
21f60d1784
|
@ -879,8 +879,10 @@ static int32_t seqJoinLaunchNewRetrieve(SOperatorInfo* pOperator, SSDataBlock**
|
|||
}
|
||||
|
||||
static FORCE_INLINE void seqStableJoinComposeRes(SStbJoinDynCtrlInfo* pStbJoin, SSDataBlock* pBlock) {
|
||||
if (pBlock != NULL) {
|
||||
pBlock->info.id.blockId = pStbJoin->outputBlkId;
|
||||
}
|
||||
}
|
||||
|
||||
int32_t seqStableJoin(SOperatorInfo* pOperator, SSDataBlock** pRes) {
|
||||
int32_t code = TSDB_CODE_SUCCESS;
|
||||
|
@ -906,7 +908,7 @@ int32_t seqStableJoin(SOperatorInfo* pOperator, SSDataBlock** pRes) {
|
|||
}
|
||||
|
||||
QRY_ERR_JRET(seqJoinContinueCurrRetrieve(pOperator, pRes));
|
||||
if (pRes) {
|
||||
if (*pRes) {
|
||||
goto _return;
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue