Received: from malur.postgresql.org ([217.196.149.56]) by arkaria.postgresql.org with esmtps (TLS1.3:ECDHE_RSA_AES_256_GCM_SHA384:256) (Exim 4.92) (envelope-from ) id 1p5dPu-0000Ey-VV for pgsql-hackers@arkaria.postgresql.org; Thu, 15 Dec 2022 01:52:10 +0000 Received: from localhost ([127.0.0.1] helo=malur.postgresql.org) by malur.postgresql.org with esmtp (Exim 4.92) (envelope-from ) id 1p5dPt-0001eE-Sf for pgsql-hackers@arkaria.postgresql.org; Thu, 15 Dec 2022 01:52:09 +0000 Received: from magus.postgresql.org ([2a02:c0:301:0:ffff::29]) by malur.postgresql.org with esmtps (TLS1.3:ECDHE_RSA_AES_256_GCM_SHA384:256) (Exim 4.92) (envelope-from ) id 1p5dPt-0001e4-HO for pgsql-hackers@lists.postgresql.org; Thu, 15 Dec 2022 01:52:09 +0000 Received: from mail-pj1-x102c.google.com ([2607:f8b0:4864:20::102c]) by magus.postgresql.org with esmtps (TLS1.3:ECDHE_RSA_AES_128_GCM_SHA256:128) (Exim 4.92) (envelope-from ) id 1p5dPr-0007xy-EL for pgsql-hackers@postgresql.org; Thu, 15 Dec 2022 01:52:09 +0000 Received: by mail-pj1-x102c.google.com with SMTP id fa4-20020a17090af0c400b002198d1328a0so5277631pjb.0 for ; Wed, 14 Dec 2022 17:52:06 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20210112; h=content-transfer-encoding:mime-version:user-agent:references :in-reply-to:from:subject:cc:to:message-id:date:from:to:cc:subject :date:message-id:reply-to; bh=XIcoPSmBQV8QIq2TcVOL600KczvBTGrOJXwfrsah74k=; b=iP1dzZ4p4vVdJBYdIlSKfS6akADM3ofOGy0ezJUVzKD4np4nubgdlYwXCH/9xPDB0l ehmUNixVVt4N4qIs2+iGGKLeBwlHdVcZA+ii3oFoDKwY/izwCQcpygroCTbld7XnrdOu 6lowaOBHSW6peBnJPQDbmtCDRrr5wsPdoYvSjamycbutdo9/2bAa9b1vtnsxS0sIVDta LQfbrc5NZFdFsgh/+ZfAV2xNzNBzwW+Uc+q7yuXYwrdBsJR+OxMPGuY8JVvRvNMIeJkS D5I2n+PXmoMMQ3YWBqf8e8d8JTaLs/2Uo000kVNItqG7im2S2ku140HM7zfG24REA0qW 5maA== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20210112; h=content-transfer-encoding:mime-version:user-agent:references :in-reply-to:from:subject:cc:to:message-id:date:x-gm-message-state :from:to:cc:subject:date:message-id:reply-to; bh=XIcoPSmBQV8QIq2TcVOL600KczvBTGrOJXwfrsah74k=; b=DaOQ416XQPJq8pVgZNcC9ofV3fj3m9qJPsI8UKsuseN0b/OaRWyLv3qN33HP8ZXNyf ByB7IBbFgcnZ2cCYVeRGVPq5sPZ7ya1v1hkJDq25o1/IsABURtAScSl94MpfxppcQj1M 7/VcUBcPSHndrW4vQrh8OgYJRY8FLWDzsy1rjPbmL0knMu7Imv6HhrgFoEM+YaEuoYlX nSqCJJdVUO6f0z6D7Hi2sTT9oRsrWbW7RwrpQlUIgRLfRk7s6d9lk5hrOdt4CskxQnKS OibfGDwqBM4f5A6cRJGwjLinXv8l6rk9BFA83DH3d2XdCqwymvE5vjsmpTgfS+C0f2Ze 9jzA== X-Gm-Message-State: AFqh2krFE6tfvvFp/y3EbmBomOOQd0/wg4DazU978hA+GuvGjOoy3SPI b6BPRulwyTFlMxmBG4ZWop8= X-Google-Smtp-Source: AMrXdXtcZQAazr+H80R+u+SBuNFU2etbWFn0MiGqyY4EDm1wp75YZdJkDgaGELkeNYUJQ1hwMH2Vpw== X-Received: by 2002:a17:902:7d8a:b0:190:edc5:a4e6 with SMTP id a10-20020a1709027d8a00b00190edc5a4e6mr3006996plm.13.1671069124393; Wed, 14 Dec 2022 17:52:04 -0800 (PST) Received: from localhost (KD036014041111.ppp-bb.dion.ne.jp. [36.14.41.111]) by smtp.gmail.com with ESMTPSA id z14-20020a170903018e00b001891a17bd93sm2509193plg.43.2022.12.14.17.52.01 (version=TLS1_3 cipher=TLS_CHACHA20_POLY1305_SHA256 bits=256/256); Wed, 14 Dec 2022 17:52:03 -0800 (PST) Date: Thu, 15 Dec 2022 10:52:00 +0900 (JST) Message-Id: <20221215.105200.268327207020006785.horikyota.ntt@gmail.com> To: amit.kapila16@gmail.com Cc: kuroda.hayato@fujitsu.com, osumi.takamichi@fujitsu.com, vignesh21@gmail.com, euler@eulerto.com, m.melihmutlu@gmail.com, andres@anarazel.de, marcos@f10.com.br, pgsql-hackers@postgresql.org, smithpb2250@gmail.com Subject: Re: Time delayed LR (WAS Re: logical replication restrictions) From: Kyotaro Horiguchi In-Reply-To: References: <20221214.103502.2162519943436870668.horikyota.ntt@gmail.com> User-Agent: Mew version 6.8 on Emacs 26.1 Mime-Version: 1.0 Content-Type: Text/Plain; charset=us-ascii Content-Transfer-Encoding: 7bit List-Id: List-Help: List-Subscribe: List-Post: List-Owner: List-Archive: Archived-At: Precedence: bulk At Wed, 14 Dec 2022 16:30:28 +0530, Amit Kapila wrote in > On Wed, Dec 14, 2022 at 4:16 PM Hayato Kuroda (Fujitsu) > wrote: > > One idea to avoid that is to send the min_apply_delay subscriber option to publisher > > and compare them, but it may be not sufficient. Because XXX_timout GUC parameters > > could be modified later. > > > > How about restarting the apply worker if min_apply_delay changes? Will > that be sufficient? Mmm. If publisher knows that value, isn't it albe to delay *sending* data in the first place? This will resolve many known issues including walsender's un-terminatability, possible buffer-full and status packet exchanging. regards. -- Kyotaro Horiguchi NTT Open Source Software Center