diff --git a/source/libs/stream/src/streamBackendRocksdb.c b/source/libs/stream/src/streamBackendRocksdb.c
index 37dd7f6297..c9538f0b2a 100644
--- a/source/libs/stream/src/streamBackendRocksdb.c
+++ b/source/libs/stream/src/streamBackendRocksdb.c
@@ -779,7 +779,6 @@ int streamStateOpenBackend(void* backend, SStreamState* pState) {
     return 0;
   }
   taosThreadMutexUnlock(&handle->cfMutex);
-  return 0;
 
   char* err = NULL;
   int   cfLen = sizeof(ginitDict) / sizeof(ginitDict[0]);