fix invalid free

This commit is contained in:
yihaoDeng 2023-06-06 02:32:06 +00:00
parent c6242fee01
commit 66f483e51a
1 changed files with 3 additions and 0 deletions

View File

@ -89,6 +89,9 @@ SStreamMeta* streamMetaOpen(const char* path, void* ahandle, FTaskExpand expandF
}
pMeta->streamBackend = streamBackendInit(streamPath);
if (pMeta->streamBackend == NULL) {
goto _err;
}
pMeta->streamBackendRid = taosAddRef(streamBackendId, pMeta->streamBackend);
taosMemoryFree(streamPath);