diff --git a/src/sync/src/syncRetrieve.c b/src/sync/src/syncRetrieve.c index bec24baf21cbc9a425f5d56d2ccd3745b7140766..a53f8fed3be4bcd1c4a25f0e45bbc8a2a8719a19 100644 --- a/src/sync/src/syncRetrieve.c +++ b/src/sync/src/syncRetrieve.c @@ -267,7 +267,7 @@ static int syncRetrieveLastWal(SSyncPeer *pPeer, char *name, uint64_t fversion, break; } - if (fversion > 0 && pHead->version > pPeer->sversion + 1) { + if (pHead->version > pPeer->sversion + 1) { sError("%s, last wal skip forward, ver:%" PRIu64 ", sver:%" PRIu64, pPeer->id, pHead->version, pPeer->sversion); } else { sDebug("%s, last wal is forwarded, ver:%" PRIu64, pPeer->id, pHead->version);