From cc1eb2769f036f3f23e8f32fb81b34a0fe5f193b Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Tue, 28 Nov 2023 20:29:42 +0800 Subject: [PATCH] fix crash while quit --- source/libs/stream/src/streamBackendRocksdb.c | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/source/libs/stream/src/streamBackendRocksdb.c b/source/libs/stream/src/streamBackendRocksdb.c index ccf166c390..19247166b3 100644 --- a/source/libs/stream/src/streamBackendRocksdb.c +++ b/source/libs/stream/src/streamBackendRocksdb.c @@ -1844,6 +1844,9 @@ void taskDbDestroy(void* pDb, bool flush) { rocksdb_column_family_handle_destroy(wrapper->pCf[i]); } } + + if (wrapper->db) rocksdb_close(wrapper->db); + rocksdb_options_destroy(wrapper->dbOpt); rocksdb_readoptions_destroy(wrapper->readOpt); rocksdb_writeoptions_destroy(wrapper->writeOpt); @@ -1851,7 +1854,6 @@ void taskDbDestroy(void* pDb, bool flush) { rocksdb_cache_destroy(wrapper->cache); taosMemoryFree(wrapper->pCf); - for (int i = 0; i < nCf; i++) { rocksdb_options_t* opt = wrapper->pCfOpts[i]; rocksdb_comparator_t* compare = wrapper->pCompares[i]; @@ -1867,8 +1869,6 @@ void taskDbDestroy(void* pDb, bool flush) { taosThreadMutexDestroy(&wrapper->mutex); - if (wrapper->db) rocksdb_close(wrapper->db); - taskDbDestroyChkpOpt(wrapper); taosMemoryFree(wrapper->idstr);