Re: Conflict detection for update_deleted in logical replication
shveta malik <shveta.malik@gmail.com>
On Thu, Jul 24, 2025 at 9:12 AM shveta malik <shveta.malik@gmail.com> wrote: > > > 2) > + if (MySubscription->retaindeadtuples && > + FindMostRecentlyDeletedTupleInfo(localrel, remoteslot, > + > &conflicttuple.xmin, > + > &conflicttuple.origin, > + > &conflicttuple.ts) && > + conflicttuple.origin != replorigin_session_origin) > + type = CT_UPDATE_DELETED; > + else > + type = CT_UPDATE_MISSING; > > Shall the conflict be detected as update_deleted irrespective of origin? > On thinking more here, I think that we may have the possibility of UPDATE after DELETE from the same origin only when a publication selectively publishes certain operations. 1) Consider a publication that only publishes UPDATE and DELETE operations. On the publisher, we may perform operations like DELETE, INSERT, and UPDATE. On the subscriber, only DELETE and UPDATE events are received. In this case, should we treat the incoming UPDATE as update_deleted or update_missing? 2) Another topology could be: pub1 --> pub2 --> sub (origin=any) pub1 --> sub - pub1 publishing only DELETEs to pub2 and the same are published to sub. - pub1 publishing only UPDATEs to sub. Now, consider that on pub1, an UPDATE occurs first, followed by a DELETE. But on the sub, the events are received in reverse order: DELETE arrives before UPDATE. Since both operations originated from the same source (pub1), how delayed UPDATE's conflict should be interpreted? Should it be detected as update_deleted or update_missing? Logically, since the DELETE is the more recent operation, it should be the final one and UPDATE should be ignored. But if we detect it as update_missing, we might incorrectly apply the UPDATE. Thoughts? thanks Shveta
Commits
-
Fix intermittent BF failures in 035_conflicts.
- 0f42206531b3 19 (unreleased) landed
-
Resume conflict-relevant data retention automatically.
- 0d48d393d465 19 (unreleased) landed
-
Fix intermittent test failure introduced in 6456c6e2c4.
- 01d793698f59 19 (unreleased) landed
-
Fix Coverity issue reported in commit a850be2fe.
- 5ac3c1ac22cb 19 (unreleased) landed
-
Add test to prevent premature removal of conflict-relevant data.
- 6456c6e2c4ad 19 (unreleased) landed
-
Post-commit review fixes for 228c370868.
- 1f7e9ba3ac4e 19 (unreleased) landed
-
Add max_retention_duration option to subscriptions.
- a850be2fe653 19 (unreleased) landed
-
Detect and report update_deleted conflicts.
- fd5a1a0c3e56 19 (unreleased) landed
-
Preserve conflict-relevant data during logical replication.
- 228c37086855 19 (unreleased) landed
-
Integrate FullTransactionIds deeper into two-phase code
- 62a17a92833d 19 (unreleased) cited
-
Improve checks for GUC recovery_target_timeline
- fd7d7b719137 19 (unreleased) cited
-
Prevent excessive delays before launching new logrep workers.
- fd519419c948 18.0 cited
-
Keep WAL segments by slot's last saved restart LSN
- ca307d5cec90 18.0 cited
-
Rework some code handling pg_subscription data in psql and pg_dump
- 08691ea958c2 18.0 cited
-
Use generateClonedIndexStmt to propagate CREATE INDEX to partitions.
- 68dfecbef210 18.0 cited