diff --git a/source/common/src/tdataformat.c b/source/common/src/tdataformat.c
index 9632750a1858a69d906c28738ace7f9f3baa2b83..d6ab974c6ced8305ddad0ebc86f072a08bf9c978 100644
--- a/source/common/src/tdataformat.c
+++ b/source/common/src/tdataformat.c
@@ -2455,6 +2455,8 @@ int32_t tColDataAddValueByDataBlock(SColData *pColData, int8_t type, int32_t byt
       } else {
         if(ASSERT(varDataTLen(data + offset) <= bytes)){
           uError("var data length invalid, varDataTLen(data + offset):%d <= bytes:%d", (int)varDataTLen(data + offset), bytes);
+          code = TSDB_CODE_INVALID_PARA;
+          goto _exit;
         }
         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 bbe36e0c8035820a9e646b076817f4807f4b93ad..132a3b26187a833b5eeb3bd23ab8642331478635 100644
--- a/source/libs/parser/src/parInsertUtil.c
+++ b/source/libs/parser/src/parInsertUtil.c
@@ -656,9 +656,6 @@ 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++) {
@@ -687,9 +684,6 @@ 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;
         }