From 8cb8c05428bcb9e60911efe2d1c0aae0485c067d Mon Sep 17 00:00:00 2001
From: yihaoDeng <cyang@taosdata.com>
Date: Thu, 15 Jun 2023 21:55:46 +0800
Subject: [PATCH] support fill history

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

diff --git a/source/libs/stream/src/streamBackendRocksdb.c b/source/libs/stream/src/streamBackendRocksdb.c
index e5aa08edaf..4697c5b130 100644
--- a/source/libs/stream/src/streamBackendRocksdb.c
+++ b/source/libs/stream/src/streamBackendRocksdb.c
@@ -254,7 +254,6 @@ void streamBackendCleanup(void* arg) {
 }
 void streamBackendHandleCleanup(void* arg) {
   SBackendWrapper* wrapper = arg;
-  bool             remove = false;
 
   qDebug("start to do-close backendwrapper %p, %s", wrapper, wrapper->idstr);
   if (wrapper->rocksdb == NULL) {
@@ -296,7 +295,7 @@ void streamBackendHandleCleanup(void* arg) {
     rocksdb_block_based_options_destroy(((RocksdbCfParam*)wrapper->param)[i].tableOpt);
   }
 
-  if (remove) {
+  if (wrapper->remove) {
     streamBackendDelCompare(wrapper->pBackend, wrapper->pComparNode);
   }
   rocksdb_writeoptions_destroy(wrapper->writeOpts);
@@ -1001,6 +1000,7 @@ void streamStateCloseBackend(SStreamState* pState, bool remove) {
   char* status[] = {"close", "drop"};
   qInfo("start to close %s state %p on backendWrapper %p %s", status[remove == false ? 0 : 1], pState, wrapper,
         wrapper->idstr);
+  wrapper->remove |= remove;  // update by other pState
   taosReleaseRef(streamBackendWrapperId, pState->pTdbState->backendWrapperId);
 }
 void streamStateDestroyCompar(void* arg) {