xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix(stream): avoid repeatly free obj.

This commit is contained in:
Haojun Liao 2023-09-27 14:05:14 +08:00
parent ae020fcd2d
commit 34d547bfff
1 changed files with 0 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
source/libs/stream/src/streamRecover.c
View File

@ -676,7 +676,6 @@ static void tryLaunchHistoryTask(void* param, void* tmrId) {
if (pHTaskInfo->retryTimes > MAX_RETRY_LAUNCH_HISTORY_TASK) { if (pHTaskInfo->retryTimes > MAX_RETRY_LAUNCH_HISTORY_TASK) {
int8_t ref = atomic_sub_fetch_32(&pTask->status.timerActive, 1); int8_t ref = atomic_sub_fetch_32(&pTask->status.timerActive, 1);
taosMemoryFree(pInfo);
streamMetaReleaseTask(pMeta, pTask); streamMetaReleaseTask(pMeta, pTask);
stError("s-task:%s max retry:%d reached, quit from retrying launch related fill-history task timer, ref:%d", stError("s-task:%s max retry:%d reached, quit from retrying launch related fill-history task timer, ref:%d",