@@ -4099,7 +4099,6 @@ bool MtmFilterTransaction(char* record, int size)
40994099switch (event )
41004100{
41014101case PGLOGICAL_PREPARE :
4102- return false;
41034102case PGLOGICAL_PRECOMMIT_PREPARED :
41044103case PGLOGICAL_ABORT_PREPARED :
41054104gid = pq_getmsgstring (& s );
@@ -4114,7 +4113,10 @@ bool MtmFilterTransaction(char* record, int size)
41144113restart_lsn = origin_node == MtmReplicationNodeId ?end_lsn :origin_lsn ;
41154114if (Mtm -> nodes [origin_node - 1 ].restartLSN < restart_lsn ) {
41164115MTM_LOG2 ("[restartlsn] node %d: %llx -> %llx (MtmFilterTransaction)" ,MtmReplicationNodeId ,Mtm -> nodes [MtmReplicationNodeId - 1 ].restartLSN ,restart_lsn );
4117- Mtm -> nodes [origin_node - 1 ].restartLSN = restart_lsn ;
4116+ if (event != PGLOGICAL_PREPARE ) {
4117+ /* Transactions can be prepared in different order, so to avoid loosing transactions we should not update restartLsn for them */
4118+ Mtm -> nodes [origin_node - 1 ].restartLSN = restart_lsn ;
4119+ }
41184120}else {
41194121duplicate = true;
41204122}