From 6319cb8dd49fedbd70c59e5f279a753b3adb96d2 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Thu, 27 Jul 2023 17:16:45 +0800 Subject: [PATCH] fix: fix syntax error. --- source/libs/stream/src/streamBackendRocksdb.c | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/source/libs/stream/src/streamBackendRocksdb.c b/source/libs/stream/src/streamBackendRocksdb.c index 9343e967b1..2636355692 100644 --- a/source/libs/stream/src/streamBackendRocksdb.c +++ b/source/libs/stream/src/streamBackendRocksdb.c @@ -1066,15 +1066,12 @@ rocksdb_iterator_t* streamStateIterCreate(SStreamState* pState, const char* cfNa rocksdb_readoptions_t** readOpt) { int idx = streamStateGetCfIdx(pState, cfName); - SBackendCfWrapper* wrapper = pState->pTdbState->pBackendCfWrapper; - if (snapshot != NULL) { - *snapshot = (rocksdb_snapshot_t*)rocksdb_create_snapshot(wrapper->rocksdb); - } rocksdb_readoptions_t* rOpt = rocksdb_readoptions_create(); *readOpt = rOpt; + SBackendCfWrapper* wrapper = pState->pTdbState->pBackendCfWrapper; if (snapshot != NULL) { - *snapshot = (rocksdb_snapshot_t*)rocksdb_create_snapshot(pState->pTdbState->rocksdb); + *snapshot = (rocksdb_snapshot_t*)rocksdb_create_snapshot(wrapper->rocksdb); rocksdb_readoptions_set_snapshot(rOpt, *snapshot); rocksdb_readoptions_set_fill_cache(rOpt, 0); } -- GitLab