From b6d4e98e68a8569f98345f8241032546b13888ad Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Tue, 20 Jun 2023 13:47:46 +0800 Subject: [PATCH] fix restart crash --- source/libs/stream/src/streamBackendRocksdb.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/libs/stream/src/streamBackendRocksdb.c b/source/libs/stream/src/streamBackendRocksdb.c index 151edbdaf0..4646af641f 100644 --- a/source/libs/stream/src/streamBackendRocksdb.c +++ b/source/libs/stream/src/streamBackendRocksdb.c @@ -1026,8 +1026,8 @@ int streamStateGetCfIdx(SStreamState* pState, const char* funcName) { break; } } - SBackendCfWrapper* wrapper = pState->pTdbState->pBackendCfWrapper; if (pState != NULL && idx != -1) { + SBackendCfWrapper* wrapper = pState->pTdbState->pBackendCfWrapper; rocksdb_column_family_handle_t* cf = NULL; taosThreadRwlockRdlock(&wrapper->rwLock); cf = wrapper->pHandle[idx];