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

fix stream backend crash when transfer

This commit is contained in:
yihaoDeng 2023-12-16 18:03:32 +08:00
parent 6f4fb506a0
commit 5aa575acfa
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
source/libs/stream/src/streamBackendRocksdb.c
View File

@ -2293,11 +2293,10 @@ int streamStateGetCfIdx(SStreamState* pState, const char* funcName) {
if (wrapper == NULL) { if (wrapper == NULL) {
return -1; return -1;
} }
rocksdb_column_family_handle_t* cf = NULL;
taosThreadMutexLock(&wrapper->mutex); taosThreadMutexLock(&wrapper->mutex);
cf = wrapper->pCf[idx]; rocksdb_column_family_handle_t* cf = wrapper->pCf[idx];
if (cf == NULL) { if (cf == NULL) {
char* err = NULL; char* err = NULL;
cf = rocksdb_create_column_family(wrapper->db, wrapper->pCfOpts[idx], ginitDict[idx].key, &err); cf = rocksdb_create_column_family(wrapper->db, wrapper->pCfOpts[idx], ginitDict[idx].key, &err);