diff --git a/src/tsdb/src/tsdbRead.c b/src/tsdb/src/tsdbRead.c
index 14cb05219665d6cf20efe56fb086fafe5869f9c2..4efcd4737d0e5335e0130de3fc6cbb0d64fb95ef 100644
--- a/src/tsdb/src/tsdbRead.c
+++ b/src/tsdb/src/tsdbRead.c
@@ -1063,7 +1063,7 @@ static int tsdbReadRowsFromCache(SSkipListIterator* pIter, STable* pTable, TSKEY
         void *value = tdGetRowDataOfCol(row, pColInfo->info.type, TD_DATA_ROW_HEAD_SIZE + offset);
         memcpy(pData, value, varDataTLen(value));
   
-        offset += sizeof(int16_t);
+        offset += sizeof(int32_t);
       } else {
         memcpy(pData, dataRowTuple(row) + offset, pColInfo->info.bytes);
         offset += pColInfo->info.bytes;