Received: from malur.postgresql.org ([217.196.149.56]) by arkaria.postgresql.org with esmtps (TLS1.3) tls TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384 (Exim 4.96) (envelope-from ) id 1wDdUn-003By8-0R for pgsql-hackers@arkaria.postgresql.org; Fri, 17 Apr 2026 07:20:09 +0000 Received: from localhost ([127.0.0.1] helo=malur.postgresql.org) by malur.postgresql.org with esmtp (Exim 4.96) (envelope-from ) id 1wDdUm-008jOo-0s for pgsql-hackers@arkaria.postgresql.org; Fri, 17 Apr 2026 07:20:08 +0000 Received: from magus.postgresql.org ([2a02:c0:301:0:ffff::29]) by malur.postgresql.org with esmtps (TLS1.3) tls TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384 (Exim 4.96) (envelope-from ) id 1wDdUW-008gJa-0G for pgsql-hackers@lists.postgresql.org; Fri, 17 Apr 2026 07:19:52 +0000 Received: from mail-lj1-x230.google.com ([2a00:1450:4864:20::230]) by magus.postgresql.org with esmtps (TLS1.3) tls TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256 (Exim 4.98.2) (envelope-from ) id 1wDdUU-00000001cMw-02mb for pgsql-hackers@lists.postgresql.org; Fri, 17 Apr 2026 07:19:51 +0000 Received: by mail-lj1-x230.google.com with SMTP id 38308e7fff4ca-38e7bd07656so3328801fa.1 for ; Fri, 17 Apr 2026 00:19:49 -0700 (PDT) ARC-Seal: i=1; a=rsa-sha256; t=1776410388; cv=none; d=google.com; s=arc-20240605; b=ARo198sopGAePgkV0Y31iPKPYGn8HrMzB/B+pjfUVJmCN+I6F6KC5xJQ4SW3HzrTM1 Vnp6Ui3fvNgOLID5On112y7CbbdM/YSyeA9KWd+P8ULX2zIhbxTodm9vxHUDEHoCG1jH ayErWnwNOZ3wlOp1S+QUBRnhdIXtJhcQHhCe0dXFp8NzL5uxW1205heGCKxz2LAI+K9l LPmjO7HK6ZX/mb+vWebcFwK9tlSNVC9WLsSBjQlw80Rp6oICBJEnLEk42kowVV2r0GBs HmB8iDqmDQbiXu0+6EXgfNgs5OM4pgyNGxPBKA4CzHHJMRW92dPFjOX/2QJUJ66HQZvD 90Cg== ARC-Message-Signature: i=1; a=rsa-sha256; c=relaxed/relaxed; d=google.com; s=arc-20240605; h=content-transfer-encoding:cc:to:subject:message-id:date:from :in-reply-to:references:mime-version:dkim-signature; bh=v+QJwJNS3aP1OkIyybtYqFcCchptHj5KsCJymvjW6VY=; fh=Ti5UUWWnIawXjRDrxK96yl2MCM81GcRJ2EeXAktfwrY=; b=CAv+DC+0LX3/9nWW7YOyf/3kXBr2PjS2fbDN79PYYRIiWu+7uOqSuI9dzCe4oyofbz zOGRv0Zt+rGGvHLV8jf913GIMBqufiE2e/Jc6nX4SCHOER5/wCQIhXCRLhcSKbll6Kd4 +FlUgikMBL1DDMNLaVUcTrWhsdv581OMO+iljiOa3Y0X8u/o0oBlHBsJfhwQzH69h1ug /t1yaeDxhg8XmBS346A1K7dFPNMVTd7PcdBzv88jVFhPa8IONPO4jzKRMYRLwZnrvMIh IZdHVNJDFSAuBlbgVIKXRfAnM1Rxafp5UkXn2ILAEaldXgI80pehzxLr6FyG3GklRbZw d1fA==; darn=lists.postgresql.org ARC-Authentication-Results: i=1; mx.google.com; arc=none DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20251104; t=1776410388; x=1777015188; darn=lists.postgresql.org; h=content-transfer-encoding:cc:to:subject:message-id:date:from :in-reply-to:references:mime-version:from:to:cc:subject:date :message-id:reply-to; bh=v+QJwJNS3aP1OkIyybtYqFcCchptHj5KsCJymvjW6VY=; b=nB9PACcEWXw0fOf5sj07LMZHLMOMC1PkoZQQJBwX7T5M3v7QD5HAQ4Wwl04FZOSbH8 DovdcwH79IO/o3//tzJMvVcdaDsseGJAAFc6Qll/si0lfFPgSaRh3mHuLaSnIK12t708 cM8ePp4s1438BH0Q0cF9/j6McgfZb2i/kcChoPZTzB3hdwJ/hshR2HrNNXyTJ+MjPK65 q4aXngTu33X9gu9Zz1bV044PyYafCejs3LE6w0D3iOkB/70YzhnavhaStIVNLPr0uJjo +F8BredtC4hY6Z2aAiv1t93YY9GbsnAvPPz7rlCrKpHuJzWKcRwmLWijJSyjvsEnjc+J QSaw== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20251104; t=1776410388; x=1777015188; h=content-transfer-encoding:cc:to:subject:message-id:date:from :in-reply-to:references:mime-version:x-gm-gg:x-gm-message-state:from :to:cc:subject:date:message-id:reply-to; bh=v+QJwJNS3aP1OkIyybtYqFcCchptHj5KsCJymvjW6VY=; b=QmTTXsgV4WI6AugnXIjHY1ymXRPgXD4LaEK5qYfaz2asyOMAeZWexyJF2ADNhzlYqE V39OFS48NsFP2Ir60DB/9ov7m44iUB0HLxgn86ZnfM/YbHY5EJPl7GYlNpOsP2pZr7HR RNrulwmfvrLtQw3q5KibDnFJ1FbkVYgDSqY8O1UfO4AVJ5EjjZnLHZALXn3QGx/a/ZR7 tpQCo5801CwNnE9HEEgwr/aGs090XguMlvlpoVV0uUTU8fw8TWp35ox4fassnjKNdFRN dFUT5Qw1Z37nX1uvjxADiwpS+stuporD+HUrJdqa8v+0q/61K93RtGPu1gdeRcZSs/Nd QBoA== X-Gm-Message-State: AOJu0Yw4DTK4RzodoRq38a+su9nITtbXtXkRX1imChIT+jsTGCBCz9WS 0dW9HA6ZHHCH8XkODOl9aqSTx/mCTy0Kx4tX0JFluGz7mcu9Wmje7e6gPedCKnvIAopiULF7gZx WdbjiScG6ObHQFJyyR2gsRUeHLkTlR/HHYm8U61k= X-Gm-Gg: AeBDievEkdKPZmoxN52+E8g7rR7+B46KZz5RkZ7CE7M0/DnGZ6OeJz8kUvN1DCSB97/ LhzyxJp//z/L1bTECNc4LAzCJVUDbzE1RyI0xvusGESXgU4Q5GuWDDG6QtHdPFJH0DyMzyFHRsi Ha4uDocSg14fkKdS/Z+wiT5FpeqhFyZlLxn+Di4e5DHuzLdqUkvamvRumUIQuA18+dTC6o801a5 usvtpv7o2AxlhEqJCXQUC4aCYnp7MHwTlS5kJSa8wyF+9TKrSGY4XDjVL4J80zTH2O36OSA/grH uQ9wDtKNjDxPkyHuzcdq8fPIS56avoNWfqCr/WW3ziodYFbv+e4LIbjUf1z02yJzM0TdBsqgeV+ 1UF4TNgzTThAJg0iv3i8= X-Received: by 2002:a05:651c:1604:b0:38d:f09c:8607 with SMTP id 38308e7fff4ca-38ec7b2f39bmr5178001fa.25.1776410387560; Fri, 17 Apr 2026 00:19:47 -0700 (PDT) MIME-Version: 1.0 References: In-Reply-To: From: Amit Kapila Date: Fri, 17 Apr 2026 12:49:36 +0530 X-Gm-Features: AQROBzA6l3JwrMoX_V-H78Iq5tTegI3sPZbZ0Ldqc4ghzxtDNQFKuyESkGinstQ Message-ID: Subject: Re: Fix stats reporting delays in logical parallel apply worker To: "Zhijie Hou (Fujitsu)" Cc: PostgreSQL Hackers Content-Type: text/plain; charset="UTF-8" Content-Transfer-Encoding: quoted-printable List-Id: List-Help: List-Subscribe: List-Post: List-Owner: List-Archive: Archived-At: Precedence: bulk On Fri, Apr 17, 2026 at 8:31=E2=80=AFAM Zhijie Hou (Fujitsu) wrote: > > When implementing another feature, I noticed that parallel apply workers > currently do not report statistics while idle in their main loop. This ca= n cause > stats from the last processed transaction to be arbitrarily delayed, espe= cially > 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 transac= tion to > trigger a stats report. > > 0001 fixes this issue by forcing a stats report when the worker is idle i= n the > main loop, matching the behavior already present in LogicalRepApplyLoop()= for > regular logical apply workers. > LGTM. We should backpatch this change. --=20 With Regards, Amit Kapila.