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;
   }