diff --git a/src/query/src/qTsbuf.c b/src/query/src/qTsbuf.c
index e6c882d0cdf496562a3317d445863afd65b02418..408dcc9881e18ec733525d33b3a938f8735f8e16 100644
--- a/src/query/src/qTsbuf.c
+++ b/src/query/src/qTsbuf.c
@@ -493,6 +493,10 @@ void tsBufAppend(STSBuf* pTSBuf, int32_t id, tVariant* tag, const char* pData, i
 }
 
 void tsBufFlush(STSBuf* pTSBuf) {
+  if (pTSBuf->numOfGroups <= 0) {
+    return;
+  }
+
   writeDataToDisk(pTSBuf);
   shrinkBuffer(&pTSBuf->tsData);