xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

change write opt

This commit is contained in:
yihaoDeng 2023-04-19 23:46:08 +00:00
parent f48c539011
commit 6ff0b09e5e
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
source/libs/stream/src/streamStateRocksdb.c
View File

@ -438,7 +438,6 @@ void streamCleanBackend(SStreamState* pState) {
pState->pTdbState->readOpts = NULL; pState->pTdbState->readOpts = NULL;
rocksdb_close(pState->pTdbState->rocksdb); rocksdb_close(pState->pTdbState->rocksdb);
rocksdb_env_destroy(pState->pTdbState->env);
for (int i = 0; i < cfLen; i++) { for (int i = 0; i < cfLen; i++) {
// rocksdb_column_family_handle_destroy(pState->pTdbState->pHandle[i]); // rocksdb_column_family_handle_destroy(pState->pTdbState->pHandle[i]);
rocksdb_options_destroy(pState->pTdbState->cfOpts[i]); rocksdb_options_destroy(pState->pTdbState->cfOpts[i]);
@ -450,6 +449,7 @@ void streamCleanBackend(SStreamState* pState) {
taosMemoryFreeClear(pState->pTdbState->cfOpts); taosMemoryFreeClear(pState->pTdbState->cfOpts);
taosMemoryFree(pState->pTdbState->pCompare); taosMemoryFree(pState->pTdbState->pCompare);
taosMemoryFree(pState->pTdbState->param); taosMemoryFree(pState->pTdbState->param);
rocksdb_env_destroy(pState->pTdbState->env);
pState->pTdbState->rocksdb = NULL; pState->pTdbState->rocksdb = NULL;
} }