diff --git a/src/client/src/tscSubquery.c b/src/client/src/tscSubquery.c
index e222c9748cbf1497831fcdf6a702e2b0f05cc5d7..eaae026f06c500d05ce163ff8db8d96d68a8a783 100644
--- a/src/client/src/tscSubquery.c
+++ b/src/client/src/tscSubquery.c
@@ -1911,13 +1911,12 @@ int32_t tscHandleMultivnodeInsert(SSqlObj *pSql) {
   size_t size = taosArrayGetSize(pCmd->pDataBlocks);
   assert(size > 0);
 
+  pSql->numOfSubs = (uint16_t)size;
   pSql->pSubs = calloc(size, POINTER_BYTES);
   if (pSql->pSubs == NULL) {
     goto _error;
   }
 
-  pSql->numOfSubs = (uint16_t)size;
-
   tscDebug("%p submit data to %" PRIzu " vnode(s)", pSql, size);
 
   SSubqueryState *pState = calloc(1, sizeof(SSubqueryState));