diff --git a/src/tsdb/src/tsdbRWHelper.c b/src/tsdb/src/tsdbRWHelper.c
index 7bb59dd47f93e4ca6f03d73fd55425a133001f6e..901b817a4c4c1ea7b05288fa7e1e76c94b68aae1 100644
--- a/src/tsdb/src/tsdbRWHelper.c
+++ b/src/tsdb/src/tsdbRWHelper.c
@@ -1541,8 +1541,9 @@ static int tsdbLoadAndMergeFromCache(SDataCols *pDataCols, int *iter, SCommitIte
       if (pSchema == NULL || schemaVersion(pSchema) != dataRowVersion(row)) {
         pSchema = tsdbGetTableSchemaImpl(pCommitIter->pTable, false, false, dataRowVersion(row));
         ASSERT(pSchema != NULL);
-        tdAppendDataRowToDataCol(row, pSchema, pTarget);
       }
+
+      tdAppendDataRowToDataCol(row, pSchema, pTarget);
       tSkipListIterNext(pCommitIter->pIter);
     }