From 54f3bc2543fb4a8c1e752c1d33d6110ea1923f8c Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Fri, 21 Apr 2023 10:06:37 +0000 Subject: [PATCH] change write opt --- contrib/CMakeLists.txt | 5 +++++ source/libs/stream/src/streamStateRocksdb.c | 2 +- 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/contrib/CMakeLists.txt b/contrib/CMakeLists.txt index f0d3397334..4013957026 100644 --- a/contrib/CMakeLists.txt +++ b/contrib/CMakeLists.txt @@ -241,6 +241,11 @@ if(${BUILD_WITH_ROCKSDB}) option(WITH_IOSTATS_CONTEXT "" OFF) option(WITH_PERF_CONTEXT "" OFF) endif(${TD_DARWIN}) + + if(${TD_WINDOWS}) + option(WITH_JNI "" ON) + endif(${TD_WINDOWS}) + option(WITH_JEMALLOC "" OFF) option(WITH_GFLAGS "" OFF) diff --git a/source/libs/stream/src/streamStateRocksdb.c b/source/libs/stream/src/streamStateRocksdb.c index 891fed8f27..8e4400e644 100644 --- a/source/libs/stream/src/streamStateRocksdb.c +++ b/source/libs/stream/src/streamStateRocksdb.c @@ -840,7 +840,7 @@ int32_t streamStateClear_rocksdb(SStreamState* pState) { } char* err = NULL; - rocksdb_delete_range_cf(pState->pTdbState->rocksdb, pState->pTdbState->writeOpts, pState->pTdbState->pHandle[0], + 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) { -- GitLab