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 1vRUXp-00ER3Y-1n for pgsql-general@arkaria.postgresql.org; Fri, 05 Dec 2025 12:04:17 +0000 Received: from localhost ([127.0.0.1] helo=malur.postgresql.org) by malur.postgresql.org with esmtp (Exim 4.96) (envelope-from ) id 1vRUXn-007nye-1B for pgsql-general@arkaria.postgresql.org; Fri, 05 Dec 2025 12:04:15 +0000 Received: from makus.postgresql.org ([2001:4800:3e1:1::229]) by malur.postgresql.org with esmtps (TLS1.3) tls TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384 (Exim 4.96) (envelope-from ) id 1vRUXm-007nyV-2L for pgsql-general@lists.postgresql.org; Fri, 05 Dec 2025 12:04:15 +0000 Received: from mail-ej1-x62d.google.com ([2a00:1450:4864:20::62d]) by makus.postgresql.org with esmtps (TLS1.3) tls TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256 (Exim 4.96) (envelope-from ) id 1vRUXj-003Gpd-1M for pgsql-general@postgresql.org; Fri, 05 Dec 2025 12:04:13 +0000 Received: by mail-ej1-x62d.google.com with SMTP id a640c23a62f3a-b7633027cb2so338510566b.1 for ; Fri, 05 Dec 2025 04:04:11 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=f10-com-br.20230601.gappssmtp.com; s=20230601; t=1764936248; x=1765541048; darn=postgresql.org; h=to:subject:message-id:date:from:mime-version:from:to:cc:subject :date:message-id:reply-to; bh=Ubb4/4tg1r74PWi1YB2PxDOlOjkOwV2N8o0MC+Bf+SI=; b=lKHaJpMLKbHB7V33J5jBotUIVnJ15x+lUl4Ejp4HxGbGZhejyr2y+eHzI/yW2VeSK5 lYI3MlVPNXSD5K7wUYZVh2ncXo8VkQVzW+Nc6KN3XPcRB/knEap0u08rgnNj4uQ0lNdV c6BVtxxyW2bvmbfuNjBQlmB0E5per7n6dLR8sg4Bl8kTfR3dVloDGbn2P6/JCF+BM00H dLAGlbZpUrMRVUMFhivEfV6+hMgPUmnU+CxocdT1KSRfSA+pjGn5dTeVYtyyCmYO1ceG LjSFln5NrOg/XlukAGRin6U5vDaRb1gkXTdQ1V1Etw12FlrI0M4hsvnkMlio8FvmWPg8 a5Bg== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20230601; t=1764936248; x=1765541048; h=to:subject:message-id:date:from:mime-version:x-gm-gg :x-gm-message-state:from:to:cc:subject:date:message-id:reply-to; bh=Ubb4/4tg1r74PWi1YB2PxDOlOjkOwV2N8o0MC+Bf+SI=; b=uW9iqXpvZIPOfN34+ErUd22HfLt0y3Dqgdwh0gy6vSSlM44pnzMsEQMO65yh+i+wNB 4PHEqVTPkd7Uia5tKIO2hmoBDVISxOaxGmoY3UBf2SkRvVxgmzvTiDftv0wn0OHSUbWB 1VjJOFfWDVY7K042MHQ8SdNRNNTJnl1esllpulTOjmkvTgZSJ2+0x9f0kNDJVN0lLW20 E0MAfE/GjXbIKH7AKTPGMI6tT2gQxeXJjXBXS/R8zwDbfA4mQujK0uA4SUNSgS13txhB EWzZ0Cw+tL8NUFWEl9VpN7IGO6bU5P0iN9YG622heBrjv/aqJ4ZqJ0XHX06Qd6JXdR8B 13Dg== X-Gm-Message-State: AOJu0Yz4rIvExDxXXHojfyIFyT6vGtJOyQXRA34rjnfeliCKRqUdO5P+ Vovd/sNnUYLg184kujsdqCui6oghjQMn7TvN61ED0J0YpXJR80cqBeC7UuN43LfgUUgEV15QafS 5z8Z3vlnEfxsE/T+MstrQTwDbrHIpLfajl6h2ovkGS7Y2vdGTy2hBtA== X-Gm-Gg: ASbGncuZODKjgUyhdfGgZYzVroHuV03kUkYhIhFA/aGHeYhTbgd8SqD8GacAuXxB80T 4/C/wbmZKw7VFtMqrhRTZ5t3k3ejDoKvRaFLRSnb2vES4qYvthqCaYwu/uQB/KiOqEuiW4gqKcN yUdxT/EzTEzXDzaMXctkvP2RyYDt6PoEbfu/OutC3FIyvLg90iQhybjQov5p+l5YGE6GKo4f2Hs vCgrgdhctm5s6LOEZK2VdOHJ4IZeZJZRDObAIp9PUhzXNw+1OxhfWlKqgpn3hpwpSaZfAk8Vw== X-Google-Smtp-Source: AGHT+IFGkl72px5JnsnzLXyaXJAIWGoMMc+dzVrmnEx0F7dwhJiRM/MfG3xoPOhYDjjk5x+oyGCx7dUQFGRWNDF0Hl8= X-Received: by 2002:a17:907:1b05:b0:b72:d9f1:75e5 with SMTP id a640c23a62f3a-b79dbe8d527mr1007748966b.20.1764936247871; Fri, 05 Dec 2025 04:04:07 -0800 (PST) MIME-Version: 1.0 From: Marcos Pegoraro Date: Fri, 5 Dec 2025 09:03:31 -0300 X-Gm-Features: AWmQ_bnmXWgPKRWFQUdsFJkJWxkDczG8IpWjDZ-UKOfRATYDlHj6-RqQqoVMeH8 Message-ID: Subject: Frosen logical replication To: Postgres General Content-Type: multipart/alternative; boundary="0000000000001b1c4f0645333ee4" List-Id: List-Help: List-Subscribe: List-Post: List-Owner: List-Archive: Archived-At: Precedence: bulk --0000000000001b1c4f0645333ee4 Content-Type: text/plain; charset="UTF-8" I have a logical replication where I want to replicate only one schema. This schema has auditing of every customer, so a thousand of tables, one for each customer CREATE PUBLICATION pub_a FOR TABLES IN SCHEMA audit; All worked fine, it copied all tables to subscriber, except one. That table has 8GB and it copied 5GB. That copy has been frozen since yesterday, as you can see. What can I do to solve this ? This select returns two records, first for processing WAL being generated and the second problematic record. # select usename, application_name, state_change, wait_event_type, wait_event, state, query, backend_type from pg_stat_activity where usename = 'replication_user'; -[ RECORD 1 ]----+---------------------------------------------------------------------------------------------------------------------------------------------------------------- usename | replication_user application_name | sub_a state_change | 2025-12-05 08:37:28.05245-03 wait_event_type | [null] wait_event | [null] state | active query | START_REPLICATION SLOT "sub_a" LOGICAL 3C14/6C6EA898 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"pub_a"') backend_type | walsender -[ RECORD 2 ]----+---------------------------------------------------------------------------------------------------------------------------------------------------------------- usename | replication_user application_name | pg_14944054_sync_29806_7565484157933843059 state_change | 2025-12-04 08:17:14.73826-03 wait_event_type | Client wait_event | ClientWrite state | active query | COPY audit.audit_0749 (audit_id, table_schema, table_name, primary_key, user_id, audit_action, audit_date_time, transaction_number, old, new) TO STDOUT backend_type | walsender regards Marcos --0000000000001b1c4f0645333ee4 Content-Type: text/html; charset="UTF-8" Content-Transfer-Encoding: quoted-printable
I have a logical replication where I wan= t to replicate only one schema.
This schema has audi= ting of every customer, so a thousand of tables, one for each customer
CREATE PUBLICATION pub_a FOR TABLES IN SCHEMA audit;
All worked fine, it copied all tables to subscriber, ex= cept one. That table has 8GB and it copied 5GB. That copy has been frozen s= ince yesterday, as you can see.

