From 8045d2bda75c1e3c806e5e2c331a1e11633762b3 Mon Sep 17 00:00:00 2001
From: yihaoDeng <yhdeng@taosdata.com>
Date: Sat, 16 Dec 2023 15:20:38 +0800
Subject: [PATCH] fix stream backend crash when transfer

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

diff --git a/source/libs/stream/src/streamBackendRocksdb.c b/source/libs/stream/src/streamBackendRocksdb.c
index 65e524d9d8..5d2c7ec504 100644
--- a/source/libs/stream/src/streamBackendRocksdb.c
+++ b/source/libs/stream/src/streamBackendRocksdb.c
@@ -1814,6 +1814,8 @@ STaskDbWrapper* taskDbOpen(char* path, char* key, int64_t chkpId) {
 
 void taskDbDestroy(void* pDb, bool flush) {
   STaskDbWrapper* wrapper = pDb;
+  if (wrapper == NULL) return;
+
   streamMetaRemoveDB(wrapper->pMeta, wrapper->idstr);
 
   qDebug("succ to destroy stream backend:%p", wrapper);