fix(stream): fix memory leak.

7f3d1dc4 · Haojun Liao · fbb33be8 · 7f3d1dc4
显示空白变更内容
内联并排

Showing with 1 addition and 0 deletion

source/dnode/vnode/src/tq/tq.c source/dnode/vnode/src/tq/tq.c +1 -0

未找到文件。
--- a/source/dnode/vnode/src/tq/tq.c
+++ b/source/dnode/vnode/src/tq/tq.c
@@ -1179,6 +1179,7 @@ int32_t tqProcessTaskScanHistory(STQ* pTq, SRpcMsg* pMsg) {
    if (done) {
      pTask->tsInfo.step2Start = taosGetTimestampMs();
      streamTaskEndScanWAL(pTask);
+      streamMetaReleaseTask(pMeta, pTask);
    } else {
      if (!streamTaskRecoverScanStep1Finished(pTask)) {
        STimeWindow* pWindow = &pTask->dataRange.window;