fix(stream): fix memory leaks.
This commit is contained in:
parent
b6eb739ae0
commit
12986ff594
|
@ -415,6 +415,7 @@ static int32_t streamTransferStateToStreamTask(SStreamTask* pTask) {
|
||||||
// free it and remove it from disk meta-store
|
// free it and remove it from disk meta-store
|
||||||
streamMetaUnregisterTask(pMeta, pTask->id.taskId);
|
streamMetaUnregisterTask(pMeta, pTask->id.taskId);
|
||||||
streamMetaRemoveTask(pMeta, taskId);
|
streamMetaRemoveTask(pMeta, taskId);
|
||||||
|
streamMetaReleaseTask(pMeta, pTask);
|
||||||
|
|
||||||
// save to disk
|
// save to disk
|
||||||
taosWLockLatch(&pMeta->lock);
|
taosWLockLatch(&pMeta->lock);
|
||||||
|
|
Loading…
Reference in New Issue