Re: Skipping logical replication transactions on subscriber side
Amit Kapila <amit.kapila16@gmail.com>
On Wed, Jan 5, 2022 at 9:48 AM Dilip Kumar <dilipbalaut@gmail.com> wrote: > > On Wed, Jan 5, 2022 at 9:01 AM Amit Kapila <amit.kapila16@gmail.com> wrote: > > > > On Mon, Dec 27, 2021 at 9:54 AM Masahiko Sawada <sawada.mshk@gmail.com> wrote: > > > > Do you mean to say that you want to omit it even when we are > > committing the changes? > > > > > Apart from that, I'm vaguely concerned that the logic seems to be > > > getting complex. Probably it comes from the fact that we store > > > skip_xid in the catalog and update the catalog to clear/set the > > > skip_xid. It might be worth revisiting the idea of storing skip_xid on > > > shmem (e.g., ReplicationState)? > > > > > > > IIRC, the problem with that idea was that we won't remember skip_xid > > information after server restart and the user won't even know that it > > has to set it again. > > > I agree, that if we don't keep it in the catalog then after restart if > the transaction replayed again then the user has to set the skip xid > again and that would be pretty inconvenient because the user might > have to analyze the failure again and repeat the same process he did > before restart. But OTOH the combination of restart and the skip xid > might not be very frequent so this might not be a very bad option. > Basically, I am in favor of storing it in a catalog as that solution > looks cleaner at least from the user pov but if we think there are a > lot of complexities from the implementation pov then we might analyze > the approach of storing in shmem as well. > Fair point, but I think it is better to see the patch or the problems that can't be solved if we pursue storing it in catalog. Even, if we decide to store it in shmem, we need to invent some way to inform the user that we have not honored the previous setting of skip_xid and it needs to be reset again. -- With Regards, Amit Kapila.
Commits
-
Test ALIGNOF_DOUBLE==4 compatibility under ALIGNOF_DOUBLE==8.
- c1da0acbb06e 15.0 landed
-
Reorder subskiplsn in pg_subscription to avoid alignment issues.
- 79b716cfb7a1 15.0 landed
-
Add ALTER SUBSCRIPTION ... SKIP.
- 208c5d65bbd6 15.0 landed
-
Optionally disable subscriptions on error.
- 705e20f8550c 15.0 cited
-
Update docs of logical replication for commit 8d74fc96db.
- 85c61ba8920b 15.0 landed
-
Respect permissions within logical replication.
- a2ab9c06ea15 15.0 cited
-
Fix regression test failure caused by commit 8d74fc96db.
- 41e66fee0516 15.0 landed
-
Add a view to show the stats of subscription workers.
- 8d74fc96db5f 15.0 landed
-
Add logical change details to logical replication worker errcontext.
- abc0910e2e0a 15.0 landed
-
Rename LOGICAL_REP_MSG_STREAM_END to LOGICAL_REP_MSG_STREAM_STOP.
- 4cd7a1896871 15.0 landed
-
Fix typo in protocol.sgml.
- e1915646658d 14.0 landed
- 0ac1aee0d7d8 15.0 landed
-
Remove unused argument in apply_handle_commit_internal().
- f4b939f1a372 14.0 landed
- 16bd4becee32 15.0 landed
-
Fix replication of in-progress transactions in tablesync worker.
- 0926e96c4934 14.0 cited
-
Reorder pg_sequence columns to avoid alignment issue
- f3b421da5f4a 10.0 cited