diff --git a/source/libs/stream/src/streamMeta.c b/source/libs/stream/src/streamMeta.c index dc69c392cf..6c5b1ef994 100644 --- a/source/libs/stream/src/streamMeta.c +++ b/source/libs/stream/src/streamMeta.c @@ -395,6 +395,7 @@ SStreamMeta* streamMetaOpen(const char* path, void* ahandle, FTaskExpand expandF pMeta->bkdChkptMgt = bkdMgtCreate(tpath); taosThreadMutexInit(&pMeta->backendMutex, NULL); + return pMeta; _err: