reset version

009d5099 · dengyihao · 8387f044 · 009d5099
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

source/libs/stream/src/streamState.c source/libs/stream/src/streamState.c +1 -1

未找到文件。
--- a/source/libs/stream/src/streamState.c
+++ b/source/libs/stream/src/streamState.c
@@ -669,7 +669,7 @@ void streamStateFreeCur(SStreamStateCur* pCur) {
  }
  qDebug("streamStateFreeCur");
  rocksdb_iter_destroy(pCur->iter);
-  rocksdb_release_snapshot(pCur->db, pCur->snapshot);
+  if (pCur->snapshot) rocksdb_release_snapshot(pCur->db, pCur->snapshot);
  rocksdb_readoptions_destroy(pCur->readOpt);

  tdbTbcClose(pCur->pCur);