From 6f4fb506a0efccc66a69f181616b1214c23c7a09 Mon Sep 17 00:00:00 2001
From: yihaoDeng <yhdeng@taosdata.com>
Date: Sat, 16 Dec 2023 17:43:41 +0800
Subject: [PATCH] fix stream backend crash when transfer

---
 source/libs/stream/src/streamBackendRocksdb.c | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/source/libs/stream/src/streamBackendRocksdb.c b/source/libs/stream/src/streamBackendRocksdb.c
index 630650025d..1bc402ef6c 100644
--- a/source/libs/stream/src/streamBackendRocksdb.c
+++ b/source/libs/stream/src/streamBackendRocksdb.c
@@ -2289,7 +2289,10 @@ int streamStateGetCfIdx(SStreamState* pState, const char* funcName) {
     }
   }
   if (pState != NULL && idx != -1) {
-    STaskDbWrapper*                 wrapper = pState->pTdbState->pOwner->pBackend;
+    STaskDbWrapper* wrapper = pState->pTdbState->pOwner->pBackend;
+    if (wrapper == NULL) {
+      return -1;
+    }
     rocksdb_column_family_handle_t* cf = NULL;
 
     taosThreadMutexLock(&wrapper->mutex);