diff --git a/source/common/src/tdataformat.c b/source/common/src/tdataformat.c
index 763c791269..6f0082aa6d 100644
--- a/source/common/src/tdataformat.c
+++ b/source/common/src/tdataformat.c
@@ -97,7 +97,7 @@ int32_t tRowBuild(SArray *aColVal, STSchema *pTSchema, SBuffer *pBuffer) {
             ntp = ntp + tPutU32v(NULL, pColVal->value.nData) + pColVal->value.nData;
             nkv = nkv + tPutI16v(NULL, pTColumn->colId) + tPutU32v(NULL, pColVal->value.nData) + pColVal->value.nData;
           } else {
-            nkv = nkv + tPutI16v(NULL, pTColumn->colId) + TYPE_BYTES[pTColumn->type];
+            nkv = nkv + tPutI16v(NULL, pTColumn->colId) + pTColumn->bytes;
           }
           nIdx++;
         } else if (COL_VAL_IS_NONE(pColVal)) {  // NONE