diff --git a/source/libs/stream/src/streamBackendRocksdb.c b/source/libs/stream/src/streamBackendRocksdb.c
index 437aa143242ded7ff88855f642fbe9d23ebc7974..92ef66cd30ad0710d591a81a939dbdcfe9e8a499 100644
--- 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) {