From 31b6d1524098a16f9dcf0c8cee9f96a82851ddea Mon Sep 17 00:00:00 2001
From: yihaoDeng <luomoxyz@126.com>
Date: Tue, 12 Mar 2024 03:08:20 +0000
Subject: [PATCH] fix invalid free

---
 source/libs/scheduler/src/schRemote.c | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/source/libs/scheduler/src/schRemote.c b/source/libs/scheduler/src/schRemote.c
index 43ea418851..1fabc3a6e5 100644
--- a/source/libs/scheduler/src/schRemote.c
+++ b/source/libs/scheduler/src/schRemote.c
@@ -892,11 +892,14 @@ int32_t schCloneCallbackParam(SSchCallbackParamHeader *pSrc, SSchCallbackParamHe
 int32_t schCloneSMsgSendInfo(void *src, void **dst) {
   SMsgSendInfo *pSrc = src;
   int32_t       code = 0;
-  SMsgSendInfo *pDst = taosMemoryMalloc(sizeof(*pSrc));
+  SMsgSendInfo *pDst = taosMemoryCalloc(1, sizeof(*pSrc));
   if (NULL == pDst) {
     qError("malloc SMsgSendInfo for rpcCtx failed, len:%d", (int32_t)sizeof(*pSrc));
     SCH_ERR_RET(TSDB_CODE_OUT_OF_MEMORY);
   }
+   if (pDst->target.dbFName != NULL) {
+    pDst->target.dbFName = taosStrdup(pSrc->target.dbFName);
+  } 
 
   memcpy(pDst, pSrc, sizeof(*pSrc));
   pDst->param = NULL;