diff --git a/source/libs/stream/src/streamState.c b/source/libs/stream/src/streamState.c
index a368707cb1..32672d7b22 100644
--- a/source/libs/stream/src/streamState.c
+++ b/source/libs/stream/src/streamState.c
@@ -687,8 +687,7 @@ void streamStateResetCur(SStreamStateCur* pCur) {
 }
 
 void streamStateFreeCur(SStreamStateCur* pCur) {
-  if (!pCur || pCur->buffIndex >= 0) {
-    taosMemoryFree(pCur);
+  if (!pCur) {
     return;
   }
   qDebug("streamStateFreeCur");