From e3002f1872e60159a7cf7f0a78cca7d56c048c3f Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Wed, 29 Mar 2023 06:17:38 +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 837255119b..82a2702e6c 100644 --- a/source/libs/stream/src/streamStateRocksdb.c +++ b/source/libs/stream/src/streamStateRocksdb.c @@ -563,7 +563,6 @@ int32_t streamStateFillDel_rocksdb(SStreamState* pState, const SWinKey* key) { } // todo refactor - int32_t streamStateClear_rocksdb(SStreamState* pState) { qDebug("streamStateClear_rocksdb"); @@ -585,6 +584,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); if (err != NULL) { qWarn("failed to delete range cf(default) err: %s, start: %s, end:%s", err, toStringStart, toStringEnd); taosMemoryFree(err);