From 984a69671edfb1640fc5e22b82a4aa5db639ffcd Mon Sep 17 00:00:00 2001
From: yihaoDeng <luomoxyz@126.com>
Date: Thu, 27 Apr 2023 14:46:33 +0000
Subject: [PATCH] merge rocksdb inst

---
 source/libs/stream/src/streamStateRocksdb.c | 1 +
 1 file changed, 1 insertion(+)

diff --git a/source/libs/stream/src/streamStateRocksdb.c b/source/libs/stream/src/streamStateRocksdb.c
index 4f336e8e71..b51e0fd811 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);
-- 
GitLab