diff --git a/source/libs/stream/src/streamBackendRocksdb.c b/source/libs/stream/src/streamBackendRocksdb.c
index 6ca47c8616..f07ef71003 100644
--- a/source/libs/stream/src/streamBackendRocksdb.c
+++ b/source/libs/stream/src/streamBackendRocksdb.c
@@ -190,6 +190,7 @@ int32_t getCfIdx(const char* cfName) {
 }
 
 bool isValidCheckpoint(const char* dir) {
+  return true;
   STaskDbWrapper* pDb = taskDbOpenImpl(NULL, NULL, (char*)dir);
   if (pDb == NULL) {
     return true;