diff --git a/source/libs/stream/src/tstreamFileState.c b/source/libs/stream/src/tstreamFileState.c
index 9602f1eb1c9f8fcde1efe6908677597991d9bcc5..08c8c16079f5f2709016780e5c7f880b0bedf1d8 100644
--- a/source/libs/stream/src/tstreamFileState.c
+++ b/source/libs/stream/src/tstreamFileState.c
@@ -413,8 +413,8 @@ int32_t recoverSnapshot(SStreamFileState* pFileState) {
     taosMemoryFree(val);
     if (ts < pFileState->flushMark) {
       // forceRemoveCheckPoint(pFileState->pFileStore, i);
-    } else {
       break;
+    } else {
     }
   }