diff --git a/src/sync/src/syncMain.c b/src/sync/src/syncMain.c index 0daf0b962060e9c9fc40d101d13eab200262c40a..f74d5a3816302d7f7ab6ea84bb50cc59b99b2eaa 100644 --- a/src/sync/src/syncMain.c +++ b/src/sync/src/syncMain.c @@ -313,6 +313,8 @@ int32_t syncForwardToPeer(void *param, void *data, void *mhandle, int qtype) { // always update version nodeVersion = pWalHead->version; + sDebug("replica:%d nodeRole:%d qtype:%d", pNode->replica, nodeRole, qtype); + if (pNode->replica == 1 || nodeRole != TAOS_SYNC_ROLE_MASTER) return 0; // only pkt from RPC or CQ can be forwarded