From d9b3c638c3a2a7c5e299793faa1c57b8c3c9ced4 Mon Sep 17 00:00:00 2001
From: wangmm0220 <wangmm0220@gmail.com>
Date: Wed, 29 Mar 2023 21:03:39 +0800
Subject: [PATCH] fix:add assert for debug

---
 source/common/src/tdataformat.c        | 3 +++
 source/libs/parser/src/parInsertUtil.c | 6 ++++++
 2 files changed, 9 insertions(+)

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;
         }