diff --git a/source/common/src/tdataformat.c b/source/common/src/tdataformat.c
index 0c4c60db07..04ad00e1dc 100644
--- a/source/common/src/tdataformat.c
+++ b/source/common/src/tdataformat.c
@@ -2450,7 +2450,7 @@ static int32_t tColDataUpdateValue72(SColData *pColData, uint8_t *pData, uint32_
     pColData->numOfValue--;
     pColData->nVal--;
     if (pColData->numOfValue) {
-      if (IS_STR_DATA_TYPE(pColData->type)) {
+      if (IS_VAR_DATA_TYPE(pColData->type)) {
         pColData->nData = pColData->aOffset[pColData->nVal];
       } else {
         pColData->nData -= TYPE_BYTES[pColData->type];
diff --git a/source/dnode/vnode/src/tq/tqRead.c b/source/dnode/vnode/src/tq/tqRead.c
index 0bb82ed50a..516a47606b 100644
--- a/source/dnode/vnode/src/tq/tqRead.c
+++ b/source/dnode/vnode/src/tq/tqRead.c
@@ -592,7 +592,7 @@ static int32_t buildResSDataBlock(SSDataBlock* pBlock, SSchemaWrapper* pSchema,
 static int32_t doSetVal(SColumnInfoData* pColumnInfoData, int32_t rowIndex, SColVal* pColVal) {
   int32_t code = TSDB_CODE_SUCCESS;
 
-  if (IS_STR_DATA_TYPE(pColVal->value.type)) {
+  if (IS_VAR_DATA_TYPE(pColVal->value.type)) {
     char val[65535 + 2] = {0};
     if (COL_VAL_IS_VALUE(pColVal)) {
       if (pColVal->value.pData != NULL) {
diff --git a/source/dnode/vnode/src/tq/tqSink.c b/source/dnode/vnode/src/tq/tqSink.c
index f7003ca41b..15538b61e3 100644
--- a/source/dnode/vnode/src/tq/tqSink.c
+++ b/source/dnode/vnode/src/tq/tqSink.c
@@ -604,7 +604,7 @@ int32_t doConvertRows(SSubmitTbData* pTableData, const STSchema* pTSchema, SSDat
           dataIndex++;
         } else {
           void* colData = colDataGetData(pColData, j);
-          if (IS_STR_DATA_TYPE(pCol->type)) {
+          if (IS_VAR_DATA_TYPE(pCol->type)) {
             // address copy, no value
             SValue sv =
                 (SValue){.type = pCol->type, .nData = varDataLen(colData), .pData = (uint8_t*)varDataVal(colData)};