diff --git a/src/query/src/qTsbuf.c b/src/query/src/qTsbuf.c
index eefb0b56a43f97a9bd21e66f1d8d99f7662e3af3..42b6e3f6e082b696b9379352f6d4c788dc1c4977 100644
--- a/src/query/src/qTsbuf.c
+++ b/src/query/src/qTsbuf.c
@@ -400,11 +400,11 @@ void tsBufAppend(STSBuf* pTSBuf, int32_t vnodeId, tVariant* tag, const char* pDa
   if ((tVariantCompare(&pTSBuf->block.tag, tag) != 0) && ptsData->len > 0) {
     // new arrived data with different tags value, save current value into disk first
     writeDataToDisk(pTSBuf);
-    tVariantAssign(&pTSBuf->block.tag, tag);
   } else {
     expandBuffer(ptsData, len);
   }
-  
+
+  tVariantAssign(&pTSBuf->block.tag, tag);
   memcpy(ptsData->rawBuf + ptsData->len, pData, (size_t)len);
   
   // todo check return value