diff --git a/src/sync/src/syncRetrieve.c b/src/sync/src/syncRetrieve.c index b3be1ace3958..d755ee9aa6f0 100644 --- a/src/sync/src/syncRetrieve.c +++ b/src/sync/src/syncRetrieve.c @@ -503,9 +503,10 @@ void *syncRetrieveData(void *param) { taosClose(pPeer->syncFd); // The ref is obtained in both the create thread and the current thread, so it is released twice + sInfo("%s, sync retrieve data over, sstatus:%s", pPeer->id, syncStatus[pPeer->sstatus]); + syncReleasePeer(pPeer); syncReleasePeer(pPeer); - sInfo("%s, sync retrieve data over, sstatus:%s", pPeer->id, syncStatus[pPeer->sstatus]); return NULL; }