From 0be1858b4be796550bbd05ef7054a90b4edcacc1 Mon Sep 17 00:00:00 2001
From: yihaoDeng <luomoxyz@126.com>
Date: Mon, 29 May 2023 01:50:43 +0000
Subject: [PATCH] Merge branch 'enh/dev3.0' into enh/addCompileError

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

diff --git a/source/libs/stream/src/streamBackendRocksdb.c b/source/libs/stream/src/streamBackendRocksdb.c
index b1a6eba42f..793575f59a 100644
--- a/source/libs/stream/src/streamBackendRocksdb.c
+++ b/source/libs/stream/src/streamBackendRocksdb.c
@@ -749,6 +749,7 @@ int32_t streamStateOpenBackendCf(void* backend, char* name, char** cfs, int32_t
     RocksdbCfInst* inst = *pIter;
     SCfComparator  compare = {.comp = inst->pCompares, .numOfComp = cfLen};
     inst->pCompareNode = streamBackendAddCompare(handle, &compare);
+    pIter = taosHashIterate(handle->cfInst, pIter);
   }
 
   taosMemoryFree(cfHandle);