fix invalid param

This commit is contained in:
yihaoDeng 2022-11-29 17:58:16 +08:00
parent dcd16684a0
commit 47c0d4cbbd
1 changed files with 3 additions and 0 deletions

View File

@ -785,6 +785,9 @@ int32_t schUpdateTaskCandidateAddr(SSchJob *pJob, SSchTask *pTask, SEpSet *pEpSe
SCH_TASK_DLOG("update task target node %d epset from %s to %s", pAddr->nodeId, origEpset, newEpset);
taosMemoryFree(origEpset);
taosMemoryFree(newEpset);
memcpy(&pAddr->epSet, pEpSet, sizeof(pAddr->epSet));
return TSDB_CODE_SUCCESS;