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 1p8GGS-0007qS-8K for pgsql-hackers@arkaria.postgresql.org; Thu, 22 Dec 2022 07:45:16 +0000 Received: from localhost ([127.0.0.1] helo=malur.postgresql.org) by malur.postgresql.org with esmtp (Exim 4.92) (envelope-from ) id 1p8GGR-0001ut-7g for pgsql-hackers@arkaria.postgresql.org; Thu, 22 Dec 2022 07:45:15 +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 1p8GGQ-0001uk-TB for pgsql-hackers@lists.postgresql.org; Thu, 22 Dec 2022 07:45:14 +0000 Received: from mail-pf1-x436.google.com ([2607:f8b0:4864:20::436]) by magus.postgresql.org with esmtps (TLS1.3:ECDHE_RSA_AES_128_GCM_SHA256:128) (Exim 4.92) (envelope-from ) id 1p8GGO-0001Jn-LX for pgsql-hackers@lists.postgresql.org; Thu, 22 Dec 2022 07:45:14 +0000 Received: by mail-pf1-x436.google.com with SMTP id a14so679393pfa.1 for ; Wed, 21 Dec 2022 23:45:12 -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=TI3Gp6aHv2H1QMk+H/LK8SNJn97qcP2OsBahNcVFQKE=; b=ipa7McREsShgkf96RKqSqRDv5m0dGA3WJRaBoagovq11GHFbJXBiIqHeKqmDiigxO5 YByTcFBnXa5S//ruJRonAmhefBSP/oikZgJCmrGUl4a99Iav6y/DBb8HzHFCHQfIdTKw 2cGGAWNMPid+PtoHMxqKTzq8crQmcf4D+X8vtjU+kqCjVmNhqQqweQnBBhnv9VcPQOld LySHeIGZHQJTqJgibC1npv8e4FkkMdjLnbulOFe7fm9POhGTa6Gx7ZJK0JOfUwP7E4mP Rv5vl7FBgpH8Sm95cmg6CYg+TIltZW14DCDxm3Agt5J0j00CgJukJAduL9Vybi6/kTBh grqA== 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=TI3Gp6aHv2H1QMk+H/LK8SNJn97qcP2OsBahNcVFQKE=; b=oan1O4q5aXQ+To4HXfu9l01IaW4uuVcXLebbZRZ7AKo1UfNX3tPbgTZNg0AYwhiU7c TVD2AR4+vN/YvzJE9xjkhSVuBauviRCercNNibQTHvwVVnaoMCmyLMMHM+0DdtHZZZf4 l0MCj+fYUdPxXHrQyl0A0b1gSr1rz9Qt6wlZOqZR093a4iNumay45b5F1Xeaj/vsvgxG a4rx16gnQS4CYevMUI1zHHR7bKk/l3al1M5yVBIU7lHo6UzZ8VhMzKiiEVWEdLqPRmQb 6LpAMzHGuQXc93d0+XoVaUmvbZ6tiQbP8Hk+JXQ2zH/2XgWhLk1hhOUPN/4qiT9ZnYYD ZzKg== X-Gm-Message-State: AFqh2kp+bbV0A3fVis8sDqQ1ThFloEJVm+3LfoSEzgIWtbzahghuFWJm 3dzBO1X21oFZ2it8rdIdTF8= X-Google-Smtp-Source: AMrXdXtIJ+UNmrsYyy4Dtub89P1rlQYTzNiZKhrkr/0JEopoelGSAxyTmknJeZhIbGmiyYhs5j9BWA== X-Received: by 2002:a62:5292:0:b0:577:4168:b5ef with SMTP id g140-20020a625292000000b005774168b5efmr5407976pfb.3.1671695110695; Wed, 21 Dec 2022 23:45:10 -0800 (PST) Received: from localhost (KD036014041111.ppp-bb.dion.ne.jp. [36.14.41.111]) by smtp.gmail.com with ESMTPSA id h18-20020aa79f52000000b00576df4543d4sm11767946pfr.166.2022.12.21.23.45.08 (version=TLS1_3 cipher=TLS_CHACHA20_POLY1305_SHA256 bits=256/256); Wed, 21 Dec 2022 23:45:10 -0800 (PST) Date: Thu, 22 Dec 2022 16:45:07 +0900 (JST) Message-Id: <20221222.164507.1962968929109173863.horikyota.ntt@gmail.com> To: amit.kapila16@gmail.com Cc: sawada.mshk@gmail.com, shiy.fnst@fujitsu.com, smithpb2250@gmail.com, kuroda.hayato@fujitsu.com, dilipbalaut@gmail.com, pgsql-hackers@lists.postgresql.org Subject: Re: Force streaming every change in logical decoding From: Kyotaro Horiguchi In-Reply-To: References: 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 Thu, 22 Dec 2022 12:35:46 +0530, Amit Kapila wrote in > I have addressed these comments in the attached. Additionally, I have > modified the docs and commit messages to make those clear. I think > instead of adding new tests with this patch, it may be better to > change some of the existing tests related to streaming to use this > parameter as that will clearly show one of the purposes of this patch. Being late but I'm warried that we might sometime regret that the lack of the explicit default. Don't we really need it? + Allows streaming or serializing changes immediately in logical decoding. + The allowed values of logical_decoding_mode are the + empty string and immediate. When set to + immediate, stream each change if + streaming option is enabled, otherwise, serialize + each change. When set to an empty string, which is the default, + decoding will stream or serialize changes when + logical_decoding_work_mem is reached. With (really) fresh eyes, I took a bit long time to understand what the "streaming" option is. Couldn't we augment the description by a bit? regards. -- Kyotaro Horiguchi NTT Open Source Software Center