Re: Introduce XID age and inactive timeout based replication slot invalidation
Amit Kapila <amit.kapila16@gmail.com>
Commits
GET /api/v1/messages/:b64id/commits
the thread's linked commits as JSON, with link sources.
API reference →
-
Add a test for commit ac0e33136a using the injection point.
- 8a695d7998be 18.0 landed
-
Invalidate inactive replication slots.
- ac0e33136abc 18.0 landed
-
Fix incorrect slot type in BuildTupleHashTableExt
- d96d1d5152f3 18.0 cited
-
Allow synced slots to have their inactive_since.
- 6f132ed693b6 17.0 landed
-
Change last_inactive_time to inactive_since in pg_replication_slots.
- 6d49c8d4b4f4 17.0 landed
-
Track last_inactive_time in pg_replication_slots.
- a11f330b5584 17.0 landed
-
Track invalidation_reason in pg_replication_slots.
- 6ae701b4378d 17.0 landed
-
Add option force_initdb to PostgreSQL::Test::Cluster:init()
- ff9e1e764fcc 17.0 cited
-
Add a failover option to subscriptions.
- 776621a5e479 17.0 cited
-
Allow setting failover property in the replication command.
- 73292404370c 17.0 cited
-
Allow to enable failover property for replication slots via SQL API.
- c393308b69d2 17.0 cited
-
Track conflict_reason in pg_replication_slots.
- 007693f2a3ac 17.0 cited
-
Log messages for replication slot acquisition and release.
- 7c3fb505b14e 17.0 cited
-
Remove vacuum_defer_cleanup_age
- 1118cd37eb61 16.0 cited
-
Fix corruption due to vacuum_defer_cleanup_age underflowing 64bit xids
- be504a3e974d 16.0 cited
-
meson: Add initial version of meson based build system
- e6927270cd18 16.0 cited
On Thu, Mar 21, 2024 at 11:23 AM Bertrand Drouvot <bertranddrouvot.pg@gmail.com> wrote: > > On Thu, Mar 21, 2024 at 08:47:18AM +0530, Amit Kapila wrote: > > On Wed, Mar 20, 2024 at 1:51 PM Bertrand Drouvot > > <bertranddrouvot.pg@gmail.com> wrote: > > > > > > On Wed, Mar 20, 2024 at 12:48:55AM +0530, Bharath Rupireddy wrote: > > > > > > > > 2. last_inactive_at and inactive_timeout are now tracked in on-disk > > > > replication slot data structure. > > > > > > Should last_inactive_at be tracked on disk? Say the engine is down for a period > > > of time > inactive_timeout then the slot will be invalidated after the engine > > > re-start (if no activity before we invalidate the slot). Should the time the > > > engine is down be counted as "inactive" time? I've the feeling it should not, and > > > that we should only take into account inactive time while the engine is up. > > > > > > > Good point. The question is how do we achieve this without persisting > > the 'last_inactive_at'? Say, 'last_inactive_at' for a particular slot > > had some valid value before we shut down but it still didn't cross the > > configured 'inactive_timeout' value, so, we won't be able to > > invalidate it. Now, after the restart, as we don't know the > > last_inactive_at's value before the shutdown, we will initialize it > > with 0 (this is what Bharath seems to have done in the latest > > v13-0002* patch). After this, even if walsender or backend never > > acquires the slot, we won't invalidate it. OTOH, if we track > > 'last_inactive_at' on the disk, after, restart, we could initialize it > > to the current time if the value is non-zero. Do you have any better > > ideas? > > > > I think that setting last_inactive_at when we restart makes sense if the slot > has been active previously. I think the idea is because it's holding xmin/catalog_xmin > and that we don't want to prevent rows removal longer that the timeout. > > So what about relying on xmin/catalog_xmin instead that way? > That doesn't sound like a great idea because xmin/catalog_xmin values won't tell us before restart whether it was active or not. It could have been inactive for long time before restart but the xmin values could still be valid. What about we always set 'last_inactive_at' at restart (if the slot's inactive_timeout has non-zero value) and reset it as soon as someone acquires that slot? Now, if the slot doesn't get acquired till 'inactive_timeout', checkpointer will invalidate the slot. -- With Regards, Amit Kapila.