Commit59f16a7

authored and

committed

Fix adding new node to multimaster

1 parent4867218 commit59f16a7Copy full SHA for 59f16a7

File tree

-1

lines changed

-1

lines changed

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -3828,6 +3828,7 @@ mtm_add_node(PG_FUNCTION_ARGS)`
`3828`	`3828`	`}`
`3829`	`3829`	`if (!MtmIsBroadcast())`
`3830`	`3830`	`{`
	`3831`	`+MtmBroadcastUtilityStmt(psprintf("select pg_create_logical_replication_slot('"MULTIMASTER_SLOT_PATTERN"', '"MULTIMASTER_NAME"')",Mtm->nAllNodes+1), true);`
`3831`	`3832`	`MtmBroadcastUtilityStmt(psprintf("select mtm.add_node('%s')",connStr), true);`
`3832`	`3833`	`}`
`3833`	`3834`	`else`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -344,7 +344,7 @@ pglogical_receiver_main(Datum main_arg)`
`344`	`344`	`* Them are either empty, either new node is synchronized using base_backup.`
`345`	`345`	`* So we assume that LSNs are the same for local and remote node`
`346`	`346`	`*/`
`347`		`-originStartPos=(Mtm->status==MTM_RECOVERY&&Mtm->donorNodeId==nodeId) ?GetXLogInsertRecPtr() :INVALID_LSN;`
	`347`	`+originStartPos=INVALID_LSN;`
`348`	`348`	`MTM_LOG1("Start logical receiver at position %llx from node %d",originStartPos,nodeId);`
`349`	`349`	`}else {`
`350`	`350`	`if (Mtm->nodes[nodeId-1].restartLSN<originStartPos) {`

Comments

(0)