diff --git a/src/sync/src/syncRestore.c b/src/sync/src/syncRestore.c
index 2360ca7bf3f865da0f7f30a40b1cdf5e3cdf39b6..2b1887b362e50837099f3405cad8e04a18f93bc6 100644
--- a/src/sync/src/syncRestore.c
+++ b/src/sync/src/syncRestore.c
@@ -39,7 +39,7 @@ static int32_t syncRecvFileVersion(SSyncPeer *pPeer, uint64_t *fversion) {
   SFileAck fileVersionAck;
   memset(&fileVersionAck, 0, sizeof(SFileAck));
   syncBuildFileAck(&fileVersionAck, pNode->vgId);
-  ret = taosReadMsg(pPeer->syncFd, &fileVersionAck, sizeof(SFileAck));
+  ret = taosWriteMsg(pPeer->syncFd, &fileVersionAck, sizeof(SFileAck));
   if (ret != sizeof(SFileAck)) {
     sError("%s, failed to write fver ack since %s", pPeer->id, strerror(errno));
     return -1;