Location via proxy:   [ UP ]  
[Report a bug]   [Manage cookies]                
Skip to content

Commit cb86819

Browse files
committed
Do not compare slot lag with MtmMaxRecoveryLag in runtime
1 parent 92415ab commit cb86819

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

multimaster.c

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3725,8 +3725,8 @@ bool MtmFilterTransaction(char* record, int size)
37253725
}
37263726
restart_lsn = origin_node == MtmReplicationNodeId ? end_lsn : origin_lsn;
37273727
if (Mtm->nodes[origin_node-1].restartLSN < restart_lsn) {
3728-
Assert(Mtm->nodes[origin_node-1].restartLSN == INVALID_LSN
3729-
|| restart_lsn < Mtm->nodes[origin_node-1].restartLSN + MtmMaxRecoveryLag);
3728+
// Assert(Mtm->nodes[origin_node-1].restartLSN == INVALID_LSN
3729+
// || restart_lsn < Mtm->nodes[origin_node-1].restartLSN + MtmMaxRecoveryLag);
37303730
MTM_LOG2("[restartlsn] node %d: %llx -> %llx (MtmFilterTransaction)", MtmReplicationNodeId, Mtm->nodes[MtmReplicationNodeId-1].restartLSN, restart_lsn);
37313731
Mtm->nodes[origin_node-1].restartLSN = restart_lsn;
37323732
} else {

0 commit comments

Comments
 (0)