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;