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

Commit 626dd6f

Browse files
knizhnikkelvich
authored andcommitted
Do not mark node as disabled on logical replication connection failure
1 parent 0055b46 commit 626dd6f

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

multimaster.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1076,7 +1076,7 @@ bool MtmRecoveryCaughtUp(int nodeId, XLogRecPtr slotLSN)
10761076
BIT_CLEAR(Mtm->nodeLockerMask, nodeId-1);
10771077
Mtm->nLockers -= 1;
10781078
} else {
1079-
MTM_LOG1("%d: dode %d is caugth-up without locking cluster", MyProcPid, nodeId);
1079+
MTM_LOG1("%d: node %d is caugth-up without locking cluster", MyProcPid, nodeId);
10801080
/* We are lucky: caugth-up without locking cluster! */
10811081
}
10821082
BIT_CLEAR(Mtm->disabledNodeMask, nodeId-1);

pglogical_receiver.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -249,7 +249,7 @@ pglogical_receiver_main(Datum main_arg)
249249
PQfinish(conn);
250250
ereport(WARNING, (errmsg("%s: Could not establish connection to remote server",
251251
worker_proc)));
252-
MtmOnNodeDisconnect(args->remote_node);
252+
/* MtmOnNodeDisconnect(args->remote_node); */
253253
proc_exit(1);
254254
}
255255

0 commit comments

Comments
 (0)