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

Commit 59f16a7

Browse files
knizhnikkelvich
authored andcommitted
Fix adding new node to multimaster
1 parent 4867218 commit 59f16a7

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

multimaster.c

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3828,6 +3828,7 @@ mtm_add_node(PG_FUNCTION_ARGS)
38283828
}
38293829
if (!MtmIsBroadcast())
38303830
{
3831+
MtmBroadcastUtilityStmt(psprintf("select pg_create_logical_replication_slot('" MULTIMASTER_SLOT_PATTERN "', '" MULTIMASTER_NAME "')", Mtm->nAllNodes+1), true);
38313832
MtmBroadcastUtilityStmt(psprintf("select mtm.add_node('%s')", connStr), true);
38323833
}
38333834
else

pglogical_receiver.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -344,7 +344,7 @@ pglogical_receiver_main(Datum main_arg)
344344
* Them are either empty, either new node is synchronized using base_backup.
345345
* So we assume that LSNs are the same for local and remote node
346346
*/
347-
originStartPos = (Mtm->status == MTM_RECOVERY && Mtm->donorNodeId == nodeId) ? GetXLogInsertRecPtr() : INVALID_LSN;
347+
originStartPos = INVALID_LSN;
348348
MTM_LOG1("Start logical receiver at position %llx from node %d", originStartPos, nodeId);
349349
} else {
350350
if (Mtm->nodes[nodeId-1].restartLSN < originStartPos) {

0 commit comments

Comments
 (0)