diff --git a/contrib/CMakeLists.txt b/contrib/CMakeLists.txt
index f0d3397334e771a8bc9db8d4fc0214e6a2e9cbb4..4013957026168e24844be51aa303d71edc940286 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 891fed8f27483385ce9a30e09ac56876cc1ee8d9..8e4400e6448ebbd5b04550e40b992baf70fcd533 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) {