@@ -3727,7 +3727,6 @@ bool MtmFilterTransaction(char* record, int size)
37273727switch (event )
37283728{
37293729case PGLOGICAL_PREPARE :
3730- // return false;
37313730case PGLOGICAL_PRECOMMIT_PREPARED :
37323731case PGLOGICAL_ABORT_PREPARED :
37333732gid = pq_getmsgstring (& s );
@@ -3742,7 +3741,10 @@ bool MtmFilterTransaction(char* record, int size)
37423741restart_lsn = origin_node == MtmReplicationNodeId ?end_lsn :origin_lsn ;
37433742if (Mtm -> nodes [origin_node - 1 ].restartLSN < restart_lsn ) {
37443743MTM_LOG2 ("[restartlsn] node %d: %llx -> %llx (MtmFilterTransaction)" ,MtmReplicationNodeId ,Mtm -> nodes [MtmReplicationNodeId - 1 ].restartLSN ,restart_lsn );
3745- Mtm -> nodes [origin_node - 1 ].restartLSN = restart_lsn ;
3744+ if (event != PGLOGICAL_PREPARE ) {
3745+ /* Transactions can be prepared in different order, so to avoid loosing transactions we should not update restartLsn for them */
3746+ Mtm -> nodes [origin_node - 1 ].restartLSN = restart_lsn ;
3747+ }
37463748}else {
37473749duplicate = true;
37483750}