diff --git a/src/backend/replication/logical/worker.c b/src/backend/replication/logical/worker.c index a75a3691dc..b1b77e4a1e 100644 --- a/src/backend/replication/logical/worker.c +++ b/src/backend/replication/logical/worker.c @@ -4078,8 +4078,9 @@ maybe_advance_nonremovable_xid(RetainConflictInfoData *data, bool status_received) { /* - * The non-removable transaction ID for a subscription is centrally - * managed by the main apply worker. + * It is sufficient to manage non-removable transaction ID for a + * subscription by the main apply worker to detect update_deleted conflict + * even for table sync or parallel apply workers. */ if (!am_leader_apply_worker()) return;