diff --git a/src/backend/replication/logical/worker.c b/src/backend/replication/logical/worker.c index 6b79aa441b..afe007bd50 100644 --- a/src/backend/replication/logical/worker.c +++ b/src/backend/replication/logical/worker.c @@ -4312,12 +4312,6 @@ wait_for_local_flush(RetainConflictInfoData *data) /* * Determine if we can attempt to advance transaction ID. - * - * TODO: The remote flush location (last_flushpos) is currently not updated - * during change application, making it impossible to satisfy the condition of - * the final phase (RCI_WAIT_FOR_LOCAL_FLUSH) for advancing the transaction ID. - * Consider updating the remote flush position in the final phase to enable - * advancement during change application. */ static inline bool can_advance_nonremovable_xid(RetainConflictInfoData *data) diff --git a/src/backend/replication/walsender.c b/src/backend/replication/walsender.c index 00b6411c7e..94acca15e3 100644 --- a/src/backend/replication/walsender.c +++ b/src/backend/replication/walsender.c @@ -2678,6 +2678,10 @@ ProcessStandbyPSRequestMessage(void) WalSnd *walsnd = MyWalSnd; TimestampTz replyTime; + /* + * This shouldn't happen because we don't support getting publisher_status + * message from standby. + */ if (RecoveryInProgress()) elog(ERROR, "the primary status is unavailable during recovery");