Merge branch 'enh/dev3.0' into enh/addCompileError

2023-05-29 01:50:43 +00:00 · 2023-05-29 01:50:43 +00:00 · 0be1858b4b
parent de739ce086
commit 0be1858b4b
1 changed files with 1 additions and 0 deletions
--- 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);