diff --git a/source/libs/stream/src/streamStateRocksdb.c b/source/libs/stream/src/streamStateRocksdb.c
index 4f336e8e711821fa43606815bcddd446217ac9ca..b51e0fd8113a755e5607d9d48938cee336563127 100644
--- a/source/libs/stream/src/streamStateRocksdb.c
+++ b/source/libs/stream/src/streamStateRocksdb.c
@@ -431,6 +431,7 @@ int streamStateOpenBackend(void* backend, SStreamState* pState) {
   // pState->pTdbState->pCompare = pCompare;
   pState->pTdbState->dbOpt = handle->dbOpt;
   pState->pTdbState->param = param;
+  pState->pTdbState->pBackendHandle = handle;
 
   SCfComparator compare = {.comp = pCompare, .numOfComp = cfLen};
   pState->pTdbState->pComparNode = streamBackendAddCompare(handle, &compare);