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