support fill history

2023-06-16 09:36:44 +08:00 · 2023-06-16 09:36:44 +08:00 · f4b9d630c0
parent 0ef8afbdaa
commit f4b9d630c0
1 changed files with 1 additions and 0 deletions
--- a/source/libs/stream/src/streamBackendRocksdb.c
+++ b/source/libs/stream/src/streamBackendRocksdb.c
@ -997,6 +997,7 @@ void streamStateCloseBackend(SStreamState* pState, bool remove) {
    taosHashRemove(pHandle->cfInst, pState->pTdbState->idstr, strlen(pState->pTdbState->idstr) + 1);
  }
  taosThreadMutexUnlock(&pHandle->cfMutex);
+
  char* status[] = {"close", "drop"};
  qInfo("start to close %s state %p on backendWrapper %p %s", status[remove == false ? 0 : 1], pState, wrapper,
        wrapper->idstr);