Re: Skipping logical replication transactions on subscriber side
Masahiko Sawada <sawada.mshk@gmail.com>
On Fri, Nov 19, 2021 at 7:09 PM Amit Kapila <amit.kapila16@gmail.com> wrote: > > On Fri, Nov 19, 2021 at 3:00 PM Greg Nancarrow <gregn4422@gmail.com> wrote: > > > > On Fri, Nov 19, 2021 at 8:15 PM Amit Kapila <amit.kapila16@gmail.com> wrote: > > > Yeah in such a case last_error_time can be shown as a time before > > > first_error_time but I don't think that will be a big problem, the > > > next message will fix it. I don't see what we can do about it and the > > > same is true for other cases like pg_stat_archiver where the success > > > and failure times can be out of order. If we want we can remove one of > > > those times but I don't think this happens frequently enough to be > > > considered a problem. Anyway, these stats are not considered to be > > > updated with the most latest info. > > > > > > > Couldn't the code block in pgstat_recv_subworker_error() that > > increments error_count just compare the new msg timestamp against the > > existing first_error_time and last_error_time and, based on the > > result, update those if required? > > > > I don't see any problem with that but let's see what Sawada-San has to > say about this? IMO not sure we should do that. Since the stats collector will not likely to receive the same error report frequently in practice (5 sec interval by default), perhaps this problem will unlikely to happen. Even if the same messages are reported frequently enough to cause this problem, the next message will also be reported soon, fixing it soon, as Amit mentioned. Also, IIUC once we have the shared memory based stats collector, we won’t need to worry about this problem. Given that this kind of problem potentially exists also in other stats views that have timestamp values, I’m not sure it's worth dealing with this problem only in pg_stat_subscription_workers view. 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