2025-01-31 07:52:40.782 GMT [7116][postmaster] LOG: starting PostgreSQL 18devel on x86_64-windows, compiled by msvc-19.29.30158, 64-bit 2025-01-31 07:52:40.784 GMT [7116][postmaster] LOG: listening on Unix socket "C:/Windows/TEMP/l73QjJHWmL/.s.PGSQL.19436" 2025-01-31 07:52:40.807 GMT [7748][startup] LOG: database system was shut down at 2025-01-31 07:44:57 GMT 2025-01-31 07:52:40.814 GMT [7116][postmaster] LOG: database system is ready to accept connections 2025-01-31 07:52:42.363 GMT [696][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:42.365 GMT [696][client backend] [[unknown]][0/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:42.365 GMT [696][client backend] [[unknown]][0/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=014_binary.pl 2025-01-31 07:52:42.388 GMT [696][client backend] [014_binary.pl][0/2:0] LOG: statement: CREATE TABLE public.test_numerical ( a INTEGER PRIMARY KEY, b NUMERIC, c FLOAT, d BIGINT ); 2025-01-31 07:52:42.400 GMT [696][client backend] [014_binary.pl][0/3:0] LOG: statement: CREATE TABLE public.test_arrays ( a INTEGER[] PRIMARY KEY, b NUMERIC[], c TEXT[] ); 2025-01-31 07:52:42.407 GMT [696][client backend] [014_binary.pl][:0] LOG: disconnection: session time: 0:00:00.048 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:42.585 GMT [1812][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:42.586 GMT [1812][client backend] [[unknown]][1/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:42.586 GMT [1812][client backend] [[unknown]][1/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=014_binary.pl 2025-01-31 07:52:42.591 GMT [1812][client backend] [014_binary.pl][1/2:0] LOG: statement: CREATE PUBLICATION tpub FOR ALL TABLES 2025-01-31 07:52:42.593 GMT [1812][client backend] [014_binary.pl][:0] LOG: disconnection: session time: 0:00:00.012 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:42.658 GMT [3312][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:42.659 GMT [3312][client backend] [[unknown]][2/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:42.659 GMT [3312][client backend] [[unknown]][2/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=014_binary.pl 2025-01-31 07:52:42.677 GMT [3312][client backend] [014_binary.pl][2/2:0] LOG: statement: INSERT INTO public.test_numerical (a, b, c, d) VALUES (1, 1.2, 1.3, 10), (2, 2.2, 2.3, 20); 2025-01-31 07:52:42.679 GMT [3312][client backend] [014_binary.pl][2/3:0] LOG: statement: INSERT INTO public.test_arrays (a, b, c) VALUES ('{1,2,3}', '{1.1, 1.2, 1.3}', '{"one", "two", "three"}'), ('{3,1,2}', '{1.3, 1.1, 1.2}', '{"three", "one", "two"}'); 2025-01-31 07:52:42.682 GMT [3312][client backend] [014_binary.pl][:0] LOG: disconnection: session time: 0:00:00.027 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:42.813 GMT [4864][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:42.814 GMT [4864][walsender] [[unknown]][23/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:42.814 GMT [4864][walsender] [[unknown]][23/1:0] LOG: replication connection authorized: user=SYSTEM application_name=tsub 2025-01-31 07:52:42.818 GMT [4864][walsender] [tsub][23/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2025-01-31 07:52:42.820 GMT [4864][walsender] [tsub][23/3:0] LOG: statement: SELECT t.pubname FROM pg_catalog.pg_publication t WHERE t.pubname IN ('tpub') 2025-01-31 07:52:42.824 GMT [4864][walsender] [tsub][23/4:0] LOG: statement: SELECT DISTINCT n.nspname, c.relname, gpt.attrs FROM pg_class c JOIN pg_namespace n ON n.oid = c.relnamespace JOIN ( SELECT (pg_get_publication_tables(VARIADIC array_agg(pubname::text))).* FROM pg_publication WHERE pubname IN ( 'tpub' )) AS gpt ON gpt.relid = c.oid 2025-01-31 07:52:42.835 GMT [4864][walsender] [tsub][23/0:0] LOG: received replication command: CREATE_REPLICATION_SLOT "tpub_slot" LOGICAL pgoutput (SNAPSHOT 'nothing') 2025-01-31 07:52:42.835 GMT [4864][walsender] [tsub][23/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tpub_slot" LOGICAL pgoutput (SNAPSHOT 'nothing') 2025-01-31 07:52:42.842 GMT [4864][walsender] [tsub][23/0:0] LOG: logical decoding found consistent point at 0/179AB40 2025-01-31 07:52:42.842 GMT [4864][walsender] [tsub][23/0:0] DETAIL: There are no running transactions. 2025-01-31 07:52:42.842 GMT [4864][walsender] [tsub][23/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tpub_slot" LOGICAL pgoutput (SNAPSHOT 'nothing') 2025-01-31 07:52:42.844 GMT [4864][walsender] [tsub][23/0:0] LOG: released logical replication slot "tpub_slot" 2025-01-31 07:52:42.844 GMT [4864][walsender] [tsub][23/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tpub_slot" LOGICAL pgoutput (SNAPSHOT 'nothing') 2025-01-31 07:52:42.844 GMT [4864][walsender] [tsub][:0] LOG: disconnection: session time: 0:00:00.035 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:42.893 GMT [5224][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:42.894 GMT [5224][walsender] [[unknown]][24/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:42.894 GMT [5224][walsender] [[unknown]][24/1:0] LOG: replication connection authorized: user=SYSTEM application_name=tsub 2025-01-31 07:52:42.899 GMT [5224][walsender] [tsub][24/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2025-01-31 07:52:42.900 GMT [5224][walsender] [tsub][24/0:0] LOG: received replication command: IDENTIFY_SYSTEM 2025-01-31 07:52:42.900 GMT [5224][walsender] [tsub][24/0:0] STATEMENT: IDENTIFY_SYSTEM 2025-01-31 07:52:42.900 GMT [5224][walsender] [tsub][24/0:0] LOG: received replication command: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:42.900 GMT [5224][walsender] [tsub][24/0:0] STATEMENT: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:42.900 GMT [5224][walsender] [tsub][24/0:0] LOG: acquired logical replication slot "tpub_slot" 2025-01-31 07:52:42.900 GMT [5224][walsender] [tsub][24/0:0] STATEMENT: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:42.901 GMT [5224][walsender] [tsub][24/0:0] LOG: starting logical decoding for slot "tpub_slot" 2025-01-31 07:52:42.901 GMT [5224][walsender] [tsub][24/0:0] DETAIL: Streaming transactions committing after 0/179AB78, reading WAL from 0/179AB40. 2025-01-31 07:52:42.901 GMT [5224][walsender] [tsub][24/0:0] STATEMENT: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:42.901 GMT [5224][walsender] [tsub][24/0:0] LOG: logical decoding found consistent point at 0/179AB40 2025-01-31 07:52:42.901 GMT [5224][walsender] [tsub][24/0:0] DETAIL: There are no running transactions. 2025-01-31 07:52:42.901 GMT [5224][walsender] [tsub][24/0:0] STATEMENT: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:42.976 GMT [4892][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:42.978 GMT [4892][walsender] [[unknown]][25/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:42.978 GMT [4892][walsender] [[unknown]][25/1:0] LOG: replication connection authorized: user=SYSTEM application_name=pg_16400_sync_16392_7465982433180864044 2025-01-31 07:52:42.981 GMT [4892][walsender] [pg_16400_sync_16392_7465982433180864044][25/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2025-01-31 07:52:42.982 GMT [4892][walsender] [pg_16400_sync_16392_7465982433180864044][25/3:0] LOG: statement: BEGIN READ ONLY ISOLATION LEVEL REPEATABLE READ 2025-01-31 07:52:42.983 GMT [4892][walsender] [pg_16400_sync_16392_7465982433180864044][25/3:0] LOG: received replication command: CREATE_REPLICATION_SLOT "pg_16400_sync_16392_7465982433180864044" LOGICAL pgoutput (SNAPSHOT 'use') 2025-01-31 07:52:42.983 GMT [4892][walsender] [pg_16400_sync_16392_7465982433180864044][25/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16400_sync_16392_7465982433180864044" LOGICAL pgoutput (SNAPSHOT 'use') 2025-01-31 07:52:42.987 GMT [4892][walsender] [pg_16400_sync_16392_7465982433180864044][25/3:0] LOG: logical decoding found consistent point at 0/179AB78 2025-01-31 07:52:42.987 GMT [4892][walsender] [pg_16400_sync_16392_7465982433180864044][25/3:0] DETAIL: There are no running transactions. 2025-01-31 07:52:42.987 GMT [4892][walsender] [pg_16400_sync_16392_7465982433180864044][25/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16400_sync_16392_7465982433180864044" LOGICAL pgoutput (SNAPSHOT 'use') 2025-01-31 07:52:43.006 GMT [4892][walsender] [pg_16400_sync_16392_7465982433180864044][25/3:0] LOG: released logical replication slot "pg_16400_sync_16392_7465982433180864044" 2025-01-31 07:52:43.006 GMT [4892][walsender] [pg_16400_sync_16392_7465982433180864044][25/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16400_sync_16392_7465982433180864044" LOGICAL pgoutput (SNAPSHOT 'use') 2025-01-31 07:52:43.007 GMT [4892][walsender] [pg_16400_sync_16392_7465982433180864044][25/3:0] LOG: statement: SELECT c.oid, c.relreplident, c.relkind FROM pg_catalog.pg_class c INNER JOIN pg_catalog.pg_namespace n ON (c.relnamespace = n.oid) WHERE n.nspname = 'public' AND c.relname = 'test_arrays' 2025-01-31 07:52:43.013 GMT [4892][walsender] [pg_16400_sync_16392_7465982433180864044][25/3:0] LOG: statement: SELECT DISTINCT (CASE WHEN (array_length(gpt.attrs, 1) = c.relnatts) THEN NULL ELSE gpt.attrs END) FROM pg_publication p, LATERAL pg_get_publication_tables(p.pubname) gpt, pg_class c WHERE gpt.relid = 16392 AND c.oid = gpt.relid AND p.pubname IN ( 'tpub' ) 2025-01-31 07:52:43.018 GMT [4892][walsender] [pg_16400_sync_16392_7465982433180864044][25/3:0] LOG: statement: SELECT a.attnum, a.attname, a.atttypid, a.attnum = ANY(i.indkey), a.attgenerated != '' FROM pg_catalog.pg_attribute a LEFT JOIN pg_catalog.pg_index i ON (i.indexrelid = pg_get_replica_identity_index(16392)) WHERE a.attnum > 0::pg_catalog.int2 AND NOT a.attisdropped AND a.attrelid = 16392 ORDER BY a.attnum 2025-01-31 07:52:43.021 GMT [4892][walsender] [pg_16400_sync_16392_7465982433180864044][25/3:0] LOG: statement: SELECT DISTINCT pg_get_expr(gpt.qual, gpt.relid) FROM pg_publication p, LATERAL pg_get_publication_tables(p.pubname) gpt WHERE gpt.relid = 16392 AND p.pubname IN ( 'tpub' ) 2025-01-31 07:52:43.023 GMT [4892][walsender] [pg_16400_sync_16392_7465982433180864044][25/3:0] LOG: statement: COPY public.test_arrays (a, b, c) TO STDOUT WITH (FORMAT binary) 2025-01-31 07:52:43.024 GMT [4892][walsender] [pg_16400_sync_16392_7465982433180864044][25/3:0] LOG: statement: COMMIT 2025-01-31 07:52:43.025 GMT [4892][walsender] [pg_16400_sync_16392_7465982433180864044][25/0:0] LOG: received replication command: START_REPLICATION SLOT "pg_16400_sync_16392_7465982433180864044" LOGICAL 0/179ABB0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:43.025 GMT [4892][walsender] [pg_16400_sync_16392_7465982433180864044][25/0:0] STATEMENT: START_REPLICATION SLOT "pg_16400_sync_16392_7465982433180864044" LOGICAL 0/179ABB0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:43.025 GMT [4892][walsender] [pg_16400_sync_16392_7465982433180864044][25/0:0] LOG: acquired logical replication slot "pg_16400_sync_16392_7465982433180864044" 2025-01-31 07:52:43.025 GMT [4892][walsender] [pg_16400_sync_16392_7465982433180864044][25/0:0] STATEMENT: START_REPLICATION SLOT "pg_16400_sync_16392_7465982433180864044" LOGICAL 0/179ABB0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:43.025 GMT [4892][walsender] [pg_16400_sync_16392_7465982433180864044][25/0:0] LOG: starting logical decoding for slot "pg_16400_sync_16392_7465982433180864044" 2025-01-31 07:52:43.025 GMT [4892][walsender] [pg_16400_sync_16392_7465982433180864044][25/0:0] DETAIL: Streaming transactions committing after 0/179ABB0, reading WAL from 0/179AB78. 2025-01-31 07:52:43.025 GMT [4892][walsender] [pg_16400_sync_16392_7465982433180864044][25/0:0] STATEMENT: START_REPLICATION SLOT "pg_16400_sync_16392_7465982433180864044" LOGICAL 0/179ABB0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:43.025 GMT [4892][walsender] [pg_16400_sync_16392_7465982433180864044][25/0:0] LOG: logical decoding found consistent point at 0/179AB78 2025-01-31 07:52:43.025 GMT [4892][walsender] [pg_16400_sync_16392_7465982433180864044][25/0:0] DETAIL: There are no running transactions. 2025-01-31 07:52:43.025 GMT [4892][walsender] [pg_16400_sync_16392_7465982433180864044][25/0:0] STATEMENT: START_REPLICATION SLOT "pg_16400_sync_16392_7465982433180864044" LOGICAL 0/179ABB0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:43.026 GMT [4892][walsender] [pg_16400_sync_16392_7465982433180864044][25/0:0] LOG: released logical replication slot "pg_16400_sync_16392_7465982433180864044" 2025-01-31 07:52:43.026 GMT [4892][walsender] [pg_16400_sync_16392_7465982433180864044][25/0:0] STATEMENT: START_REPLICATION SLOT "pg_16400_sync_16392_7465982433180864044" LOGICAL 0/179ABB0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:43.026 GMT [4892][walsender] [pg_16400_sync_16392_7465982433180864044][25/0:0] LOG: received replication command: DROP_REPLICATION_SLOT pg_16400_sync_16392_7465982433180864044 WAIT 2025-01-31 07:52:43.026 GMT [4892][walsender] [pg_16400_sync_16392_7465982433180864044][25/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16400_sync_16392_7465982433180864044 WAIT 2025-01-31 07:52:43.026 GMT [4892][walsender] [pg_16400_sync_16392_7465982433180864044][25/0:0] LOG: acquired logical replication slot "pg_16400_sync_16392_7465982433180864044" 2025-01-31 07:52:43.026 GMT [4892][walsender] [pg_16400_sync_16392_7465982433180864044][25/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16400_sync_16392_7465982433180864044 WAIT 2025-01-31 07:52:43.027 GMT [4892][walsender] [pg_16400_sync_16392_7465982433180864044][:0] LOG: disconnection: session time: 0:00:00.055 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:43.042 GMT [5748][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:43.043 GMT [5748][walsender] [[unknown]][26/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:43.043 GMT [5748][walsender] [[unknown]][26/1:0] LOG: replication connection authorized: user=SYSTEM application_name=pg_16400_sync_16384_7465982433180864044 2025-01-31 07:52:43.048 GMT [5748][walsender] [pg_16400_sync_16384_7465982433180864044][26/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2025-01-31 07:52:43.049 GMT [5748][walsender] [pg_16400_sync_16384_7465982433180864044][26/3:0] LOG: statement: BEGIN READ ONLY ISOLATION LEVEL REPEATABLE READ 2025-01-31 07:52:43.049 GMT [5748][walsender] [pg_16400_sync_16384_7465982433180864044][26/3:0] LOG: received replication command: CREATE_REPLICATION_SLOT "pg_16400_sync_16384_7465982433180864044" LOGICAL pgoutput (SNAPSHOT 'use') 2025-01-31 07:52:43.049 GMT [5748][walsender] [pg_16400_sync_16384_7465982433180864044][26/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16400_sync_16384_7465982433180864044" LOGICAL pgoutput (SNAPSHOT 'use') 2025-01-31 07:52:43.062 GMT [5748][walsender] [pg_16400_sync_16384_7465982433180864044][26/3:0] LOG: logical decoding found consistent point at 0/179ABB0 2025-01-31 07:52:43.062 GMT [5748][walsender] [pg_16400_sync_16384_7465982433180864044][26/3:0] DETAIL: There are no running transactions. 2025-01-31 07:52:43.062 GMT [5748][walsender] [pg_16400_sync_16384_7465982433180864044][26/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16400_sync_16384_7465982433180864044" LOGICAL pgoutput (SNAPSHOT 'use') 2025-01-31 07:52:43.200 GMT [5748][walsender] [pg_16400_sync_16384_7465982433180864044][26/3:0] LOG: released logical replication slot "pg_16400_sync_16384_7465982433180864044" 2025-01-31 07:52:43.200 GMT [5748][walsender] [pg_16400_sync_16384_7465982433180864044][26/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16400_sync_16384_7465982433180864044" LOGICAL pgoutput (SNAPSHOT 'use') 2025-01-31 07:52:43.201 GMT [5748][walsender] [pg_16400_sync_16384_7465982433180864044][26/3:0] LOG: statement: SELECT c.oid, c.relreplident, c.relkind FROM pg_catalog.pg_class c INNER JOIN pg_catalog.pg_namespace n ON (c.relnamespace = n.oid) WHERE n.nspname = 'public' AND c.relname = 'test_numerical' 2025-01-31 07:52:43.206 GMT [5748][walsender] [pg_16400_sync_16384_7465982433180864044][26/3:0] LOG: statement: SELECT DISTINCT (CASE WHEN (array_length(gpt.attrs, 1) = c.relnatts) THEN NULL ELSE gpt.attrs END) FROM pg_publication p, LATERAL pg_get_publication_tables(p.pubname) gpt, pg_class c WHERE gpt.relid = 16384 AND c.oid = gpt.relid AND p.pubname IN ( 'tpub' ) 2025-01-31 07:52:43.210 GMT [5748][walsender] [pg_16400_sync_16384_7465982433180864044][26/3:0] LOG: statement: SELECT a.attnum, a.attname, a.atttypid, a.attnum = ANY(i.indkey), a.attgenerated != '' FROM pg_catalog.pg_attribute a LEFT JOIN pg_catalog.pg_index i ON (i.indexrelid = pg_get_replica_identity_index(16384)) WHERE a.attnum > 0::pg_catalog.int2 AND NOT a.attisdropped AND a.attrelid = 16384 ORDER BY a.attnum 2025-01-31 07:52:43.212 GMT [5748][walsender] [pg_16400_sync_16384_7465982433180864044][26/3:0] LOG: statement: SELECT DISTINCT pg_get_expr(gpt.qual, gpt.relid) FROM pg_publication p, LATERAL pg_get_publication_tables(p.pubname) gpt WHERE gpt.relid = 16384 AND p.pubname IN ( 'tpub' ) 2025-01-31 07:52:43.214 GMT [5748][walsender] [pg_16400_sync_16384_7465982433180864044][26/3:0] LOG: statement: COPY public.test_numerical (a, b, c, d) TO STDOUT WITH (FORMAT binary) 2025-01-31 07:52:43.215 GMT [5748][walsender] [pg_16400_sync_16384_7465982433180864044][26/3:0] LOG: statement: COMMIT 2025-01-31 07:52:43.215 GMT [5748][walsender] [pg_16400_sync_16384_7465982433180864044][26/0:0] LOG: received replication command: START_REPLICATION SLOT "pg_16400_sync_16384_7465982433180864044" LOGICAL 0/179ABE8 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:43.215 GMT [5748][walsender] [pg_16400_sync_16384_7465982433180864044][26/0:0] STATEMENT: START_REPLICATION SLOT "pg_16400_sync_16384_7465982433180864044" LOGICAL 0/179ABE8 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:43.215 GMT [5748][walsender] [pg_16400_sync_16384_7465982433180864044][26/0:0] LOG: acquired logical replication slot "pg_16400_sync_16384_7465982433180864044" 2025-01-31 07:52:43.215 GMT [5748][walsender] [pg_16400_sync_16384_7465982433180864044][26/0:0] STATEMENT: START_REPLICATION SLOT "pg_16400_sync_16384_7465982433180864044" LOGICAL 0/179ABE8 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:43.215 GMT [5748][walsender] [pg_16400_sync_16384_7465982433180864044][26/0:0] LOG: starting logical decoding for slot "pg_16400_sync_16384_7465982433180864044" 2025-01-31 07:52:43.215 GMT [5748][walsender] [pg_16400_sync_16384_7465982433180864044][26/0:0] DETAIL: Streaming transactions committing after 0/179ABE8, reading WAL from 0/179ABB0. 2025-01-31 07:52:43.215 GMT [5748][walsender] [pg_16400_sync_16384_7465982433180864044][26/0:0] STATEMENT: START_REPLICATION SLOT "pg_16400_sync_16384_7465982433180864044" LOGICAL 0/179ABE8 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:43.216 GMT [5748][walsender] [pg_16400_sync_16384_7465982433180864044][26/0:0] LOG: logical decoding found consistent point at 0/179ABB0 2025-01-31 07:52:43.216 GMT [5748][walsender] [pg_16400_sync_16384_7465982433180864044][26/0:0] DETAIL: There are no running transactions. 2025-01-31 07:52:43.216 GMT [5748][walsender] [pg_16400_sync_16384_7465982433180864044][26/0:0] STATEMENT: START_REPLICATION SLOT "pg_16400_sync_16384_7465982433180864044" LOGICAL 0/179ABE8 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:43.216 GMT [5748][walsender] [pg_16400_sync_16384_7465982433180864044][26/0:0] LOG: released logical replication slot "pg_16400_sync_16384_7465982433180864044" 2025-01-31 07:52:43.216 GMT [5748][walsender] [pg_16400_sync_16384_7465982433180864044][26/0:0] STATEMENT: START_REPLICATION SLOT "pg_16400_sync_16384_7465982433180864044" LOGICAL 0/179ABE8 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:43.216 GMT [5748][walsender] [pg_16400_sync_16384_7465982433180864044][26/0:0] LOG: received replication command: DROP_REPLICATION_SLOT pg_16400_sync_16384_7465982433180864044 WAIT 2025-01-31 07:52:43.216 GMT [5748][walsender] [pg_16400_sync_16384_7465982433180864044][26/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16400_sync_16384_7465982433180864044 WAIT 2025-01-31 07:52:43.216 GMT [5748][walsender] [pg_16400_sync_16384_7465982433180864044][26/0:0] LOG: acquired logical replication slot "pg_16400_sync_16384_7465982433180864044" 2025-01-31 07:52:43.216 GMT [5748][walsender] [pg_16400_sync_16384_7465982433180864044][26/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16400_sync_16384_7465982433180864044 WAIT 2025-01-31 07:52:43.218 GMT [5748][walsender] [pg_16400_sync_16384_7465982433180864044][:0] LOG: disconnection: session time: 0:00:00.179 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:43.376 GMT [5608][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:43.378 GMT [5608][client backend] [[unknown]][3/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:43.378 GMT [5608][client backend] [[unknown]][3/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=014_binary.pl 2025-01-31 07:52:43.383 GMT [5608][client backend] [014_binary.pl][3/2:0] LOG: statement: SELECT pg_is_in_recovery() 2025-01-31 07:52:43.387 GMT [5608][client backend] [014_binary.pl][:0] LOG: disconnection: session time: 0:00:00.014 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:43.470 GMT [1268][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:43.473 GMT [1268][client backend] [[unknown]][4/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:43.474 GMT [1268][client backend] [[unknown]][4/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=014_binary.pl 2025-01-31 07:52:43.483 GMT [1268][client backend] [014_binary.pl][4/2:0] LOG: statement: SELECT pg_current_wal_lsn() 2025-01-31 07:52:43.486 GMT [1268][client backend] [014_binary.pl][:0] LOG: disconnection: session time: 0:00:00.020 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:43.594 GMT [4304][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:43.595 GMT [4304][client backend] [[unknown]][5/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:43.595 GMT [4304][client backend] [[unknown]][5/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=014_binary.pl 2025-01-31 07:52:43.599 GMT [4304][client backend] [014_binary.pl][5/2:0] LOG: statement: SELECT '0/179ABE8' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tsub', 'walreceiver') 2025-01-31 07:52:43.610 GMT [4304][client backend] [014_binary.pl][:0] LOG: disconnection: session time: 0:00:00.019 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:43.759 GMT [424][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:43.762 GMT [424][client backend] [[unknown]][6/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:43.762 GMT [424][client backend] [[unknown]][6/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=014_binary.pl 2025-01-31 07:52:43.767 GMT [424][client backend] [014_binary.pl][6/2:0] LOG: statement: INSERT INTO public.test_arrays (a, b, c) VALUES ('{2,1,3}', '{1.2, 1.1, 1.3}', '{"two", "one", "three"}'), ('{1,3,2}', '{1.1, 1.3, 1.2}', '{"one", "three", "two"}'); 2025-01-31 07:52:43.769 GMT [424][client backend] [014_binary.pl][6/3:0] LOG: statement: INSERT INTO public.test_numerical (a, b, c, d) VALUES (3, 3.2, 3.3, 30), (4, 4.2, 4.3, 40); 2025-01-31 07:52:43.770 GMT [424][client backend] [014_binary.pl][:0] LOG: disconnection: session time: 0:00:00.022 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:43.831 GMT [5428][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:43.833 GMT [5428][client backend] [[unknown]][7/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:43.833 GMT [5428][client backend] [[unknown]][7/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=014_binary.pl 2025-01-31 07:52:43.836 GMT [5428][client backend] [014_binary.pl][7/2:0] LOG: statement: SELECT pg_is_in_recovery() 2025-01-31 07:52:43.839 GMT [5428][client backend] [014_binary.pl][:0] LOG: disconnection: session time: 0:00:00.010 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:43.915 GMT [8004][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:43.917 GMT [8004][client backend] [[unknown]][8/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:43.917 GMT [8004][client backend] [[unknown]][8/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=014_binary.pl 2025-01-31 07:52:43.921 GMT [8004][client backend] [014_binary.pl][8/2:0] LOG: statement: SELECT pg_current_wal_lsn() 2025-01-31 07:52:43.924 GMT [8004][client backend] [014_binary.pl][:0] LOG: disconnection: session time: 0:00:00.015 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:44.006 GMT [5460][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:44.007 GMT [5460][client backend] [[unknown]][9/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:44.007 GMT [5460][client backend] [[unknown]][9/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=014_binary.pl 2025-01-31 07:52:44.011 GMT [5460][client backend] [014_binary.pl][9/2:0] LOG: statement: SELECT '0/179AFC8' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tsub', 'walreceiver') 2025-01-31 07:52:44.020 GMT [5460][client backend] [014_binary.pl][:0] LOG: disconnection: session time: 0:00:00.019 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:44.254 GMT [6740][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:44.255 GMT [6740][client backend] [[unknown]][0/4:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:44.255 GMT [6740][client backend] [[unknown]][0/4:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=014_binary.pl 2025-01-31 07:52:44.258 GMT [6740][client backend] [014_binary.pl][0/5:0] LOG: statement: UPDATE public.test_arrays SET b[1] = 42, c = NULL; 2025-01-31 07:52:44.261 GMT [6740][client backend] [014_binary.pl][0/6:0] LOG: statement: UPDATE public.test_numerical SET b = 42, c = NULL; 2025-01-31 07:52:44.262 GMT [6740][client backend] [014_binary.pl][:0] LOG: disconnection: session time: 0:00:00.012 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:44.362 GMT [1096][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:44.364 GMT [1096][client backend] [[unknown]][1/3:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:44.364 GMT [1096][client backend] [[unknown]][1/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=014_binary.pl 2025-01-31 07:52:44.367 GMT [1096][client backend] [014_binary.pl][1/4:0] LOG: statement: SELECT pg_is_in_recovery() 2025-01-31 07:52:44.372 GMT [1096][client backend] [014_binary.pl][:0] LOG: disconnection: session time: 0:00:00.013 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:44.495 GMT [6024][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:44.496 GMT [6024][client backend] [[unknown]][2/4:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:44.496 GMT [6024][client backend] [[unknown]][2/4:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=014_binary.pl 2025-01-31 07:52:44.500 GMT [6024][client backend] [014_binary.pl][2/5:0] LOG: statement: SELECT pg_current_wal_lsn() 2025-01-31 07:52:44.504 GMT [6024][client backend] [014_binary.pl][:0] LOG: disconnection: session time: 0:00:00.023 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:44.596 GMT [396][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:44.597 GMT [396][client backend] [[unknown]][3/3:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:44.597 GMT [396][client backend] [[unknown]][3/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=014_binary.pl 2025-01-31 07:52:44.600 GMT [396][client backend] [014_binary.pl][3/4:0] LOG: statement: SELECT '0/179B408' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tsub', 'walreceiver') 2025-01-31 07:52:44.609 GMT [396][client backend] [014_binary.pl][:0] LOG: disconnection: session time: 0:00:00.016 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:44.989 GMT [5224][walsender] [tsub][24/0:0] LOG: released logical replication slot "tpub_slot" 2025-01-31 07:52:44.989 GMT [5224][walsender] [tsub][:0] LOG: disconnection: session time: 0:00:02.099 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:45.037 GMT [192][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:45.041 GMT [192][walsender] [[unknown]][27/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:45.041 GMT [192][walsender] [[unknown]][27/1:0] LOG: replication connection authorized: user=SYSTEM application_name=tsub 2025-01-31 07:52:45.047 GMT [192][walsender] [tsub][27/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2025-01-31 07:52:45.048 GMT [192][walsender] [tsub][27/0:0] LOG: received replication command: IDENTIFY_SYSTEM 2025-01-31 07:52:45.048 GMT [192][walsender] [tsub][27/0:0] STATEMENT: IDENTIFY_SYSTEM 2025-01-31 07:52:45.048 GMT [192][walsender] [tsub][27/0:0] LOG: received replication command: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/179B408 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"') 2025-01-31 07:52:45.048 GMT [192][walsender] [tsub][27/0:0] STATEMENT: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/179B408 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"') 2025-01-31 07:52:45.048 GMT [192][walsender] [tsub][27/0:0] LOG: acquired logical replication slot "tpub_slot" 2025-01-31 07:52:45.048 GMT [192][walsender] [tsub][27/0:0] STATEMENT: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/179B408 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"') 2025-01-31 07:52:45.049 GMT [192][walsender] [tsub][27/0:0] LOG: starting logical decoding for slot "tpub_slot" 2025-01-31 07:52:45.049 GMT [192][walsender] [tsub][27/0:0] DETAIL: Streaming transactions committing after 0/179B408, reading WAL from 0/179ABB0. 2025-01-31 07:52:45.049 GMT [192][walsender] [tsub][27/0:0] STATEMENT: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/179B408 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"') 2025-01-31 07:52:45.049 GMT [192][walsender] [tsub][27/0:0] LOG: logical decoding found consistent point at 0/179ABB0 2025-01-31 07:52:45.049 GMT [192][walsender] [tsub][27/0:0] DETAIL: There are no running transactions. 2025-01-31 07:52:45.049 GMT [192][walsender] [tsub][27/0:0] STATEMENT: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/179B408 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"') 2025-01-31 07:52:45.110 GMT [4480][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:45.111 GMT [4480][client backend] [[unknown]][4/3:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:45.112 GMT [4480][client backend] [[unknown]][4/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=014_binary.pl 2025-01-31 07:52:45.115 GMT [4480][client backend] [014_binary.pl][4/4:0] LOG: statement: INSERT INTO public.test_numerical (a, b, c, d) VALUES (5, 5.2, 5.3, 50); 2025-01-31 07:52:45.117 GMT [4480][client backend] [014_binary.pl][:0] LOG: disconnection: session time: 0:00:00.009 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:45.192 GMT [4564][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:45.194 GMT [4564][client backend] [[unknown]][5/3:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:45.194 GMT [4564][client backend] [[unknown]][5/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=014_binary.pl 2025-01-31 07:52:45.197 GMT [4564][client backend] [014_binary.pl][5/4:0] LOG: statement: SELECT pg_is_in_recovery() 2025-01-31 07:52:45.200 GMT [4564][client backend] [014_binary.pl][:0] LOG: disconnection: session time: 0:00:00.011 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:45.306 GMT [7460][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:45.308 GMT [7460][client backend] [[unknown]][6/4:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:45.308 GMT [7460][client backend] [[unknown]][6/4:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=014_binary.pl 2025-01-31 07:52:45.311 GMT [7460][client backend] [014_binary.pl][6/5:0] LOG: statement: SELECT pg_current_wal_lsn() 2025-01-31 07:52:45.314 GMT [7460][client backend] [014_binary.pl][:0] LOG: disconnection: session time: 0:00:00.010 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:45.394 GMT [7808][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:45.395 GMT [7808][client backend] [[unknown]][7/3:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:45.395 GMT [7808][client backend] [[unknown]][7/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=014_binary.pl 2025-01-31 07:52:45.399 GMT [7808][client backend] [014_binary.pl][7/4:0] LOG: statement: SELECT '0/179B4D0' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tsub', 'walreceiver') 2025-01-31 07:52:45.408 GMT [7808][client backend] [014_binary.pl][:0] LOG: disconnection: session time: 0:00:00.018 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:45.700 GMT [192][walsender] [tsub][27/0:0] LOG: released logical replication slot "tpub_slot" 2025-01-31 07:52:45.701 GMT [192][walsender] [tsub][:0] LOG: disconnection: session time: 0:00:00.667 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:45.750 GMT [7008][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:45.757 GMT [7008][walsender] [[unknown]][28/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:45.758 GMT [7008][walsender] [[unknown]][28/1:0] LOG: replication connection authorized: user=SYSTEM application_name=tsub 2025-01-31 07:52:45.761 GMT [7008][walsender] [tsub][28/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2025-01-31 07:52:45.762 GMT [7008][walsender] [tsub][28/0:0] LOG: received replication command: IDENTIFY_SYSTEM 2025-01-31 07:52:45.762 GMT [7008][walsender] [tsub][28/0:0] STATEMENT: IDENTIFY_SYSTEM 2025-01-31 07:52:45.762 GMT [7008][walsender] [tsub][28/0:0] LOG: received replication command: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/179B4D0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:45.762 GMT [7008][walsender] [tsub][28/0:0] STATEMENT: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/179B4D0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:45.762 GMT [7008][walsender] [tsub][28/0:0] LOG: acquired logical replication slot "tpub_slot" 2025-01-31 07:52:45.762 GMT [7008][walsender] [tsub][28/0:0] STATEMENT: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/179B4D0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:45.763 GMT [7008][walsender] [tsub][28/0:0] LOG: starting logical decoding for slot "tpub_slot" 2025-01-31 07:52:45.763 GMT [7008][walsender] [tsub][28/0:0] DETAIL: Streaming transactions committing after 0/179B4D0, reading WAL from 0/179ABB0. 2025-01-31 07:52:45.763 GMT [7008][walsender] [tsub][28/0:0] STATEMENT: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/179B4D0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:45.763 GMT [7008][walsender] [tsub][28/0:0] LOG: logical decoding found consistent point at 0/179ABB0 2025-01-31 07:52:45.763 GMT [7008][walsender] [tsub][28/0:0] DETAIL: There are no running transactions. 2025-01-31 07:52:45.763 GMT [7008][walsender] [tsub][28/0:0] STATEMENT: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/179B4D0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:45.817 GMT [6708][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:45.818 GMT [6708][client backend] [[unknown]][8/3:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:45.818 GMT [6708][client backend] [[unknown]][8/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=014_binary.pl 2025-01-31 07:52:45.822 GMT [6708][client backend] [014_binary.pl][8/4:0] LOG: statement: INSERT INTO public.test_arrays (a, b, c) VALUES ('{2,3,1}', '{1.2, 1.3, 1.1}', '{"two", "three", "one"}'); 2025-01-31 07:52:45.824 GMT [6708][client backend] [014_binary.pl][:0] LOG: disconnection: session time: 0:00:00.010 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:45.904 GMT [8124][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:45.906 GMT [8124][client backend] [[unknown]][9/3:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:45.906 GMT [8124][client backend] [[unknown]][9/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=014_binary.pl 2025-01-31 07:52:45.909 GMT [8124][client backend] [014_binary.pl][9/4:0] LOG: statement: SELECT pg_is_in_recovery() 2025-01-31 07:52:45.912 GMT [8124][client backend] [014_binary.pl][:0] LOG: disconnection: session time: 0:00:00.011 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:46.006 GMT [5976][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:46.014 GMT [5976][client backend] [[unknown]][0/7:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:46.014 GMT [5976][client backend] [[unknown]][0/7:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=014_binary.pl 2025-01-31 07:52:46.020 GMT [5976][client backend] [014_binary.pl][0/8:0] LOG: statement: SELECT pg_current_wal_lsn() 2025-01-31 07:52:46.022 GMT [5976][client backend] [014_binary.pl][:0] LOG: disconnection: session time: 0:00:00.028 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:46.110 GMT [8044][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:46.112 GMT [8044][client backend] [[unknown]][1/5:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:46.112 GMT [8044][client backend] [[unknown]][1/5:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=014_binary.pl 2025-01-31 07:52:46.116 GMT [8044][client backend] [014_binary.pl][1/6:0] LOG: statement: SELECT '0/179B628' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tsub', 'walreceiver') 2025-01-31 07:52:46.129 GMT [8044][client backend] [014_binary.pl][:0] LOG: disconnection: session time: 0:00:00.023 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:46.291 GMT [6624][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:46.292 GMT [6624][client backend] [[unknown]][2/6:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:46.292 GMT [6624][client backend] [[unknown]][2/6:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=014_binary.pl 2025-01-31 07:52:46.295 GMT [6624][client backend] [014_binary.pl][2/7:0] LOG: statement: CREATE TYPE myvarchar; 2025-01-31 07:52:46.297 GMT [6624][client backend] [014_binary.pl][2/8:0] LOG: statement: CREATE FUNCTION myvarcharin(cstring, oid, integer) RETURNS myvarchar LANGUAGE internal IMMUTABLE PARALLEL SAFE STRICT AS 'varcharin'; 2025-01-31 07:52:46.308 GMT [6624][client backend] [014_binary.pl][2/9:0] LOG: statement: CREATE FUNCTION myvarcharout(myvarchar) RETURNS cstring LANGUAGE internal IMMUTABLE PARALLEL SAFE STRICT AS 'varcharout'; 2025-01-31 07:52:46.316 GMT [6624][client backend] [014_binary.pl][2/10:0] LOG: statement: CREATE TYPE myvarchar ( input = myvarcharin, output = myvarcharout); 2025-01-31 07:52:46.318 GMT [6624][client backend] [014_binary.pl][2/11:0] LOG: statement: CREATE TABLE public.test_myvarchar ( a myvarchar ); 2025-01-31 07:52:46.320 GMT [6624][client backend] [014_binary.pl][:0] LOG: disconnection: session time: 0:00:00.032 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:46.551 GMT [4848][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:46.553 GMT [4848][client backend] [[unknown]][3/5:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:46.553 GMT [4848][client backend] [[unknown]][3/5:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=014_binary.pl 2025-01-31 07:52:46.560 GMT [4848][client backend] [014_binary.pl][3/6:0] LOG: statement: INSERT INTO public.test_myvarchar (a) VALUES ('a'); 2025-01-31 07:52:46.561 GMT [4848][client backend] [014_binary.pl][:0] LOG: disconnection: session time: 0:00:00.015 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:46.732 GMT [6680][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:46.735 GMT [6680][walsender] [[unknown]][29/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:46.735 GMT [6680][walsender] [[unknown]][29/1:0] LOG: replication connection authorized: user=SYSTEM application_name=tsub 2025-01-31 07:52:46.738 GMT [6680][walsender] [tsub][29/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2025-01-31 07:52:46.739 GMT [6680][walsender] [tsub][29/3:0] LOG: statement: SELECT DISTINCT n.nspname, c.relname, gpt.attrs FROM pg_class c JOIN pg_namespace n ON n.oid = c.relnamespace JOIN ( SELECT (pg_get_publication_tables(VARIADIC array_agg(pubname::text))).* FROM pg_publication WHERE pubname IN ( 'tpub' )) AS gpt ON gpt.relid = c.oid 2025-01-31 07:52:46.750 GMT [6680][walsender] [tsub][:0] LOG: disconnection: session time: 0:00:00.020 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:46.847 GMT [1984][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:46.849 GMT [1984][walsender] [[unknown]][30/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:46.849 GMT [1984][walsender] [[unknown]][30/1:0] LOG: replication connection authorized: user=SYSTEM application_name=pg_16400_sync_16405_7465982433180864044 2025-01-31 07:52:46.853 GMT [1984][walsender] [pg_16400_sync_16405_7465982433180864044][30/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2025-01-31 07:52:46.854 GMT [1984][walsender] [pg_16400_sync_16405_7465982433180864044][30/3:0] LOG: statement: BEGIN READ ONLY ISOLATION LEVEL REPEATABLE READ 2025-01-31 07:52:46.854 GMT [1984][walsender] [pg_16400_sync_16405_7465982433180864044][30/3:0] LOG: received replication command: CREATE_REPLICATION_SLOT "pg_16400_sync_16405_7465982433180864044" LOGICAL pgoutput (SNAPSHOT 'use') 2025-01-31 07:52:46.854 GMT [1984][walsender] [pg_16400_sync_16405_7465982433180864044][30/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16400_sync_16405_7465982433180864044" LOGICAL pgoutput (SNAPSHOT 'use') 2025-01-31 07:52:46.859 GMT [1984][walsender] [pg_16400_sync_16405_7465982433180864044][30/3:0] LOG: logical decoding found consistent point at 0/17AB110 2025-01-31 07:52:46.859 GMT [1984][walsender] [pg_16400_sync_16405_7465982433180864044][30/3:0] DETAIL: There are no running transactions. 2025-01-31 07:52:46.859 GMT [1984][walsender] [pg_16400_sync_16405_7465982433180864044][30/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16400_sync_16405_7465982433180864044" LOGICAL pgoutput (SNAPSHOT 'use') 2025-01-31 07:52:46.863 GMT [1984][walsender] [pg_16400_sync_16405_7465982433180864044][30/3:0] LOG: released logical replication slot "pg_16400_sync_16405_7465982433180864044" 2025-01-31 07:52:46.863 GMT [1984][walsender] [pg_16400_sync_16405_7465982433180864044][30/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16400_sync_16405_7465982433180864044" LOGICAL pgoutput (SNAPSHOT 'use') 2025-01-31 07:52:46.863 GMT [1984][walsender] [pg_16400_sync_16405_7465982433180864044][30/3:0] LOG: statement: SELECT c.oid, c.relreplident, c.relkind FROM pg_catalog.pg_class c INNER JOIN pg_catalog.pg_namespace n ON (c.relnamespace = n.oid) WHERE n.nspname = 'public' AND c.relname = 'test_myvarchar' 2025-01-31 07:52:46.868 GMT [1984][walsender] [pg_16400_sync_16405_7465982433180864044][30/3:0] LOG: statement: SELECT DISTINCT (CASE WHEN (array_length(gpt.attrs, 1) = c.relnatts) THEN NULL ELSE gpt.attrs END) FROM pg_publication p, LATERAL pg_get_publication_tables(p.pubname) gpt, pg_class c WHERE gpt.relid = 16405 AND c.oid = gpt.relid AND p.pubname IN ( 'tpub' ) 2025-01-31 07:52:46.872 GMT [1984][walsender] [pg_16400_sync_16405_7465982433180864044][30/3:0] LOG: statement: SELECT a.attnum, a.attname, a.atttypid, a.attnum = ANY(i.indkey), a.attgenerated != '' FROM pg_catalog.pg_attribute a LEFT JOIN pg_catalog.pg_index i ON (i.indexrelid = pg_get_replica_identity_index(16405)) WHERE a.attnum > 0::pg_catalog.int2 AND NOT a.attisdropped AND a.attrelid = 16405 ORDER BY a.attnum 2025-01-31 07:52:46.874 GMT [1984][walsender] [pg_16400_sync_16405_7465982433180864044][30/3:0] LOG: statement: SELECT DISTINCT pg_get_expr(gpt.qual, gpt.relid) FROM pg_publication p, LATERAL pg_get_publication_tables(p.pubname) gpt WHERE gpt.relid = 16405 AND p.pubname IN ( 'tpub' ) 2025-01-31 07:52:46.875 GMT [1984][walsender] [pg_16400_sync_16405_7465982433180864044][30/3:0] LOG: statement: COPY public.test_myvarchar (a) TO STDOUT WITH (FORMAT binary) 2025-01-31 07:52:46.875 GMT [1984][walsender] [pg_16400_sync_16405_7465982433180864044][30/3:0] ERROR: no binary output function available for type public.myvarchar 2025-01-31 07:52:46.875 GMT [1984][walsender] [pg_16400_sync_16405_7465982433180864044][30/3:0] STATEMENT: COPY public.test_myvarchar (a) TO STDOUT WITH (FORMAT binary) 2025-01-31 07:52:46.876 GMT [1984][walsender] [pg_16400_sync_16405_7465982433180864044][30/0:0] LOG: could not receive data from client: An existing connection was forcibly closed by the remote host. 2025-01-31 07:52:46.876 GMT [1984][walsender] [pg_16400_sync_16405_7465982433180864044][:0] LOG: disconnection: session time: 0:00:00.031 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:47.016 GMT [5896][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:47.018 GMT [5896][client backend] [[unknown]][4/5:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:47.018 GMT [5896][client backend] [[unknown]][4/5:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=014_binary.pl 2025-01-31 07:52:47.030 GMT [5896][client backend] [014_binary.pl][4/6:0] LOG: statement: CREATE FUNCTION myvarcharsend(myvarchar) RETURNS bytea LANGUAGE internal STABLE PARALLEL SAFE STRICT AS 'varcharsend'; 2025-01-31 07:52:47.034 GMT [5896][client backend] [014_binary.pl][4/7:0] LOG: statement: CREATE FUNCTION myvarcharrecv(internal, oid, integer) RETURNS myvarchar LANGUAGE internal STABLE PARALLEL SAFE STRICT AS 'varcharrecv'; 2025-01-31 07:52:47.034 GMT [5896][client backend] [014_binary.pl][4/8:0] LOG: statement: ALTER TYPE myvarchar SET ( send = myvarcharsend, receive = myvarcharrecv ); 2025-01-31 07:52:47.036 GMT [5896][client backend] [014_binary.pl][:0] LOG: disconnection: session time: 0:00:00.031 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:48.091 GMT [3500][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:48.093 GMT [3500][walsender] [[unknown]][31/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:48.093 GMT [3500][walsender] [[unknown]][31/1:0] LOG: replication connection authorized: user=SYSTEM application_name=pg_16400_sync_16405_7465982433180864044 2025-01-31 07:52:48.097 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2025-01-31 07:52:48.097 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/0:0] LOG: received replication command: DROP_REPLICATION_SLOT pg_16400_sync_16405_7465982433180864044 WAIT 2025-01-31 07:52:48.097 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16400_sync_16405_7465982433180864044 WAIT 2025-01-31 07:52:48.097 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/0:0] LOG: acquired logical replication slot "pg_16400_sync_16405_7465982433180864044" 2025-01-31 07:52:48.097 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16400_sync_16405_7465982433180864044 WAIT 2025-01-31 07:52:48.099 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/3:0] LOG: statement: BEGIN READ ONLY ISOLATION LEVEL REPEATABLE READ 2025-01-31 07:52:48.099 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/3:0] LOG: received replication command: CREATE_REPLICATION_SLOT "pg_16400_sync_16405_7465982433180864044" LOGICAL pgoutput (SNAPSHOT 'use') 2025-01-31 07:52:48.099 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16400_sync_16405_7465982433180864044" LOGICAL pgoutput (SNAPSHOT 'use') 2025-01-31 07:52:48.102 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/3:0] LOG: logical decoding found consistent point at 0/17AE048 2025-01-31 07:52:48.102 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/3:0] DETAIL: There are no running transactions. 2025-01-31 07:52:48.102 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16400_sync_16405_7465982433180864044" LOGICAL pgoutput (SNAPSHOT 'use') 2025-01-31 07:52:48.103 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/3:0] LOG: released logical replication slot "pg_16400_sync_16405_7465982433180864044" 2025-01-31 07:52:48.103 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16400_sync_16405_7465982433180864044" LOGICAL pgoutput (SNAPSHOT 'use') 2025-01-31 07:52:48.104 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/3:0] LOG: statement: SELECT c.oid, c.relreplident, c.relkind FROM pg_catalog.pg_class c INNER JOIN pg_catalog.pg_namespace n ON (c.relnamespace = n.oid) WHERE n.nspname = 'public' AND c.relname = 'test_myvarchar' 2025-01-31 07:52:48.108 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/3:0] LOG: statement: SELECT DISTINCT (CASE WHEN (array_length(gpt.attrs, 1) = c.relnatts) THEN NULL ELSE gpt.attrs END) FROM pg_publication p, LATERAL pg_get_publication_tables(p.pubname) gpt, pg_class c WHERE gpt.relid = 16405 AND c.oid = gpt.relid AND p.pubname IN ( 'tpub' ) 2025-01-31 07:52:48.113 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/3:0] LOG: statement: SELECT a.attnum, a.attname, a.atttypid, a.attnum = ANY(i.indkey), a.attgenerated != '' FROM pg_catalog.pg_attribute a LEFT JOIN pg_catalog.pg_index i ON (i.indexrelid = pg_get_replica_identity_index(16405)) WHERE a.attnum > 0::pg_catalog.int2 AND NOT a.attisdropped AND a.attrelid = 16405 ORDER BY a.attnum 2025-01-31 07:52:48.115 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/3:0] LOG: statement: SELECT DISTINCT pg_get_expr(gpt.qual, gpt.relid) FROM pg_publication p, LATERAL pg_get_publication_tables(p.pubname) gpt WHERE gpt.relid = 16405 AND p.pubname IN ( 'tpub' ) 2025-01-31 07:52:48.117 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/3:0] LOG: statement: COPY public.test_myvarchar (a) TO STDOUT WITH (FORMAT binary) 2025-01-31 07:52:48.118 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/3:0] LOG: statement: COMMIT 2025-01-31 07:52:48.118 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/0:0] LOG: received replication command: START_REPLICATION SLOT "pg_16400_sync_16405_7465982433180864044" LOGICAL 0/17AE080 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:48.118 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/0:0] STATEMENT: START_REPLICATION SLOT "pg_16400_sync_16405_7465982433180864044" LOGICAL 0/17AE080 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:48.118 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/0:0] LOG: acquired logical replication slot "pg_16400_sync_16405_7465982433180864044" 2025-01-31 07:52:48.118 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/0:0] STATEMENT: START_REPLICATION SLOT "pg_16400_sync_16405_7465982433180864044" LOGICAL 0/17AE080 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:48.118 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/0:0] LOG: starting logical decoding for slot "pg_16400_sync_16405_7465982433180864044" 2025-01-31 07:52:48.118 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/0:0] DETAIL: Streaming transactions committing after 0/17AE080, reading WAL from 0/17AE048. 2025-01-31 07:52:48.118 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/0:0] STATEMENT: START_REPLICATION SLOT "pg_16400_sync_16405_7465982433180864044" LOGICAL 0/17AE080 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:48.119 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/0:0] LOG: logical decoding found consistent point at 0/17AE048 2025-01-31 07:52:48.119 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/0:0] DETAIL: There are no running transactions. 2025-01-31 07:52:48.119 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/0:0] STATEMENT: START_REPLICATION SLOT "pg_16400_sync_16405_7465982433180864044" LOGICAL 0/17AE080 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:48.119 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/0:0] LOG: released logical replication slot "pg_16400_sync_16405_7465982433180864044" 2025-01-31 07:52:48.119 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/0:0] STATEMENT: START_REPLICATION SLOT "pg_16400_sync_16405_7465982433180864044" LOGICAL 0/17AE080 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:48.119 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/0:0] LOG: received replication command: DROP_REPLICATION_SLOT pg_16400_sync_16405_7465982433180864044 WAIT 2025-01-31 07:52:48.119 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16400_sync_16405_7465982433180864044 WAIT 2025-01-31 07:52:48.119 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/0:0] LOG: acquired logical replication slot "pg_16400_sync_16405_7465982433180864044" 2025-01-31 07:52:48.119 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][31/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16400_sync_16405_7465982433180864044 WAIT 2025-01-31 07:52:48.120 GMT [3500][walsender] [pg_16400_sync_16405_7465982433180864044][:0] LOG: disconnection: session time: 0:00:00.032 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:48.324 GMT [6876][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:48.326 GMT [6876][client backend] [[unknown]][5/5:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:48.326 GMT [6876][client backend] [[unknown]][5/5:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=014_binary.pl 2025-01-31 07:52:48.330 GMT [6876][client backend] [014_binary.pl][5/6:0] LOG: statement: SELECT pg_is_in_recovery() 2025-01-31 07:52:48.333 GMT [6876][client backend] [014_binary.pl][:0] LOG: disconnection: session time: 0:00:00.012 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:48.485 GMT [4884][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:48.487 GMT [4884][client backend] [[unknown]][6/6:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:48.487 GMT [4884][client backend] [[unknown]][6/6:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=014_binary.pl 2025-01-31 07:52:48.490 GMT [4884][client backend] [014_binary.pl][6/7:0] LOG: statement: SELECT pg_current_wal_lsn() 2025-01-31 07:52:48.494 GMT [4884][client backend] [014_binary.pl][:0] LOG: disconnection: session time: 0:00:00.012 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:48.603 GMT [6980][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:48.604 GMT [6980][client backend] [[unknown]][7/5:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:48.604 GMT [6980][client backend] [[unknown]][7/5:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=014_binary.pl 2025-01-31 07:52:48.607 GMT [6980][client backend] [014_binary.pl][7/6:0] LOG: statement: SELECT '0/17AE080' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tsub', 'walreceiver') 2025-01-31 07:52:48.616 GMT [6980][client backend] [014_binary.pl][:0] LOG: disconnection: session time: 0:00:00.018 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:48.745 GMT [5964][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:48.748 GMT [5964][client backend] [[unknown]][8/5:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:48.748 GMT [5964][client backend] [[unknown]][8/5:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=014_binary.pl 2025-01-31 07:52:48.753 GMT [5964][client backend] [014_binary.pl][8/6:0] LOG: statement: CREATE TABLE public.test_mismatching_types ( a bigint PRIMARY KEY ); 2025-01-31 07:52:48.760 GMT [5964][client backend] [014_binary.pl][8/7:0] LOG: statement: INSERT INTO public.test_mismatching_types (a) VALUES (1), (2); 2025-01-31 07:52:48.762 GMT [5964][client backend] [014_binary.pl][:0] LOG: disconnection: session time: 0:00:00.020 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:48.763 GMT [7008][walsender] [tsub][28/0:0] LOG: could not receive data from client: An existing connection was forcibly closed by the remote host. 2025-01-31 07:52:48.763 GMT [7008][walsender] [tsub][28/0:0] STATEMENT: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/179B4D0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:48.763 GMT [7008][walsender] [tsub][28/0:0] LOG: unexpected EOF on standby connection 2025-01-31 07:52:48.763 GMT [7008][walsender] [tsub][28/0:0] STATEMENT: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/179B4D0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:48.763 GMT [7008][walsender] [tsub][28/0:0] LOG: released logical replication slot "tpub_slot" 2025-01-31 07:52:48.763 GMT [7008][walsender] [tsub][:0] LOG: disconnection: session time: 0:00:03.017 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:48.830 GMT [6848][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:48.831 GMT [6848][walsender] [[unknown]][32/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:48.831 GMT [6848][walsender] [[unknown]][32/1:0] LOG: replication connection authorized: user=SYSTEM application_name=tsub 2025-01-31 07:52:48.851 GMT [6848][walsender] [tsub][32/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2025-01-31 07:52:48.853 GMT [6848][walsender] [tsub][32/0:0] LOG: received replication command: IDENTIFY_SYSTEM 2025-01-31 07:52:48.853 GMT [6848][walsender] [tsub][32/0:0] STATEMENT: IDENTIFY_SYSTEM 2025-01-31 07:52:48.853 GMT [6848][walsender] [tsub][32/0:0] LOG: received replication command: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/17AB110 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:48.853 GMT [6848][walsender] [tsub][32/0:0] STATEMENT: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/17AB110 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:48.853 GMT [6848][walsender] [tsub][32/0:0] LOG: acquired logical replication slot "tpub_slot" 2025-01-31 07:52:48.853 GMT [6848][walsender] [tsub][32/0:0] STATEMENT: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/17AB110 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:48.853 GMT [6848][walsender] [tsub][32/0:0] LOG: 0/17AB110 has been already streamed, forwarding to 0/17B2038 2025-01-31 07:52:48.853 GMT [6848][walsender] [tsub][32/0:0] STATEMENT: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/17AB110 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:48.854 GMT [6848][walsender] [tsub][32/0:0] LOG: starting logical decoding for slot "tpub_slot" 2025-01-31 07:52:48.854 GMT [6848][walsender] [tsub][32/0:0] DETAIL: Streaming transactions committing after 0/17B2038, reading WAL from 0/17AE048. 2025-01-31 07:52:48.854 GMT [6848][walsender] [tsub][32/0:0] STATEMENT: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/17AB110 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:48.854 GMT [6848][walsender] [tsub][32/0:0] LOG: logical decoding found consistent point at 0/17AE048 2025-01-31 07:52:48.854 GMT [6848][walsender] [tsub][32/0:0] DETAIL: There are no running transactions. 2025-01-31 07:52:48.854 GMT [6848][walsender] [tsub][32/0:0] STATEMENT: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/17AB110 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:48.857 GMT [6848][walsender] [tsub][32/0:0] LOG: released logical replication slot "tpub_slot" 2025-01-31 07:52:48.858 GMT [6848][walsender] [tsub][:0] LOG: disconnection: session time: 0:00:00.031 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:48.955 GMT [6932][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:48.957 GMT [6932][walsender] [[unknown]][23/5:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:48.957 GMT [6932][walsender] [[unknown]][23/5:0] LOG: replication connection authorized: user=SYSTEM application_name=tsub 2025-01-31 07:52:48.964 GMT [6932][walsender] [tsub][23/6:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2025-01-31 07:52:48.965 GMT [6932][walsender] [tsub][23/7:0] LOG: statement: SELECT DISTINCT n.nspname, c.relname, gpt.attrs FROM pg_class c JOIN pg_namespace n ON n.oid = c.relnamespace JOIN ( SELECT (pg_get_publication_tables(VARIADIC array_agg(pubname::text))).* FROM pg_publication WHERE pubname IN ( 'tpub' )) AS gpt ON gpt.relid = c.oid 2025-01-31 07:52:48.976 GMT [6932][walsender] [tsub][:0] LOG: disconnection: session time: 0:00:00.030 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:49.323 GMT [2360][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:49.330 GMT [2360][walsender] [[unknown]][25/4:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:49.330 GMT [2360][walsender] [[unknown]][25/4:0] LOG: replication connection authorized: user=SYSTEM application_name=tsub 2025-01-31 07:52:49.335 GMT [2360][walsender] [tsub][25/5:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2025-01-31 07:52:49.336 GMT [2360][walsender] [tsub][25/0:0] LOG: received replication command: IDENTIFY_SYSTEM 2025-01-31 07:52:49.336 GMT [2360][walsender] [tsub][25/0:0] STATEMENT: IDENTIFY_SYSTEM 2025-01-31 07:52:49.336 GMT [2360][walsender] [tsub][25/0:0] LOG: received replication command: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/17AB110 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:49.336 GMT [2360][walsender] [tsub][25/0:0] STATEMENT: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/17AB110 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:49.336 GMT [2360][walsender] [tsub][25/0:0] LOG: acquired logical replication slot "tpub_slot" 2025-01-31 07:52:49.336 GMT [2360][walsender] [tsub][25/0:0] STATEMENT: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/17AB110 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:49.336 GMT [2360][walsender] [tsub][25/0:0] LOG: 0/17AB110 has been already streamed, forwarding to 0/17B2038 2025-01-31 07:52:49.336 GMT [2360][walsender] [tsub][25/0:0] STATEMENT: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/17AB110 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:49.336 GMT [2360][walsender] [tsub][25/0:0] LOG: starting logical decoding for slot "tpub_slot" 2025-01-31 07:52:49.336 GMT [2360][walsender] [tsub][25/0:0] DETAIL: Streaming transactions committing after 0/17B2038, reading WAL from 0/17AE048. 2025-01-31 07:52:49.336 GMT [2360][walsender] [tsub][25/0:0] STATEMENT: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/17AB110 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:49.337 GMT [2360][walsender] [tsub][25/0:0] LOG: logical decoding found consistent point at 0/17AE048 2025-01-31 07:52:49.337 GMT [2360][walsender] [tsub][25/0:0] DETAIL: There are no running transactions. 2025-01-31 07:52:49.337 GMT [2360][walsender] [tsub][25/0:0] STATEMENT: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/17AB110 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"', binary 'true') 2025-01-31 07:52:49.395 GMT [1764][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:49.396 GMT [1764][walsender] [[unknown]][26/4:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:49.396 GMT [1764][walsender] [[unknown]][26/4:0] LOG: replication connection authorized: user=SYSTEM application_name=pg_16400_sync_16410_7465982433180864044 2025-01-31 07:52:49.400 GMT [1764][walsender] [pg_16400_sync_16410_7465982433180864044][26/5:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2025-01-31 07:52:49.401 GMT [1764][walsender] [pg_16400_sync_16410_7465982433180864044][26/6:0] LOG: statement: BEGIN READ ONLY ISOLATION LEVEL REPEATABLE READ 2025-01-31 07:52:49.401 GMT [1764][walsender] [pg_16400_sync_16410_7465982433180864044][26/6:0] LOG: received replication command: CREATE_REPLICATION_SLOT "pg_16400_sync_16410_7465982433180864044" LOGICAL pgoutput (SNAPSHOT 'use') 2025-01-31 07:52:49.401 GMT [1764][walsender] [pg_16400_sync_16410_7465982433180864044][26/6:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16400_sync_16410_7465982433180864044" LOGICAL pgoutput (SNAPSHOT 'use') 2025-01-31 07:52:49.407 GMT [1764][walsender] [pg_16400_sync_16410_7465982433180864044][26/6:0] LOG: logical decoding found consistent point at 0/17B21C8 2025-01-31 07:52:49.407 GMT [1764][walsender] [pg_16400_sync_16410_7465982433180864044][26/6:0] DETAIL: There are no running transactions. 2025-01-31 07:52:49.407 GMT [1764][walsender] [pg_16400_sync_16410_7465982433180864044][26/6:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16400_sync_16410_7465982433180864044" LOGICAL pgoutput (SNAPSHOT 'use') 2025-01-31 07:52:49.408 GMT [1764][walsender] [pg_16400_sync_16410_7465982433180864044][26/6:0] LOG: released logical replication slot "pg_16400_sync_16410_7465982433180864044" 2025-01-31 07:52:49.408 GMT [1764][walsender] [pg_16400_sync_16410_7465982433180864044][26/6:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16400_sync_16410_7465982433180864044" LOGICAL pgoutput (SNAPSHOT 'use') 2025-01-31 07:52:49.408 GMT [1764][walsender] [pg_16400_sync_16410_7465982433180864044][26/6:0] LOG: statement: SELECT c.oid, c.relreplident, c.relkind FROM pg_catalog.pg_class c INNER JOIN pg_catalog.pg_namespace n ON (c.relnamespace = n.oid) WHERE n.nspname = 'public' AND c.relname = 'test_mismatching_types' 2025-01-31 07:52:49.412 GMT [1764][walsender] [pg_16400_sync_16410_7465982433180864044][26/6:0] LOG: statement: SELECT DISTINCT (CASE WHEN (array_length(gpt.attrs, 1) = c.relnatts) THEN NULL ELSE gpt.attrs END) FROM pg_publication p, LATERAL pg_get_publication_tables(p.pubname) gpt, pg_class c WHERE gpt.relid = 16410 AND c.oid = gpt.relid AND p.pubname IN ( 'tpub' ) 2025-01-31 07:52:49.417 GMT [1764][walsender] [pg_16400_sync_16410_7465982433180864044][26/6:0] LOG: statement: SELECT a.attnum, a.attname, a.atttypid, a.attnum = ANY(i.indkey), a.attgenerated != '' FROM pg_catalog.pg_attribute a LEFT JOIN pg_catalog.pg_index i ON (i.indexrelid = pg_get_replica_identity_index(16410)) WHERE a.attnum > 0::pg_catalog.int2 AND NOT a.attisdropped AND a.attrelid = 16410 ORDER BY a.attnum 2025-01-31 07:52:49.419 GMT [1764][walsender] [pg_16400_sync_16410_7465982433180864044][26/6:0] LOG: statement: SELECT DISTINCT pg_get_expr(gpt.qual, gpt.relid) FROM pg_publication p, LATERAL pg_get_publication_tables(p.pubname) gpt WHERE gpt.relid = 16410 AND p.pubname IN ( 'tpub' ) 2025-01-31 07:52:49.421 GMT [1764][walsender] [pg_16400_sync_16410_7465982433180864044][26/6:0] LOG: statement: COPY public.test_mismatching_types (a) TO STDOUT WITH (FORMAT binary) 2025-01-31 07:52:49.421 GMT [1764][walsender] [pg_16400_sync_16410_7465982433180864044][:0] LOG: disconnection: session time: 0:00:00.030 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:49.572 GMT [2360][walsender] [tsub][25/0:0] LOG: released logical replication slot "tpub_slot" 2025-01-31 07:52:49.572 GMT [2360][walsender] [tsub][:0] LOG: disconnection: session time: 0:00:00.252 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:49.612 GMT [1608][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:49.613 GMT [1608][walsender] [[unknown]][24/8:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:49.613 GMT [1608][walsender] [[unknown]][24/8:0] LOG: replication connection authorized: user=SYSTEM application_name=tsub 2025-01-31 07:52:49.617 GMT [1608][walsender] [tsub][24/9:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2025-01-31 07:52:49.618 GMT [1608][walsender] [tsub][24/0:0] LOG: received replication command: IDENTIFY_SYSTEM 2025-01-31 07:52:49.618 GMT [1608][walsender] [tsub][24/0:0] STATEMENT: IDENTIFY_SYSTEM 2025-01-31 07:52:49.618 GMT [1608][walsender] [tsub][24/0:0] LOG: received replication command: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/17AB110 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"') 2025-01-31 07:52:49.618 GMT [1608][walsender] [tsub][24/0:0] STATEMENT: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/17AB110 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"') 2025-01-31 07:52:49.618 GMT [1608][walsender] [tsub][24/0:0] LOG: acquired logical replication slot "tpub_slot" 2025-01-31 07:52:49.618 GMT [1608][walsender] [tsub][24/0:0] STATEMENT: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/17AB110 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"') 2025-01-31 07:52:49.618 GMT [1608][walsender] [tsub][24/0:0] LOG: 0/17AB110 has been already streamed, forwarding to 0/17B2200 2025-01-31 07:52:49.618 GMT [1608][walsender] [tsub][24/0:0] STATEMENT: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/17AB110 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"') 2025-01-31 07:52:49.618 GMT [1608][walsender] [tsub][24/0:0] LOG: starting logical decoding for slot "tpub_slot" 2025-01-31 07:52:49.618 GMT [1608][walsender] [tsub][24/0:0] DETAIL: Streaming transactions committing after 0/17B2200, reading WAL from 0/17B21C8. 2025-01-31 07:52:49.618 GMT [1608][walsender] [tsub][24/0:0] STATEMENT: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/17AB110 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"') 2025-01-31 07:52:49.619 GMT [1608][walsender] [tsub][24/0:0] LOG: logical decoding found consistent point at 0/17B21C8 2025-01-31 07:52:49.619 GMT [1608][walsender] [tsub][24/0:0] DETAIL: There are no running transactions. 2025-01-31 07:52:49.619 GMT [1608][walsender] [tsub][24/0:0] STATEMENT: START_REPLICATION SLOT "tpub_slot" LOGICAL 0/17AB110 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"') 2025-01-31 07:52:49.662 GMT [5116][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:49.664 GMT [5116][walsender] [[unknown]][27/5:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:49.664 GMT [5116][walsender] [[unknown]][27/5:0] LOG: replication connection authorized: user=SYSTEM application_name=pg_16400_sync_16410_7465982433180864044 2025-01-31 07:52:49.666 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/6:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2025-01-31 07:52:49.667 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/0:0] LOG: received replication command: DROP_REPLICATION_SLOT pg_16400_sync_16410_7465982433180864044 WAIT 2025-01-31 07:52:49.667 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16400_sync_16410_7465982433180864044 WAIT 2025-01-31 07:52:49.667 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/0:0] LOG: acquired logical replication slot "pg_16400_sync_16410_7465982433180864044" 2025-01-31 07:52:49.667 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16400_sync_16410_7465982433180864044 WAIT 2025-01-31 07:52:49.669 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/7:0] LOG: statement: BEGIN READ ONLY ISOLATION LEVEL REPEATABLE READ 2025-01-31 07:52:49.669 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/7:0] LOG: received replication command: CREATE_REPLICATION_SLOT "pg_16400_sync_16410_7465982433180864044" LOGICAL pgoutput (SNAPSHOT 'use') 2025-01-31 07:52:49.669 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/7:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16400_sync_16410_7465982433180864044" LOGICAL pgoutput (SNAPSHOT 'use') 2025-01-31 07:52:49.675 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/7:0] LOG: logical decoding found consistent point at 0/17B2200 2025-01-31 07:52:49.675 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/7:0] DETAIL: There are no running transactions. 2025-01-31 07:52:49.675 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/7:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16400_sync_16410_7465982433180864044" LOGICAL pgoutput (SNAPSHOT 'use') 2025-01-31 07:52:49.676 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/7:0] LOG: released logical replication slot "pg_16400_sync_16410_7465982433180864044" 2025-01-31 07:52:49.676 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/7:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16400_sync_16410_7465982433180864044" LOGICAL pgoutput (SNAPSHOT 'use') 2025-01-31 07:52:49.677 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/7:0] LOG: statement: SELECT c.oid, c.relreplident, c.relkind FROM pg_catalog.pg_class c INNER JOIN pg_catalog.pg_namespace n ON (c.relnamespace = n.oid) WHERE n.nspname = 'public' AND c.relname = 'test_mismatching_types' 2025-01-31 07:52:49.681 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/7:0] LOG: statement: SELECT DISTINCT (CASE WHEN (array_length(gpt.attrs, 1) = c.relnatts) THEN NULL ELSE gpt.attrs END) FROM pg_publication p, LATERAL pg_get_publication_tables(p.pubname) gpt, pg_class c WHERE gpt.relid = 16410 AND c.oid = gpt.relid AND p.pubname IN ( 'tpub' ) 2025-01-31 07:52:49.685 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/7:0] LOG: statement: SELECT a.attnum, a.attname, a.atttypid, a.attnum = ANY(i.indkey), a.attgenerated != '' FROM pg_catalog.pg_attribute a LEFT JOIN pg_catalog.pg_index i ON (i.indexrelid = pg_get_replica_identity_index(16410)) WHERE a.attnum > 0::pg_catalog.int2 AND NOT a.attisdropped AND a.attrelid = 16410 ORDER BY a.attnum 2025-01-31 07:52:49.687 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/7:0] LOG: statement: SELECT DISTINCT pg_get_expr(gpt.qual, gpt.relid) FROM pg_publication p, LATERAL pg_get_publication_tables(p.pubname) gpt WHERE gpt.relid = 16410 AND p.pubname IN ( 'tpub' ) 2025-01-31 07:52:49.689 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/7:0] LOG: statement: COPY public.test_mismatching_types (a) TO STDOUT 2025-01-31 07:52:49.690 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/7:0] LOG: statement: COMMIT 2025-01-31 07:52:49.691 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/0:0] LOG: received replication command: START_REPLICATION SLOT "pg_16400_sync_16410_7465982433180864044" LOGICAL 0/17B2238 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"') 2025-01-31 07:52:49.691 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/0:0] STATEMENT: START_REPLICATION SLOT "pg_16400_sync_16410_7465982433180864044" LOGICAL 0/17B2238 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"') 2025-01-31 07:52:49.691 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/0:0] LOG: acquired logical replication slot "pg_16400_sync_16410_7465982433180864044" 2025-01-31 07:52:49.691 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/0:0] STATEMENT: START_REPLICATION SLOT "pg_16400_sync_16410_7465982433180864044" LOGICAL 0/17B2238 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"') 2025-01-31 07:52:49.691 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/0:0] LOG: starting logical decoding for slot "pg_16400_sync_16410_7465982433180864044" 2025-01-31 07:52:49.691 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/0:0] DETAIL: Streaming transactions committing after 0/17B2238, reading WAL from 0/17B2200. 2025-01-31 07:52:49.691 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/0:0] STATEMENT: START_REPLICATION SLOT "pg_16400_sync_16410_7465982433180864044" LOGICAL 0/17B2238 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"') 2025-01-31 07:52:49.691 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/0:0] LOG: logical decoding found consistent point at 0/17B2200 2025-01-31 07:52:49.691 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/0:0] DETAIL: There are no running transactions. 2025-01-31 07:52:49.691 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/0:0] STATEMENT: START_REPLICATION SLOT "pg_16400_sync_16410_7465982433180864044" LOGICAL 0/17B2238 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"') 2025-01-31 07:52:49.691 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/0:0] LOG: released logical replication slot "pg_16400_sync_16410_7465982433180864044" 2025-01-31 07:52:49.691 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/0:0] STATEMENT: START_REPLICATION SLOT "pg_16400_sync_16410_7465982433180864044" LOGICAL 0/17B2238 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tpub"') 2025-01-31 07:52:49.692 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/0:0] LOG: received replication command: DROP_REPLICATION_SLOT pg_16400_sync_16410_7465982433180864044 WAIT 2025-01-31 07:52:49.692 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16400_sync_16410_7465982433180864044 WAIT 2025-01-31 07:52:49.692 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/0:0] LOG: acquired logical replication slot "pg_16400_sync_16410_7465982433180864044" 2025-01-31 07:52:49.692 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][27/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16400_sync_16410_7465982433180864044 WAIT 2025-01-31 07:52:49.693 GMT [5116][walsender] [pg_16400_sync_16410_7465982433180864044][:0] LOG: disconnection: session time: 0:00:00.034 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:49.820 GMT [7884][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:49.822 GMT [7884][client backend] [[unknown]][9/5:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:49.822 GMT [7884][client backend] [[unknown]][9/5:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=014_binary.pl 2025-01-31 07:52:49.826 GMT [7884][client backend] [014_binary.pl][9/6:0] LOG: statement: SELECT pg_is_in_recovery() 2025-01-31 07:52:49.829 GMT [7884][client backend] [014_binary.pl][:0] LOG: disconnection: session time: 0:00:00.012 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:49.889 GMT [4388][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:49.890 GMT [4388][client backend] [[unknown]][0/9:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:49.890 GMT [4388][client backend] [[unknown]][0/9:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=014_binary.pl 2025-01-31 07:52:49.893 GMT [4388][client backend] [014_binary.pl][0/10:0] LOG: statement: SELECT pg_current_wal_lsn() 2025-01-31 07:52:49.896 GMT [4388][client backend] [014_binary.pl][:0] LOG: disconnection: session time: 0:00:00.011 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:50.029 GMT [5436][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-31 07:52:50.031 GMT [5436][client backend] [[unknown]][1/7:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/014_binary/data/t_014_binary_publisher_data/pgdata/pg_hba.conf:117) 2025-01-31 07:52:50.031 GMT [5436][client backend] [[unknown]][1/7:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=014_binary.pl 2025-01-31 07:52:50.046 GMT [5436][client backend] [014_binary.pl][1/8:0] LOG: statement: SELECT '0/17B2238' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tsub', 'walreceiver') 2025-01-31 07:52:50.053 GMT [5436][client backend] [014_binary.pl][:0] LOG: disconnection: session time: 0:00:00.027 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:51.214 GMT [1608][walsender] [tsub][24/0:0] LOG: released logical replication slot "tpub_slot" 2025-01-31 07:52:51.215 GMT [1608][walsender] [tsub][:0] LOG: disconnection: session time: 0:00:01.605 user=SYSTEM database=postgres host=[local] 2025-01-31 07:52:51.340 GMT [7116][postmaster] LOG: received immediate shutdown request TRAP: failed Assert("(remainMask.mask | targetMask.mask) == BTYPE_MASK_ALL.mask"), File: "../src/backend/postmaster/postmaster.c", Line: 2951, PID: 7116 abort() has been called