Merge branch 'enh/dev3.0' into enh/addCompileError

de739ce0 · dengyihao · 2f5fe2de · de739ce0
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

source/libs/stream/src/streamBackendRocksdb.c source/libs/stream/src/streamBackendRocksdb.c +1 -1

未找到文件。
--- 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];