Re: Adding REPACK [concurrently]
Antonin Houska <ah@cybertec.at>
Amit Kapila <amit.kapila16@gmail.com> wrote: > On Tue, Mar 31, 2026 at 8:06 PM Antonin Houska <ah@cybertec.at> wrote: > > > > Amit Kapila <amit.kapila16@gmail.com> wrote: > > > 2. > > > * > > > + /* > > > + * TODO Consider a GUC to reserve certain amount of replication slots for > > > + * REPACK (CONCURRENTLY) and using it here. > > > + */ > > > +#define MAX_REPACK_XIDS 16 > > > + > > > > > > This sounds a bit scary as reserving replication slots for REPACK > > > (CONCURRENTLY) may not be what users expect. But it is not clear why > > > replication slots need to be reserved for this. > > > > The point is that REPACK should not block replication [1]. Thus reserving > > slots for non-REPACK users is probably more precise statement. > > > > oh, so shouldn't be a separate patch than this and an important for > this functionality to get committed? I don't see why we need to make > such a GUC or knob as part of this patch if we need the same. REPACK is a new user of replication slots. Without that, there is no other way to "steal" the slots from the replication users. > > > IIUC, two reasons why logical decoding can ignore REPACK > > > (CONCURRENTLY) are (a) does not perform any catalog changes relevant > > > to logical decoding, (b) neither walsenders nor backends performing > > > logical decoding needs to care sending the WAL generated by REPACK > > > (CONCURRENTLY). Is that understanding correct? If so, we may want to > > > clarify why we want to ignore this command's WAL while sending changes > > > downstream in the commit message or give some reference of the patch > > > where the same is mentioned. This can help reviewing this patch > > > independently. > > > > Correct, but in fact this diff only affects the setup of the logical decoding > > rather than the decoding itself. On the other hand, if REPACK (CONCURRENTLY) > > starts when the decoding backend's snapshot builder is already in the > > SNAPBUILD_FULL_SNAPSHOT state, reorderbuffer.c processes the transaction > > normally, and another part of the series (v46-0002) ensures that the table > > rewriting is not decoded: REPACK simply tells heap_insert(), heap_update(), > > heap_delete() not to put the extra (replication specific) information into the > > corresponding WAL records. I suppose this is what you mean in (b). > > > > Regarding (a), yes, the absence of catalog changes in the REPACK's transaction > > is the reason that even the logical decoding setup does not have to wait for > > the transaction to finish. > > > > Hmm, but we don't do any catalog changes for transactions that have > DML say only INSERT but we don't have separate logic like REPACK in > snapbuild machinery. Same is probably true for dml operations on an > unlogged table which doesn't have WAL to send nor any catalog > operations involved but we don't have any special path for that in > snapbuild code path. So, why do we need special handling for this > operation? If an "ordinary" transaction, which had started before the snapshot builder reached the SNAPBUILD_FULL_SNAPSHOT state, runs DML, the snapshot builder does not know if the same transaction changed something in the catalog earlier. So it needs to wait for this transaction to finish before it advances to SNAPBUILD_CONSISTENT. For REPACK, we know that it cannot happen because it cannot run in transaction block for other reasons. So the snapshot builder does not have to wait. Nevertheless, I'm not sure it's a good idea for snapbuild.c to handle special cases like REPACK. Instead, I'm thinking if snapbuild.c can safely ignore XIDs of backends connected to databases other than the one we're decoding. Thus the restriction would be one backend running REPACK per database rather than cluster. -- Antonin Houska Web: https://www.cybertec-postgresql.com
Commits
GET /api/v1/messages/:b64id/commits
the thread's linked commits as JSON, with link sources.
API reference →
-
Allow old WAL recycling during REPACK CONCURRENTLY
- 45b02984e2fa 19 (unreleased) landed
-
Advance restart_lsn more eagerly in LogicalConfirmReceivedLocation
- 38470c2c1ea7 19 (unreleased) landed
-
Remove unnecessary signal handler change
- 5d48d3b14e0e 19 (unreleased) landed
-
Improve REPACK (CONCURRENTLY) error messages some more
- 378dffaf8c80 19 (unreleased) landed
-
Revert "Allow logical replication snapshots to be database-specific"
- 01a80f062146 19 (unreleased) landed
-
Move REPACK (CONCURRENTLY) test out of stock regression tests
- 4b2aa4b39cba 19 (unreleased) landed
-
REPACK: do not require REPLICATION or LOGIN
- 5dbb63fc82b7 19 (unreleased) landed
-
Add missing initialization
- 05c401d5786a 19 (unreleased) landed
-
Simplify declaration of memcpy target
- 2cff363715ef 19 (unreleased) landed
-
Reserve replication slots specifically for REPACK
- e76d8c749c31 19 (unreleased) landed
-
doc: Add an example of REPACK (CONCURRENTLY)
- 8fb95a8ab6e5 19 (unreleased) landed
-
Allow logical replication snapshots to be database-specific
- 0d3dba38c777 19 (unreleased) landed
-
Avoid different-size pointer-to-integer cast
- a3b069ef90bd 19 (unreleased) landed
-
Fix valgrind failure
- 5bcc3fbd196c 19 (unreleased) landed
-
Add CONCURRENTLY option to REPACK
- 28d534e2ae0a 19 (unreleased) landed
-
Rename cluster.c to repack.c (and corresponding .h)
- c0b53ec06309 19 (unreleased) landed
-
Allow index_create to suppress index_build progress reporting
- caec9d9fadf1 19 (unreleased) landed
-
Make index_concurrently_create_copy more general
- 33bf7318f94c 19 (unreleased) landed
-
Document the 'command' column of pg_stat_progress_repack
- a630ac5c2016 19 (unreleased) landed
-
Introduce the REPACK command
- ac58465e0618 19 (unreleased) landed
-
Toggle logical decoding dynamically based on logical slot presence.
- 67c20979ce72 19 (unreleased) cited
-
Split vacuumdb to create vacuuming.c/h
- c4067383cb2c 19 (unreleased) landed
-
Remove ReorderBufferTupleBuf structure.
- 08e6344fd642 17.0 cited
-
Revert changes to CONCURRENTLY that "sped up" Xmin advance
- 042b584c7f7d 14.4 cited
-
VACUUM: ignore indexing operations with CONCURRENTLY
- d9d076222f5b 14.0 cited