What can I do to solve=C2=A0this ?

This select returns two records, first for processing WA= L being generated and the second problematic record.

# select usename, application_name, state_chan= ge, wait_event_type, wait_event, state, query, backend_type from pg_stat_ac= tivity where usename =3D 'replication_user';
-[ RECORD 1 ]----+-= ---------------------------------------------------------------------------= ---------------------------------------------------------------------------= ---------
usename =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0| replication_userapplication_name | sub_a
state_change =C2=A0 =C2=A0 | 2025-12-05 08:37= :28.05245-03
wait_event_type =C2=A0| [null]
wait_event =C2=A0 =C2=A0 = =C2=A0 | [null]
state =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0| active<= br>query =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0| START_REPLICATION SLOT = "sub_a" LOGICAL 3C14/6C6EA898 (proto_version '4', streami= ng 'parallel', origin 'any', publication_names '"p= ub_a"')
backend_type =C2=A0 =C2=A0 | walsender
-[ RECORD 2 ]= ----+----------------------------------------------------------------------= ---------------------------------------------------------------------------= ---------------
usename =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0| replication_= user
application_name | pg_14944054_sync_29806_7565484157933843059
st= ate_change =C2=A0 =C2=A0 | 2025-12-04 08:17:14.73826-03
wait_event_type = =C2=A0| Client
wait_event =C2=A0 =C2=A0 =C2=A0 | ClientWrite
state = =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0| active
query =C2=A0 =C2=A0 = =C2=A0 =C2=A0 =C2=A0 =C2=A0| COPY audit.audit_0749 (audit_id, table_schema,= table_name, primary_key, user_id, audit_action, audit_date_time, transacti= on_number, old, new) TO STDOUT
backend_type =C2=A0 =C2=A0 | walsender

regards
Marcos
--0000000000001b1c4f0645333ee4--