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 1pFpli-0007i9-BD for pgsql-hackers@arkaria.postgresql.org; Thu, 12 Jan 2023 05:04:50 +0000 Received: from localhost ([127.0.0.1] helo=malur.postgresql.org) by malur.postgresql.org with esmtp (Exim 4.92) (envelope-from ) id 1pFplg-0004Q5-SF for pgsql-hackers@arkaria.postgresql.org; Thu, 12 Jan 2023 05:04:48 +0000 Received: from makus.postgresql.org ([2001:4800:3e1:1::229]) by malur.postgresql.org with esmtps (TLS1.3:ECDHE_RSA_AES_256_GCM_SHA384:256) (Exim 4.92) (envelope-from ) id 1pFplg-0004Pw-HG for pgsql-hackers@lists.postgresql.org; Thu, 12 Jan 2023 05:04:48 +0000 Received: from mail-ot1-x32b.google.com ([2607:f8b0:4864:20::32b]) by makus.postgresql.org with esmtps (TLS1.3:ECDHE_RSA_AES_128_GCM_SHA256:128) (Exim 4.92) (envelope-from ) id 1pFple-0004hy-5m for pgsql-hackers@lists.postgresql.org; Thu, 12 Jan 2023 05:04:47 +0000 Received: by mail-ot1-x32b.google.com with SMTP id p17-20020a9d6951000000b00678306ceb94so10019541oto.5 for ; Wed, 11 Jan 2023 21:04:46 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20210112; h=cc:to:subject:message-id:date:from:in-reply-to:references :mime-version:from:to:cc:subject:date:message-id:reply-to; bh=zYuWLed3FfDk3jfGbhL8Uam27GCM6UoJC5XP5vqwYgc=; b=I8gcabu/LZcncgo3iHawQlJoo7/iml95s8CwHabirUauNCv4b/zHYH0smoK2XRYWc1 Ggt3bysum6tQ9IvG1n/qW236gviyelyjVT7lPZO3dy7D/j/WF0gljqizL4mXVTHtp0BP +bDqHjpWkoIOhMbzVFI8A2sInLNKk/vYG6GRF1Izq9vco2KgtmO5CBxk6v4arEqbqVQS naSrhszirx7AelBxdxOQ4cRjayJVchqmauRlJvb6QVlYk3upLMTdai8GDKjT03oC3j74 nu1XqC1mLOutD3r0eWxTFBB2FBjm1bqdaruaAGIILuIb0i3ww5BHTf2yb4r6ZXiQPDJb 7dKg== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20210112; h=cc:to:subject:message-id:date:from:in-reply-to:references :mime-version:x-gm-message-state:from:to:cc:subject:date:message-id :reply-to; bh=zYuWLed3FfDk3jfGbhL8Uam27GCM6UoJC5XP5vqwYgc=; b=wFsQPB7T/KghO7OQP5DmlBUCjudzT+fBhio61HGmFwmcblsVxtOwS9NoHGntTl0uL/ vNTlNn7mXPiSHIpqJEKKbv6zaKNZHwffljtfA/S6BLjeLou1TFqbBerxqjCYRdA0EvLm T9WGgVQpJD96sgHG1Ncl9fiJydR6HuIB0sg2ZLDKN5SYVEaCiYqHJEBVWEM58F/hfPu1 CXlDBIcfbMBHzKIcCXmUOvrVkDNSwLFQOY0629NGh+AE80aOVt5pILjoAzUh86TNgCqU Iw7DXybwZm3tyCI1dfXthhxLTcK7GX/GxC6H8yHHvsVGmdUBVBVrVZNakMcSXcAQ9rmC 1W6Q== X-Gm-Message-State: AFqh2krgWYQoVN9IJPX108Ma8Xv4Sqjd9J8/WFqu+cH6e1Bh7qnDrRjF UIT7I1Xykl5Gk9eQTi0qy+H/BaLPTtbz5ai9HiI= X-Google-Smtp-Source: AMrXdXteoGHIdreRuLvFUYackalintQne0FMzC0KhXcYOZMZSHAwwZVtGj1L0jTi+x9xXBf/0OhRU6k5WrlE/gY/K+M= X-Received: by 2002:a05:6830:1612:b0:670:66a3:3319 with SMTP id g18-20020a056830161200b0067066a33319mr5283173otr.335.1673499885392; Wed, 11 Jan 2023 21:04:45 -0800 (PST) MIME-Version: 1.0 References: In-Reply-To: From: Amit Kapila Date: Thu, 12 Jan 2023 10:34:33 +0530 Message-ID: Subject: Re: Perform streaming logical transactions by background workers and parallel apply To: Peter Smith Cc: "houzj.fnst@fujitsu.com" , Masahiko Sawada , "wangw.fnst@fujitsu.com" , "shiy.fnst@fujitsu.com" , PostgreSQL Hackers , Dilip Kumar Content-Type: text/plain; charset="UTF-8" List-Id: List-Help: List-Subscribe: List-Post: List-Owner: List-Archive: Archived-At: Precedence: bulk On Thu, Jan 12, 2023 at 9:54 AM Peter Smith wrote: > > > doc/src/sgml/monitoring.sgml > > 5. pg_stat_subscription > > @@ -3198,11 +3198,22 @@ SELECT pid, wait_event_type, wait_event FROM > pg_stat_activity WHERE wait_event i > > > > + apply_leader_pid integer > + > + > + Process ID of the leader apply worker, if this process is a apply > + parallel worker. NULL if this process is a leader apply worker or a > + synchronization worker. > + > + > + > + > + > relid oid > > > OID of the relation that the worker is synchronizing; null for the > - main apply worker > + main apply worker and the parallel apply worker > > > > 5a. > > (Same as general comment #1 about terminology) > > "apply_leader_pid" --> "leader_apply_pid" > How about naming this as just leader_pid? I think it could be helpful in the future if we decide to parallelize initial sync (aka parallel copy) because then we could use this for the leader PID of parallel sync workers as well. -- With Regards, Amit Kapila.