diff --git a/source/libs/stream/src/streamTask.c b/source/libs/stream/src/streamTask.c index ff9688e3d6..fc72489ee6 100644 --- a/source/libs/stream/src/streamTask.c +++ b/source/libs/stream/src/streamTask.c @@ -315,7 +315,6 @@ void streamFreeTaskState(SStreamTask* pTask, int8_t remove) { streamStateClose(pTask->pState, remove); if (remove) taskDbSetClearFileFlag(pTask->pBackend); - taskDbRemoveRef(pTask->pBackend); pTask->pBackend = NULL; pTask->pState = NULL;