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

2f5fe2de · dengyihao · 4b931d30 · 2f5fe2de
隐藏空白更改
内联并排

Showing with 4 addition and 2 deletion

source/libs/stream/src/streamBackendRocksdb.c source/libs/stream/src/streamBackendRocksdb.c +4 -2

未找到文件。
--- a/source/libs/stream/src/streamBackendRocksdb.c
+++ b/source/libs/stream/src/streamBackendRocksdb.c
@@ -1104,8 +1104,10 @@ int32_t streamStateClear_rocksdb(SStreamState* pState) {
  }

  char* err = NULL;
-  rocksdb_delete_range_cf(pState->pTdbState->rocksdb, pState->pTdbState->writeOpts, pState->pTdbState->pHandle[1],
-                          sKeyStr, sLen, eKeyStr, eLen, &err);
+  if (pState->pTdbState->pHandle[1] != NULL) {
+    rocksdb_delete_range_cf(pState->pTdbState->rocksdb, pState->pTdbState->writeOpts, pState->pTdbState->pHandle[1],
+                            sKeyStr, sLen, eKeyStr, eLen, &err);
+  }
  // rocksdb_compact_range_cf(pState->pTdbState->rocksdb, pState->pTdbState->pHandle[0], sKeyStr, sLen, eKeyStr,
  // eLen);
  if (err != NULL) {