fix(stream): fix syntax error.

This commit is contained in:
Haojun Liao 2024-11-05 11:02:41 +08:00
parent 8148f26d30
commit 75f838c4b4
1 changed files with 1 additions and 1 deletions

View File

@ -452,7 +452,7 @@ int32_t streamMetaOpen(const char* path, void* ahandle, FTaskBuild buildTaskFn,
TSDB_CHECK_CODE(code, lino, _err);
// add refId at the end of initialization function
pMeta->rid = taosAddRef(streamMetaId, pMeta);
pMeta->rid = taosAddRef(streamMetaRefPool, pMeta);
int64_t* pRid = taosMemoryMalloc(sizeof(int64_t));
TSDB_CHECK_NULL(pRid, code, lino, _err, terrno);