RE: Slow catchup of 2PC (twophase) transactions on replica in LR
Hayato Kuroda (Fujitsu) <kuroda.hayato@fujitsu.com>
From: "Hayato Kuroda (Fujitsu)" <kuroda.hayato@fujitsu.com>
To: 'Amit Kapila' <amit.kapila16@gmail.com>
Cc: Ajin Cherian <itsajin@gmail.com>, Давыдов Виталий <v.davydov@postgrespro.ru>, Heikki Linnakangas <hlinnaka@iki.fi>, "pgsql-hackers@lists.postgresql.org" <pgsql-hackers@lists.postgresql.org>
Date: 2024-07-05T05:39:05Z
Lists: pgsql-hackers
Commits
Same data as JSON:
GET /api/v1/messages/:b64id/commits
the thread's linked commits as JSON, with link sources.
API reference →
-
Fix random failure in 021_twophase.
- 0dcea330babd 18.0 landed
-
Allow altering of two_phase option of a SUBSCRIPTION.
- 1462aad2e447 18.0 landed
-
Doc: use true|false rather than on|off for "failover" option
- fa65a022db26 17.0 cited
-
Support an optional asynchronous commit mode, in which we don't flush WAL
- 4a78cdeb6b59 8.3.0 cited
Attachments
- v15-0001-Allow-altering-of-two_phase-option-of-a-SUBSCRIP.patch (application/octet-stream) patch v15-0001
- v15-0002-Alter-slot-option-two_phase-only-when-altering-t.patch (application/octet-stream) patch v15-0002
- v15-0003-Abort-prepared-transactions-while-altering-two_p.patch (application/octet-stream) patch v15-0003
- v15-0004-Add-force_alter-option-for-ALTER-SUBSCRIPTION-.-.patch (application/octet-stream) patch v15-0004
Dear Amit, Thanks for giving comments. I hope all comments have been addressed. PSA new version. > > Actually, earlier version (-v3) did not have a mechanism but they sometimes got > > assertion failures in maybe_reread_subscription(). This was because the > survived > > workers read pg_subscription catalog and failed below assertion: > > > > ``` > > /* two-phase cannot be altered while the worker exists */ > > Assert(newsub->twophasestate == > MySubscription->twophasestate); > > ``` > > > > But that is not a good reason for this operation to stop workers > first. Instead, we should prohibit this operation if any worker is > present. The reason is that there is always a chance that if any > worker is alive, it can prepare a new transaction after we have > checked for the presence of any prepared transactions. I used the function because it internally waits until all workers are exited. But OK, I modified like you suggested (logicalrep_workers_find() is used). Best Regards, Hayato Kuroda FUJITSU LIMITED https://www.fujitsu.com/