diff --git a/source/libs/stream/src/streamBackendRocksdb.c b/source/libs/stream/src/streamBackendRocksdb.c
index b1a6eba42f51cc65f1bb899616732226ff4e56ab..793575f59a991d60059efbb097dce0b419bed6da 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);