diff --git a/source/common/src/tdatablock.c b/source/common/src/tdatablock.c
index a47e52b84ce1e64d8d7ca9d01b86390fa99acdf0..a02b5d11dacf8a6dd3f9b128ec3564f5b233c710 100644
--- a/source/common/src/tdatablock.c
+++ b/source/common/src/tdatablock.c
@@ -2246,6 +2246,9 @@ int32_t buildSubmitReqFromDataBlock(SSubmitReq2** ppReq, const SSDataBlock* pDat
       continue;
     }
 
+    // the rsma result should has the same column number with schema.
+    ASSERT(colNum == pTSchema->numOfCols);
+
     SSubmitTbData tbData = {0};
 
     if (!(tbData.aRowP = taosArrayInit(rows, sizeof(SRow*)))) {