diff --git a/src/rpc/src/tudp.c b/src/rpc/src/tudp.c
index bfc95373fc842684081b76ef1095080413fc2086..fb0b37d93baaf98a6caed35ec980de72090819f2 100644
--- a/src/rpc/src/tudp.c
+++ b/src/rpc/src/tudp.c
@@ -377,6 +377,7 @@ void *taosTransferDataViaTcp(void *argv) {
       pThead->tcp = 1;
       pThead->msgType = (char)(pHeader->msgType - 1);
       pThead->msgLen = (int32_t)htonl(sizeof(STaosHeader));
+      uint32_t id = pThead->sourceId; pThead->sourceId = pThead->destId; pThead->destId = id;
       pMonitor->ip = pTransfer->ip;
       pMonitor->port = pTransfer->port;
       pMonitor->pSet = pSet;