diff --git a/src/sync/src/syncMain.c b/src/sync/src/syncMain.c index ac79b48606..b43626ce43 100644 --- a/src/sync/src/syncMain.c +++ b/src/sync/src/syncMain.c @@ -1266,7 +1266,9 @@ static int32_t syncForwardToPeerImpl(SSyncNode *pNode, void *data, void *mhandle } } - return TSDB_CODE_SYN_INVALID_VERSION; + if (pNode->replica != 1) { + return TSDB_CODE_SYN_INVALID_VERSION; + } } // always update version