fix(stream): coverity scan

2022-10-20 11:41:20 +08:00 · 2022-10-20 11:41:20 +08:00 · 86a858e04d
parent ef6ba5b9ac
commit 86a858e04d
1 changed files with 1 additions and 0 deletions
--- a/source/libs/stream/src/streamMeta.c
+++ b/source/libs/stream/src/streamMeta.c
@ -253,6 +253,7 @@ int32_t streamLoadTasks(SStreamMeta* pMeta) {
    if (pTask == NULL) {
      tdbFree(pKey);
      tdbFree(pVal);
+      tdbTbcClose(pCur);
      return -1;
    }
    tDecoderInit(&decoder, (uint8_t*)pVal, vLen);