From 03f80fbe3635e73af3891a6a9f1732cc02a3821c Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Wed, 29 Mar 2023 07:28:34 +0000 Subject: [PATCH] add backend --- source/libs/stream/src/streamStateRocksdb.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/libs/stream/src/streamStateRocksdb.c b/source/libs/stream/src/streamStateRocksdb.c index fc354952a9..31868bd4a2 100644 --- a/source/libs/stream/src/streamStateRocksdb.c +++ b/source/libs/stream/src/streamStateRocksdb.c @@ -587,7 +587,7 @@ int32_t streamStateClear_rocksdb(SStreamState* pState) { char* err = NULL; rocksdb_delete_range_cf(pState->pTdbState->rocksdb, pState->pTdbState->writeOpts, pState->pTdbState->pHandle[0], sKeyStr, sLen, eKeyStr, eLen, &err); - rocksdb_compact_range_cf(pState->pTdbState->rocksdb, pState->pTdbState->pHandle[0], sKeyStr, sLen, eKeyStr, eLen); + // rocksdb_compact_range_cf(pState->pTdbState->rocksdb, pState->pTdbState->pHandle[0], sKeyStr, sLen, eKeyStr, eLen); if (err != NULL) { qWarn("failed to delete range cf(default) err: %s, start: %s, end:%s", err, toStringStart, toStringEnd); taosMemoryFree(err);