From de739ce086d1388a7adfc18034760584673ed425 Mon Sep 17 00:00:00 2001
From: yihaoDeng <luomoxyz@126.com>
Date: Mon, 29 May 2023 01:11:13 +0000
Subject: [PATCH] Merge branch 'enh/dev3.0' into enh/addCompileError

---
 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 92ef66cd30..b1a6eba42f 100644
--- a/source/libs/stream/src/streamBackendRocksdb.c
+++ b/source/libs/stream/src/streamBackendRocksdb.c
@@ -910,7 +910,7 @@ int streamGetInit(SStreamState* pState, const char* funcName) {
       break;
     }
   }
-  if (idx != -1) {
+  if (pState != NULL && idx != -1) {
     rocksdb_column_family_handle_t* cf = NULL;
     taosThreadRwlockRdlock(&pState->pTdbState->rwLock);
     cf = pState->pTdbState->pHandle[idx];