diff --git a/src/client/src/tscLocalMerge.c b/src/client/src/tscLocalMerge.c
index db85b7a5e563f9f6a8719c0985057500ee7f6bd1..fba685e7039c0727d559b1f58833e483d562ec31 100644
--- a/src/client/src/tscLocalMerge.c
+++ b/src/client/src/tscLocalMerge.c
@@ -316,6 +316,7 @@ void tscCreateLocalReducer(tExtMemBuffer **pMemBuffer, int32_t numOfBuffer, tOrd
   pReducer->finalRowSize = tscGetResRowLength(pQueryInfo->exprList);
   pReducer->resColModel = finalmodel;
   pReducer->resColModel->capacity = pReducer->nResultBufSize;
+  assert(pReducer->finalRowSize > 0);
   if (pReducer->finalRowSize > 0) {
     pReducer->resColModel->capacity /= pReducer->finalRowSize;
   }
diff --git a/src/client/src/tscSubquery.c b/src/client/src/tscSubquery.c
index 32b8129d025a47330833d2b160f3e34821551e8c..6e94fd563523356d11d881977ce1bc36f667c0f0 100644
--- a/src/client/src/tscSubquery.c
+++ b/src/client/src/tscSubquery.c
@@ -936,6 +936,7 @@ static SJoinSupporter* tscUpdateSubqueryStatus(SSqlObj* pSql, int32_t numOfFetch
     }
   }
   
+  assert(pState != NULL);
   if (pState != NULL) {
     pState->numOfTotal = pSql->numOfSubs;
     pState->numOfRemain = numOfFetch;