diff --git a/source/common/src/tdataformat.c b/source/common/src/tdataformat.c
index 34808aa389..9632750a18 100644
--- a/source/common/src/tdataformat.c
+++ b/source/common/src/tdataformat.c
@@ -2453,6 +2453,9 @@ int32_t tColDataAddValueByDataBlock(SColData *pColData, int8_t type, int32_t byt
         code = tColDataAppendValueImpl[pColData->flag][CV_FLAG_NULL](pColData, NULL, 0);
         if (code) goto _exit;
       } else {
+        if(ASSERT(varDataTLen(data + offset) <= bytes)){
+          uError("var data length invalid, varDataTLen(data + offset):%d <= bytes:%d", (int)varDataTLen(data + offset), bytes);
+        }
         code = tColDataAppendValueImpl[pColData->flag][CV_FLAG_VALUE](pColData, (uint8_t *)varDataVal(data + offset),
                                                                       varDataLen(data + offset));
       }
diff --git a/source/libs/parser/src/parInsertUtil.c b/source/libs/parser/src/parInsertUtil.c
index 132a3b2618..bbe36e0c80 100644
--- a/source/libs/parser/src/parInsertUtil.c
+++ b/source/libs/parser/src/parInsertUtil.c
@@ -656,6 +656,9 @@ int rawBlockBindData(SQuery* query, STableMeta* pTableMeta, void* data, SVCreate
       } else {
         pStart += colLength[j];
       }
+      if(ASSERT(pCol->nVal == numOfRows)){
+        uError("tFields is null, pCol->nVal:%d != numOfRows:%d", pCol->nVal, numOfRows);
+      }
     }
   }else{
     for (int i = 0; i < numFields; i++) {
@@ -684,6 +687,9 @@ int rawBlockBindData(SQuery* query, STableMeta* pTableMeta, void* data, SVCreate
           } else {
             pStart += colLength[i];
           }
+          if(ASSERT(pCol->nVal == numOfRows)){
+            uError("tFields is not null, pCol->nVal:%d != numOfRows:%d", pCol->nVal, numOfRows);
+          }
           boundInfo->pColIndex[j] = -1;
           break;
         }