From 47c0d4cbbd6dbe3f1fe257d91792c2c0b7d3b6cd Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Tue, 29 Nov 2022 17:58:16 +0800 Subject: [PATCH] fix invalid param --- source/libs/scheduler/src/schTask.c | 3 +++ 1 file changed, 3 insertions(+) diff --git a/source/libs/scheduler/src/schTask.c b/source/libs/scheduler/src/schTask.c index af78647018..ed052be784 100644 --- a/source/libs/scheduler/src/schTask.c +++ b/source/libs/scheduler/src/schTask.c @@ -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;