fix: cleanup memory with streamLoadTasks

2022-08-26 14:51:30 +08:00 · 2022-08-26 14:51:30 +08:00 · 04e5c75bba
parent a76bbfe062
commit 04e5c75bba
1 changed files with 2 additions and 0 deletions
--- a/source/libs/stream/src/streamMeta.c
+++ b/source/libs/stream/src/streamMeta.c
@ -265,6 +265,8 @@ int32_t streamLoadTasks(SStreamMeta* pMeta) {
    }
  }

+  tdbFree(pKey);
+  tdbFree(pVal);
  if (tdbTbcClose(pCur) < 0) {
    return -1;
  }