From 0304ad88ffba8125df8fc1693084208007e71069 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Tue, 22 Aug 2023 09:49:04 +0800 Subject: [PATCH] fix invalid cmp --- source/libs/stream/src/streamBackendRocksdb.c | 21 ++++++++++--------- 1 file changed, 11 insertions(+), 10 deletions(-) diff --git a/source/libs/stream/src/streamBackendRocksdb.c b/source/libs/stream/src/streamBackendRocksdb.c index 4a2dc5ff2c..c5da5eb213 100644 --- a/source/libs/stream/src/streamBackendRocksdb.c +++ b/source/libs/stream/src/streamBackendRocksdb.c @@ -544,16 +544,16 @@ void streamBackendCleanup(void* arg) { taosHashCleanup(pHandle->cfInst); if (pHandle->db) { - char* err = NULL; - rocksdb_flushoptions_t* flushOpt = rocksdb_flushoptions_create(); - rocksdb_flushoptions_set_wait(flushOpt, 1); - rocksdb_flush(pHandle->db, flushOpt, &err); - - if (err != NULL) { - qError("failed to flush db before streamBackend clean up, reason:%s", err); - taosMemoryFree(err); - } - rocksdb_flushoptions_destroy(flushOpt); + // char* err = NULL; + // rocksdb_flushoptions_t* flushOpt = rocksdb_flushoptions_create(); + // rocksdb_flushoptions_set_wait(flushOpt, 1); + // rocksdb_flush(pHandle->db, flushOpt, &err); + + // if (err != NULL) { + // qError("failed to flush db before streamBackend clean up, reason:%s", err); + // taosMemoryFree(err); + // } + // rocksdb_flushoptions_destroy(flushOpt); rocksdb_close(pHandle->db); } rocksdb_options_destroy(pHandle->dbOpt); @@ -617,6 +617,7 @@ void streamBackendHandleCleanup(void* arg) { } } taosMemoryFreeClear(wrapper->pHandle); + for (int i = 0; i < cfLen; i++) { rocksdb_options_destroy(wrapper->cfOpts[i]); rocksdb_block_based_options_destroy(((RocksdbCfParam*)wrapper->param)[i].tableOpt); -- GitLab