fix(stream):fix memory leak.

This commit is contained in:
Haojun Liao 2024-08-17 23:23:18 +08:00
parent 0d3d0730d4
commit 89eaf01621
1 changed files with 2 additions and 2 deletions

View File

@ -314,8 +314,8 @@ int32_t streamMetaInitStartInfo(STaskStartInfo* pStartInfo) {
}
void streamMetaClearStartInfo(STaskStartInfo* pStartInfo) {
taosHashClear(pStartInfo->pReadyTaskSet);
taosHashClear(pStartInfo->pFailedTaskSet);
taosHashCleanup(pStartInfo->pReadyTaskSet);
taosHashCleanup(pStartInfo->pFailedTaskSet);
pStartInfo->readyTs = 0;
pStartInfo->elapsedTime = 0;
pStartInfo->startTs = 0;