Re: Skipping logical replication transactions on subscriber side
Masahiko Sawada <sawada.mshk@gmail.com>
Attachments
- v11-0001-Add-logical-change-details-to-logical-replicatio.patch (application/octet-stream) patch v11-0001
- v11-0003-Add-RESET-command-to-ALTER-SUBSCRIPTION-command.patch (application/octet-stream) patch v11-0003
- v11-0004-Add-skip_xid-option-to-ALTER-SUBSCRIPTION.patch (application/octet-stream) patch v11-0004
- v11-0005-Move-shared-fileset-cleanup-to-before_shmem_exit.patch (application/octet-stream) patch v11-0005
- v11-0002-Add-pg_stat_subscription_errors-statistics-view.patch (application/octet-stream) patch v11-0002
On Tue, Aug 24, 2021 at 10:05 PM Amit Kapila <amit.kapila16@gmail.com> wrote: > > On Tue, Aug 24, 2021 at 11:44 AM tanghy.fnst@fujitsu.com > <tanghy.fnst@fujitsu.com> wrote: > > > > On Monday, August 23, 2021 11:09 AM Masahiko Sawada <sawada.mshk@gmail.com> wrote: > > > > > > I've attached updated patches. Please review them. > > > > > > > I tested v10-0001 patch in both streaming and no-streaming more. All tests works well. > > > > I also tried two-phase commit feature, the error context was set as expected, > > but please allow me to propose a fix suggestion on the error description: Thank you for the suggestion! > > > > CONTEXT: processing remote data during "INSERT" for replication target relation > > "public.test" in transaction 714 with commit timestamp 2021-08-24 > > 13:20:22.480532+08 > > > > It said "commit timestamp", but for 2pc feature, the timestamp could be "prepare timestamp" or "rollback timestamp", too. > > Could we make some change to make the error log more comprehensive? > > > > I think we can write something like: (processing remote data during > "INSERT" for replication target relation "public.test" in transaction > 714 at 2021-08-24 13:20:22.480532+08). Basically replacing "with > commit timestamp" with "at". This is similar to what we do > test_decoding module for transaction timestamp. +1 > The other idea could > be we print the exact operation like commit/prepare/rollback which is > also possible because we have that information while setting context > info but that might add a bit more complexity which I don't think is > worth it. Agreed. I replaced "with commit timestamp" with "at" and rename 'commit_ts' field name to 'ts'. > > One more point about the v10-0001* patch: From the commit message > "Add logical changes details to errcontext of apply worker errors.", > it appears that the context will be added only for the apply worker > but won't it get added for tablesync worker as well during its sync > phase (when it tries to catch up with apply worker)? Right. I've updated the message. Attached updated version patches. Please review them. Regards, -- Masahiko Sawada EDB: https://www.enterprisedb.com/
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