public inbox for [email protected]  

help / color / mirror / Atom feed

From: Amit Kapila <[email protected]>
To: Zhijie Hou (Fujitsu) <[email protected]>
Cc: PostgreSQL Hackers <[email protected]>
Subject: Re: Fix stats reporting delays in logical parallel apply worker
Date: Fri, 17 Apr 2026 12:49:36 +0530
Message-ID: <CAA4eK1JF-zny8pGP4Mafk8=mNBCV8A0a1-6HvVd1Q2ZVJW-NJw@mail.gmail.com> (raw)
In-Reply-To: <TYRPR01MB1419579F217CC4332B615589594202@TYRPR01MB14195.jpnprd01.prod.outlook.com>
References: <TYRPR01MB1419579F217CC4332B615589594202@TYRPR01MB14195.jpnprd01.prod.outlook.com>

On Fri, Apr 17, 2026 at 8:31 AM Zhijie Hou (Fujitsu)
<[email protected]> wrote:
>
> When implementing another feature, I noticed that parallel apply workers
> currently do not report statistics while idle in their main loop. This can cause
> stats from the last processed transaction to be arbitrarily delayed, especially
> when there are long gaps between streamed transactions.
>
> The issue is demonstrated in 0002, where a TAP test fails when attempting to
> collect stats from a parallel apply worker that has no subsequent transaction to
> trigger a stats report.
>
> 0001 fixes this issue by forcing a stats report when the worker is idle in the
> main loop, matching the behavior already present in LogicalRepApplyLoop() for
> regular logical apply workers.
>

LGTM. We should backpatch this change.

-- 
With Regards,
Amit Kapila.

view thread (7+ messages)  latest in thread

reply

Reply instructions:

You may reply publicly to this message via plain-text email
using any one of the following methods:

* Reply to all the recipients using the --to and --cc options:
  reply via email

  To: [email protected]
  Cc: [email protected], [email protected], [email protected]
  Subject: Re: Fix stats reporting delays in logical parallel apply worker
  In-Reply-To: <CAA4eK1JF-zny8pGP4Mafk8=mNBCV8A0a1-6HvVd1Q2ZVJW-NJw@mail.gmail.com>

* Save the following mbox file, import it into your mail client,
  and reply-to-all from there: mbox

This inbox is served by agora; see mirroring instructions
for how to clone and mirror all data and code used for this inbox