2024-11-24 06:03:40.195 GMT [3500][postmaster] LOG: starting PostgreSQL 18devel on x86_64-windows, compiled by msvc-19.29.30157, 64-bit 2024-11-24 06:03:40.196 GMT [3500][postmaster] LOG: listening on Unix socket "C:/Windows/TEMP/vLsxcV_O6N/.s.PGSQL.15608" 2024-11-24 06:03:40.219 GMT [6104][startup] LOG: database system was shut down at 2024-11-24 05:56:53 GMT 2024-11-24 06:03:40.247 GMT [3500][postmaster] LOG: database system is ready to accept connections 2024-11-24 06:03:41.684 GMT [5648][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:41.686 GMT [5648][client backend] [[unknown]][0/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:41.686 GMT [5648][client backend] [[unknown]][0/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=004_sync.pl 2024-11-24 06:03:41.736 GMT [5648][client backend] [004_sync.pl][0/2:0] LOG: statement: CREATE TABLE tab_rep (a int primary key) 2024-11-24 06:03:41.754 GMT [5648][client backend] [004_sync.pl][:0] LOG: disconnection: session time: 0:00:00.074 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:41.911 GMT [2736][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:41.912 GMT [2736][client backend] [[unknown]][1/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:41.912 GMT [2736][client backend] [[unknown]][1/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=004_sync.pl 2024-11-24 06:03:41.923 GMT [2736][client backend] [004_sync.pl][1/2:0] LOG: statement: INSERT INTO tab_rep SELECT generate_series(1,10) 2024-11-24 06:03:41.926 GMT [2736][client backend] [004_sync.pl][:0] LOG: disconnection: session time: 0:00:00.036 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:42.233 GMT [7048][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:42.234 GMT [7048][client backend] [[unknown]][2/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:42.234 GMT [7048][client backend] [[unknown]][2/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=004_sync.pl 2024-11-24 06:03:42.237 GMT [7048][client backend] [004_sync.pl][2/2:0] LOG: statement: CREATE PUBLICATION tap_pub FOR ALL TABLES 2024-11-24 06:03:42.239 GMT [7048][client backend] [004_sync.pl][:0] LOG: disconnection: session time: 0:00:00.009 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:42.450 GMT [4208][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:42.451 GMT [4208][walsender] [[unknown]][22/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:42.451 GMT [4208][walsender] [[unknown]][22/1:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-11-24 06:03:42.471 GMT [4208][walsender] [tap_sub][22/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-24 06:03:42.472 GMT [4208][walsender] [tap_sub][22/3:0] LOG: statement: SELECT t.pubname FROM pg_catalog.pg_publication t WHERE t.pubname IN ('tap_pub') 2024-11-24 06:03:42.476 GMT [4208][walsender] [tap_sub][22/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 ( 'tap_pub' )) AS gpt ON gpt.relid = c.oid 2024-11-24 06:03:42.485 GMT [4208][walsender] [tap_sub][22/0:0] LOG: received replication command: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-24 06:03:42.485 GMT [4208][walsender] [tap_sub][22/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-24 06:03:42.489 GMT [4208][walsender] [tap_sub][22/0:0] LOG: logical decoding found consistent point at 0/17878A0 2024-11-24 06:03:42.489 GMT [4208][walsender] [tap_sub][22/0:0] DETAIL: There are no running transactions. 2024-11-24 06:03:42.489 GMT [4208][walsender] [tap_sub][22/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-24 06:03:42.490 GMT [4208][walsender] [tap_sub][22/0:0] LOG: released logical replication slot "tap_sub" 2024-11-24 06:03:42.490 GMT [4208][walsender] [tap_sub][22/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-24 06:03:42.490 GMT [4208][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:00.049 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:42.624 GMT [4508][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:42.626 GMT [4508][walsender] [[unknown]][23/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:42.626 GMT [4508][walsender] [[unknown]][23/1:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-11-24 06:03:42.643 GMT [4508][walsender] [tap_sub][23/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-24 06:03:42.644 GMT [4508][walsender] [tap_sub][23/0:0] LOG: received replication command: IDENTIFY_SYSTEM 2024-11-24 06:03:42.644 GMT [4508][walsender] [tap_sub][23/0:0] STATEMENT: IDENTIFY_SYSTEM 2024-11-24 06:03:42.644 GMT [4508][walsender] [tap_sub][23/0:0] LOG: received replication command: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:42.644 GMT [4508][walsender] [tap_sub][23/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:42.644 GMT [4508][walsender] [tap_sub][23/0:0] LOG: acquired logical replication slot "tap_sub" 2024-11-24 06:03:42.644 GMT [4508][walsender] [tap_sub][23/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:42.664 GMT [4508][walsender] [tap_sub][23/0:0] LOG: starting logical decoding for slot "tap_sub" 2024-11-24 06:03:42.664 GMT [4508][walsender] [tap_sub][23/0:0] DETAIL: Streaming transactions committing after 0/17878D8, reading WAL from 0/17878A0. 2024-11-24 06:03:42.664 GMT [4508][walsender] [tap_sub][23/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:42.664 GMT [4508][walsender] [tap_sub][23/0:0] LOG: logical decoding found consistent point at 0/17878A0 2024-11-24 06:03:42.664 GMT [4508][walsender] [tap_sub][23/0:0] DETAIL: There are no running transactions. 2024-11-24 06:03:42.664 GMT [4508][walsender] [tap_sub][23/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:42.711 GMT [4604][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:42.713 GMT [4604][walsender] [[unknown]][24/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:42.713 GMT [4604][walsender] [[unknown]][24/1:0] LOG: replication connection authorized: user=SYSTEM application_name=pg_16390_sync_16384_7440720796304225096 2024-11-24 06:03:42.715 GMT [4604][walsender] [pg_16390_sync_16384_7440720796304225096][24/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-24 06:03:42.716 GMT [4604][walsender] [pg_16390_sync_16384_7440720796304225096][24/3:0] LOG: statement: BEGIN READ ONLY ISOLATION LEVEL REPEATABLE READ 2024-11-24 06:03:42.717 GMT [4604][walsender] [pg_16390_sync_16384_7440720796304225096][24/3:0] LOG: received replication command: CREATE_REPLICATION_SLOT "pg_16390_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:42.717 GMT [4604][walsender] [pg_16390_sync_16384_7440720796304225096][24/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16390_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:42.723 GMT [4604][walsender] [pg_16390_sync_16384_7440720796304225096][24/3:0] LOG: logical decoding found consistent point at 0/17878D8 2024-11-24 06:03:42.723 GMT [4604][walsender] [pg_16390_sync_16384_7440720796304225096][24/3:0] DETAIL: There are no running transactions. 2024-11-24 06:03:42.723 GMT [4604][walsender] [pg_16390_sync_16384_7440720796304225096][24/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16390_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:42.724 GMT [4604][walsender] [pg_16390_sync_16384_7440720796304225096][24/3:0] LOG: released logical replication slot "pg_16390_sync_16384_7440720796304225096" 2024-11-24 06:03:42.724 GMT [4604][walsender] [pg_16390_sync_16384_7440720796304225096][24/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16390_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:42.725 GMT [4604][walsender] [pg_16390_sync_16384_7440720796304225096][24/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 = 'tab_rep' 2024-11-24 06:03:42.729 GMT [4604][walsender] [pg_16390_sync_16384_7440720796304225096][24/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 ( 'tap_pub' ) 2024-11-24 06:03:42.733 GMT [4604][walsender] [pg_16390_sync_16384_7440720796304225096][24/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 2024-11-24 06:03:42.738 GMT [4604][walsender] [pg_16390_sync_16384_7440720796304225096][24/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 ( 'tap_pub' ) 2024-11-24 06:03:42.739 GMT [4604][walsender] [pg_16390_sync_16384_7440720796304225096][24/3:0] LOG: statement: COPY public.tab_rep (a) TO STDOUT 2024-11-24 06:03:42.740 GMT [4604][walsender] [pg_16390_sync_16384_7440720796304225096][24/3:0] LOG: statement: COMMIT 2024-11-24 06:03:42.741 GMT [4604][walsender] [pg_16390_sync_16384_7440720796304225096][24/0:0] LOG: received replication command: START_REPLICATION SLOT "pg_16390_sync_16384_7440720796304225096" LOGICAL 0/1787910 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:42.741 GMT [4604][walsender] [pg_16390_sync_16384_7440720796304225096][24/0:0] STATEMENT: START_REPLICATION SLOT "pg_16390_sync_16384_7440720796304225096" LOGICAL 0/1787910 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:42.741 GMT [4604][walsender] [pg_16390_sync_16384_7440720796304225096][24/0:0] LOG: acquired logical replication slot "pg_16390_sync_16384_7440720796304225096" 2024-11-24 06:03:42.741 GMT [4604][walsender] [pg_16390_sync_16384_7440720796304225096][24/0:0] STATEMENT: START_REPLICATION SLOT "pg_16390_sync_16384_7440720796304225096" LOGICAL 0/1787910 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:42.741 GMT [4604][walsender] [pg_16390_sync_16384_7440720796304225096][24/0:0] LOG: starting logical decoding for slot "pg_16390_sync_16384_7440720796304225096" 2024-11-24 06:03:42.741 GMT [4604][walsender] [pg_16390_sync_16384_7440720796304225096][24/0:0] DETAIL: Streaming transactions committing after 0/1787910, reading WAL from 0/17878D8. 2024-11-24 06:03:42.741 GMT [4604][walsender] [pg_16390_sync_16384_7440720796304225096][24/0:0] STATEMENT: START_REPLICATION SLOT "pg_16390_sync_16384_7440720796304225096" LOGICAL 0/1787910 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:42.741 GMT [4604][walsender] [pg_16390_sync_16384_7440720796304225096][24/0:0] LOG: logical decoding found consistent point at 0/17878D8 2024-11-24 06:03:42.741 GMT [4604][walsender] [pg_16390_sync_16384_7440720796304225096][24/0:0] DETAIL: There are no running transactions. 2024-11-24 06:03:42.741 GMT [4604][walsender] [pg_16390_sync_16384_7440720796304225096][24/0:0] STATEMENT: START_REPLICATION SLOT "pg_16390_sync_16384_7440720796304225096" LOGICAL 0/1787910 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:42.741 GMT [4604][walsender] [pg_16390_sync_16384_7440720796304225096][24/0:0] LOG: released logical replication slot "pg_16390_sync_16384_7440720796304225096" 2024-11-24 06:03:42.741 GMT [4604][walsender] [pg_16390_sync_16384_7440720796304225096][24/0:0] STATEMENT: START_REPLICATION SLOT "pg_16390_sync_16384_7440720796304225096" LOGICAL 0/1787910 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:42.741 GMT [4604][walsender] [pg_16390_sync_16384_7440720796304225096][24/0:0] LOG: received replication command: DROP_REPLICATION_SLOT pg_16390_sync_16384_7440720796304225096 WAIT 2024-11-24 06:03:42.741 GMT [4604][walsender] [pg_16390_sync_16384_7440720796304225096][24/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16390_sync_16384_7440720796304225096 WAIT 2024-11-24 06:03:42.741 GMT [4604][walsender] [pg_16390_sync_16384_7440720796304225096][24/0:0] LOG: acquired logical replication slot "pg_16390_sync_16384_7440720796304225096" 2024-11-24 06:03:42.741 GMT [4604][walsender] [pg_16390_sync_16384_7440720796304225096][24/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16390_sync_16384_7440720796304225096 WAIT 2024-11-24 06:03:42.743 GMT [4604][walsender] [pg_16390_sync_16384_7440720796304225096][:0] LOG: disconnection: session time: 0:00:00.034 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:42.924 GMT [6716][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:42.927 GMT [6716][client backend] [[unknown]][3/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:42.927 GMT [6716][client backend] [[unknown]][3/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=004_sync.pl 2024-11-24 06:03:42.934 GMT [6716][client backend] [004_sync.pl][3/2:0] LOG: statement: SELECT pg_is_in_recovery() 2024-11-24 06:03:42.937 GMT [6716][client backend] [004_sync.pl][:0] LOG: disconnection: session time: 0:00:00.021 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:43.019 GMT [2348][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:43.021 GMT [2348][client backend] [[unknown]][4/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:43.021 GMT [2348][client backend] [[unknown]][4/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=004_sync.pl 2024-11-24 06:03:43.024 GMT [2348][client backend] [004_sync.pl][4/2:0] LOG: statement: SELECT pg_current_wal_lsn() 2024-11-24 06:03:43.026 GMT [2348][client backend] [004_sync.pl][:0] LOG: disconnection: session time: 0:00:00.009 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:43.102 GMT [6776][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:43.103 GMT [6776][client backend] [[unknown]][5/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:43.103 GMT [6776][client backend] [[unknown]][5/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=004_sync.pl 2024-11-24 06:03:43.106 GMT [6776][client backend] [004_sync.pl][5/2:0] LOG: statement: SELECT '0/1787910' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-11-24 06:03:43.115 GMT [6776][client backend] [004_sync.pl][:0] LOG: disconnection: session time: 0:00:00.016 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:43.382 GMT [4508][walsender] [tap_sub][23/0:0] LOG: released logical replication slot "tap_sub" 2024-11-24 06:03:43.382 GMT [4508][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:00.760 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:43.420 GMT [4284][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:43.424 GMT [4284][walsender] [[unknown]][25/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:43.424 GMT [4284][walsender] [[unknown]][25/1:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-11-24 06:03:43.429 GMT [4284][walsender] [tap_sub][25/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-24 06:03:43.429 GMT [4284][walsender] [tap_sub][25/0:0] LOG: received replication command: DROP_REPLICATION_SLOT tap_sub WAIT 2024-11-24 06:03:43.429 GMT [4284][walsender] [tap_sub][25/0:0] STATEMENT: DROP_REPLICATION_SLOT tap_sub WAIT 2024-11-24 06:03:43.429 GMT [4284][walsender] [tap_sub][25/0:0] LOG: acquired logical replication slot "tap_sub" 2024-11-24 06:03:43.429 GMT [4284][walsender] [tap_sub][25/0:0] STATEMENT: DROP_REPLICATION_SLOT tap_sub WAIT 2024-11-24 06:03:43.431 GMT [4284][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:00.014 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:43.530 GMT [1220][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:43.531 GMT [1220][client backend] [[unknown]][6/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:43.531 GMT [1220][client backend] [[unknown]][6/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=004_sync.pl 2024-11-24 06:03:43.534 GMT [1220][client backend] [004_sync.pl][6/2:0] LOG: statement: INSERT INTO tab_rep SELECT generate_series(11,20) 2024-11-24 06:03:43.536 GMT [1220][client backend] [004_sync.pl][:0] LOG: disconnection: session time: 0:00:00.008 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:43.697 GMT [5156][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:43.702 GMT [5156][walsender] [[unknown]][26/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:43.702 GMT [5156][walsender] [[unknown]][26/1:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-11-24 06:03:43.704 GMT [5156][walsender] [tap_sub][26/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-24 06:03:43.705 GMT [5156][walsender] [tap_sub][26/3:0] LOG: statement: SELECT t.pubname FROM pg_catalog.pg_publication t WHERE t.pubname IN ('tap_pub') 2024-11-24 06:03:43.707 GMT [5156][walsender] [tap_sub][26/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 ( 'tap_pub' )) AS gpt ON gpt.relid = c.oid 2024-11-24 06:03:43.713 GMT [5156][walsender] [tap_sub][26/0:0] LOG: received replication command: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-24 06:03:43.713 GMT [5156][walsender] [tap_sub][26/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-24 06:03:43.715 GMT [5156][walsender] [tap_sub][26/0:0] LOG: logical decoding found consistent point at 0/1787E40 2024-11-24 06:03:43.715 GMT [5156][walsender] [tap_sub][26/0:0] DETAIL: There are no running transactions. 2024-11-24 06:03:43.715 GMT [5156][walsender] [tap_sub][26/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-24 06:03:43.716 GMT [5156][walsender] [tap_sub][26/0:0] LOG: released logical replication slot "tap_sub" 2024-11-24 06:03:43.716 GMT [5156][walsender] [tap_sub][26/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-24 06:03:43.716 GMT [5156][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:00.022 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:43.790 GMT [6868][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:43.791 GMT [6868][walsender] [[unknown]][27/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:43.791 GMT [6868][walsender] [[unknown]][27/1:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-11-24 06:03:43.794 GMT [6868][walsender] [tap_sub][27/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-24 06:03:43.794 GMT [6868][walsender] [tap_sub][27/0:0] LOG: received replication command: IDENTIFY_SYSTEM 2024-11-24 06:03:43.794 GMT [6868][walsender] [tap_sub][27/0:0] STATEMENT: IDENTIFY_SYSTEM 2024-11-24 06:03:43.794 GMT [6868][walsender] [tap_sub][27/0:0] LOG: received replication command: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:43.794 GMT [6868][walsender] [tap_sub][27/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:43.794 GMT [6868][walsender] [tap_sub][27/0:0] LOG: acquired logical replication slot "tap_sub" 2024-11-24 06:03:43.794 GMT [6868][walsender] [tap_sub][27/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:43.795 GMT [6868][walsender] [tap_sub][27/0:0] LOG: starting logical decoding for slot "tap_sub" 2024-11-24 06:03:43.795 GMT [6868][walsender] [tap_sub][27/0:0] DETAIL: Streaming transactions committing after 0/1787E78, reading WAL from 0/1787E40. 2024-11-24 06:03:43.795 GMT [6868][walsender] [tap_sub][27/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:43.795 GMT [6868][walsender] [tap_sub][27/0:0] LOG: logical decoding found consistent point at 0/1787E40 2024-11-24 06:03:43.795 GMT [6868][walsender] [tap_sub][27/0:0] DETAIL: There are no running transactions. 2024-11-24 06:03:43.795 GMT [6868][walsender] [tap_sub][27/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:43.852 GMT [5180][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:43.854 GMT [5180][walsender] [[unknown]][28/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:43.854 GMT [5180][walsender] [[unknown]][28/1:0] LOG: replication connection authorized: user=SYSTEM application_name=pg_16391_sync_16384_7440720796304225096 2024-11-24 06:03:43.856 GMT [5180][walsender] [pg_16391_sync_16384_7440720796304225096][28/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-24 06:03:43.857 GMT [5180][walsender] [pg_16391_sync_16384_7440720796304225096][28/3:0] LOG: statement: BEGIN READ ONLY ISOLATION LEVEL REPEATABLE READ 2024-11-24 06:03:43.857 GMT [5180][walsender] [pg_16391_sync_16384_7440720796304225096][28/3:0] LOG: received replication command: CREATE_REPLICATION_SLOT "pg_16391_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:43.857 GMT [5180][walsender] [pg_16391_sync_16384_7440720796304225096][28/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16391_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:43.860 GMT [5180][walsender] [pg_16391_sync_16384_7440720796304225096][28/3:0] LOG: logical decoding found consistent point at 0/1787E78 2024-11-24 06:03:43.860 GMT [5180][walsender] [pg_16391_sync_16384_7440720796304225096][28/3:0] DETAIL: There are no running transactions. 2024-11-24 06:03:43.860 GMT [5180][walsender] [pg_16391_sync_16384_7440720796304225096][28/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16391_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:43.861 GMT [5180][walsender] [pg_16391_sync_16384_7440720796304225096][28/3:0] LOG: released logical replication slot "pg_16391_sync_16384_7440720796304225096" 2024-11-24 06:03:43.861 GMT [5180][walsender] [pg_16391_sync_16384_7440720796304225096][28/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16391_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:43.862 GMT [5180][walsender] [pg_16391_sync_16384_7440720796304225096][28/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 = 'tab_rep' 2024-11-24 06:03:43.866 GMT [5180][walsender] [pg_16391_sync_16384_7440720796304225096][28/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 ( 'tap_pub' ) 2024-11-24 06:03:43.870 GMT [5180][walsender] [pg_16391_sync_16384_7440720796304225096][28/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 2024-11-24 06:03:43.872 GMT [5180][walsender] [pg_16391_sync_16384_7440720796304225096][28/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 ( 'tap_pub' ) 2024-11-24 06:03:43.874 GMT [5180][walsender] [pg_16391_sync_16384_7440720796304225096][28/3:0] LOG: statement: COPY public.tab_rep (a) TO STDOUT 2024-11-24 06:03:43.875 GMT [5180][walsender] [pg_16391_sync_16384_7440720796304225096][:0] LOG: disconnection: session time: 0:00:00.025 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:43.953 GMT [2092][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:43.954 GMT [2092][walsender] [[unknown]][29/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:43.954 GMT [2092][walsender] [[unknown]][29/1:0] LOG: replication connection authorized: user=SYSTEM application_name=pg_16391_sync_16384_7440720796304225096 2024-11-24 06:03:43.958 GMT [2092][walsender] [pg_16391_sync_16384_7440720796304225096][29/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-24 06:03:43.959 GMT [2092][walsender] [pg_16391_sync_16384_7440720796304225096][29/0:0] LOG: received replication command: DROP_REPLICATION_SLOT pg_16391_sync_16384_7440720796304225096 WAIT 2024-11-24 06:03:43.959 GMT [2092][walsender] [pg_16391_sync_16384_7440720796304225096][29/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16391_sync_16384_7440720796304225096 WAIT 2024-11-24 06:03:43.959 GMT [2092][walsender] [pg_16391_sync_16384_7440720796304225096][29/0:0] LOG: acquired logical replication slot "pg_16391_sync_16384_7440720796304225096" 2024-11-24 06:03:43.959 GMT [2092][walsender] [pg_16391_sync_16384_7440720796304225096][29/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16391_sync_16384_7440720796304225096 WAIT 2024-11-24 06:03:43.960 GMT [2092][walsender] [pg_16391_sync_16384_7440720796304225096][29/3:0] LOG: statement: BEGIN READ ONLY ISOLATION LEVEL REPEATABLE READ 2024-11-24 06:03:43.960 GMT [2092][walsender] [pg_16391_sync_16384_7440720796304225096][29/3:0] LOG: received replication command: CREATE_REPLICATION_SLOT "pg_16391_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:43.960 GMT [2092][walsender] [pg_16391_sync_16384_7440720796304225096][29/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16391_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:43.965 GMT [2092][walsender] [pg_16391_sync_16384_7440720796304225096][29/3:0] LOG: logical decoding found consistent point at 0/1787EB0 2024-11-24 06:03:43.965 GMT [2092][walsender] [pg_16391_sync_16384_7440720796304225096][29/3:0] DETAIL: There are no running transactions. 2024-11-24 06:03:43.965 GMT [2092][walsender] [pg_16391_sync_16384_7440720796304225096][29/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16391_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:43.966 GMT [2092][walsender] [pg_16391_sync_16384_7440720796304225096][29/3:0] LOG: released logical replication slot "pg_16391_sync_16384_7440720796304225096" 2024-11-24 06:03:43.966 GMT [2092][walsender] [pg_16391_sync_16384_7440720796304225096][29/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16391_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:43.967 GMT [2092][walsender] [pg_16391_sync_16384_7440720796304225096][29/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 = 'tab_rep' 2024-11-24 06:03:43.971 GMT [2092][walsender] [pg_16391_sync_16384_7440720796304225096][29/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 ( 'tap_pub' ) 2024-11-24 06:03:43.975 GMT [2092][walsender] [pg_16391_sync_16384_7440720796304225096][29/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 2024-11-24 06:03:43.977 GMT [2092][walsender] [pg_16391_sync_16384_7440720796304225096][29/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 ( 'tap_pub' ) 2024-11-24 06:03:43.978 GMT [2092][walsender] [pg_16391_sync_16384_7440720796304225096][29/3:0] LOG: statement: COPY public.tab_rep (a) TO STDOUT 2024-11-24 06:03:43.979 GMT [2092][walsender] [pg_16391_sync_16384_7440720796304225096][:0] LOG: disconnection: session time: 0:00:00.029 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:44.051 GMT [4668][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:44.052 GMT [4668][walsender] [[unknown]][30/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:44.052 GMT [4668][walsender] [[unknown]][30/1:0] LOG: replication connection authorized: user=SYSTEM application_name=pg_16391_sync_16384_7440720796304225096 2024-11-24 06:03:44.056 GMT [4668][walsender] [pg_16391_sync_16384_7440720796304225096][30/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-24 06:03:44.057 GMT [4668][walsender] [pg_16391_sync_16384_7440720796304225096][30/0:0] LOG: received replication command: DROP_REPLICATION_SLOT pg_16391_sync_16384_7440720796304225096 WAIT 2024-11-24 06:03:44.057 GMT [4668][walsender] [pg_16391_sync_16384_7440720796304225096][30/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16391_sync_16384_7440720796304225096 WAIT 2024-11-24 06:03:44.057 GMT [4668][walsender] [pg_16391_sync_16384_7440720796304225096][30/0:0] LOG: acquired logical replication slot "pg_16391_sync_16384_7440720796304225096" 2024-11-24 06:03:44.057 GMT [4668][walsender] [pg_16391_sync_16384_7440720796304225096][30/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16391_sync_16384_7440720796304225096 WAIT 2024-11-24 06:03:44.058 GMT [4668][walsender] [pg_16391_sync_16384_7440720796304225096][30/3:0] LOG: statement: BEGIN READ ONLY ISOLATION LEVEL REPEATABLE READ 2024-11-24 06:03:44.058 GMT [4668][walsender] [pg_16391_sync_16384_7440720796304225096][30/3:0] LOG: received replication command: CREATE_REPLICATION_SLOT "pg_16391_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:44.058 GMT [4668][walsender] [pg_16391_sync_16384_7440720796304225096][30/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16391_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:44.064 GMT [4668][walsender] [pg_16391_sync_16384_7440720796304225096][30/3:0] LOG: logical decoding found consistent point at 0/1787EE8 2024-11-24 06:03:44.064 GMT [4668][walsender] [pg_16391_sync_16384_7440720796304225096][30/3:0] DETAIL: There are no running transactions. 2024-11-24 06:03:44.064 GMT [4668][walsender] [pg_16391_sync_16384_7440720796304225096][30/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16391_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:44.065 GMT [4668][walsender] [pg_16391_sync_16384_7440720796304225096][30/3:0] LOG: released logical replication slot "pg_16391_sync_16384_7440720796304225096" 2024-11-24 06:03:44.065 GMT [4668][walsender] [pg_16391_sync_16384_7440720796304225096][30/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16391_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:44.066 GMT [4668][walsender] [pg_16391_sync_16384_7440720796304225096][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 = 'tab_rep' 2024-11-24 06:03:44.083 GMT [4668][walsender] [pg_16391_sync_16384_7440720796304225096][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 = 16384 AND c.oid = gpt.relid AND p.pubname IN ( 'tap_pub' ) 2024-11-24 06:03:44.087 GMT [4668][walsender] [pg_16391_sync_16384_7440720796304225096][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(16384)) WHERE a.attnum > 0::pg_catalog.int2 AND NOT a.attisdropped AND a.attrelid = 16384 ORDER BY a.attnum 2024-11-24 06:03:44.089 GMT [4668][walsender] [pg_16391_sync_16384_7440720796304225096][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 = 16384 AND p.pubname IN ( 'tap_pub' ) 2024-11-24 06:03:44.090 GMT [4668][walsender] [pg_16391_sync_16384_7440720796304225096][30/3:0] LOG: statement: COPY public.tab_rep (a) TO STDOUT 2024-11-24 06:03:44.091 GMT [4668][walsender] [pg_16391_sync_16384_7440720796304225096][:0] LOG: disconnection: session time: 0:00:00.043 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:44.178 GMT [4680][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:44.183 GMT [4680][walsender] [[unknown]][31/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:44.183 GMT [4680][walsender] [[unknown]][31/1:0] LOG: replication connection authorized: user=SYSTEM application_name=pg_16391_sync_16384_7440720796304225096 2024-11-24 06:03:44.196 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][31/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-24 06:03:44.197 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][31/0:0] LOG: received replication command: DROP_REPLICATION_SLOT pg_16391_sync_16384_7440720796304225096 WAIT 2024-11-24 06:03:44.197 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][31/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16391_sync_16384_7440720796304225096 WAIT 2024-11-24 06:03:44.197 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][31/0:0] LOG: acquired logical replication slot "pg_16391_sync_16384_7440720796304225096" 2024-11-24 06:03:44.197 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][31/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16391_sync_16384_7440720796304225096 WAIT 2024-11-24 06:03:44.200 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][31/3:0] LOG: statement: BEGIN READ ONLY ISOLATION LEVEL REPEATABLE READ 2024-11-24 06:03:44.201 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][31/3:0] LOG: received replication command: CREATE_REPLICATION_SLOT "pg_16391_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:44.201 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][31/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16391_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:44.203 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][31/3:0] LOG: logical decoding found consistent point at 0/1787F20 2024-11-24 06:03:44.203 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][31/3:0] DETAIL: There are no running transactions. 2024-11-24 06:03:44.203 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][31/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16391_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:44.204 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][31/3:0] LOG: released logical replication slot "pg_16391_sync_16384_7440720796304225096" 2024-11-24 06:03:44.204 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][31/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16391_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:44.205 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][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 = 'tab_rep' 2024-11-24 06:03:44.218 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][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 = 16384 AND c.oid = gpt.relid AND p.pubname IN ( 'tap_pub' ) 2024-11-24 06:03:44.234 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][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(16384)) WHERE a.attnum > 0::pg_catalog.int2 AND NOT a.attisdropped AND a.attrelid = 16384 ORDER BY a.attnum 2024-11-24 06:03:44.237 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][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 = 16384 AND p.pubname IN ( 'tap_pub' ) 2024-11-24 06:03:44.240 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][31/3:0] LOG: statement: COPY public.tab_rep (a) TO STDOUT 2024-11-24 06:03:44.243 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][31/3:0] LOG: statement: COMMIT 2024-11-24 06:03:44.244 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][31/0:0] LOG: received replication command: START_REPLICATION SLOT "pg_16391_sync_16384_7440720796304225096" LOGICAL 0/1787F58 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:44.244 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][31/0:0] STATEMENT: START_REPLICATION SLOT "pg_16391_sync_16384_7440720796304225096" LOGICAL 0/1787F58 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:44.244 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][31/0:0] LOG: acquired logical replication slot "pg_16391_sync_16384_7440720796304225096" 2024-11-24 06:03:44.244 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][31/0:0] STATEMENT: START_REPLICATION SLOT "pg_16391_sync_16384_7440720796304225096" LOGICAL 0/1787F58 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:44.244 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][31/0:0] LOG: starting logical decoding for slot "pg_16391_sync_16384_7440720796304225096" 2024-11-24 06:03:44.244 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][31/0:0] DETAIL: Streaming transactions committing after 0/1787F58, reading WAL from 0/1787F20. 2024-11-24 06:03:44.244 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][31/0:0] STATEMENT: START_REPLICATION SLOT "pg_16391_sync_16384_7440720796304225096" LOGICAL 0/1787F58 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:44.244 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][31/0:0] LOG: logical decoding found consistent point at 0/1787F20 2024-11-24 06:03:44.244 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][31/0:0] DETAIL: There are no running transactions. 2024-11-24 06:03:44.244 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][31/0:0] STATEMENT: START_REPLICATION SLOT "pg_16391_sync_16384_7440720796304225096" LOGICAL 0/1787F58 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:44.244 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][31/0:0] LOG: released logical replication slot "pg_16391_sync_16384_7440720796304225096" 2024-11-24 06:03:44.244 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][31/0:0] STATEMENT: START_REPLICATION SLOT "pg_16391_sync_16384_7440720796304225096" LOGICAL 0/1787F58 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:44.245 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][31/0:0] LOG: received replication command: DROP_REPLICATION_SLOT pg_16391_sync_16384_7440720796304225096 WAIT 2024-11-24 06:03:44.245 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][31/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16391_sync_16384_7440720796304225096 WAIT 2024-11-24 06:03:44.245 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][31/0:0] LOG: acquired logical replication slot "pg_16391_sync_16384_7440720796304225096" 2024-11-24 06:03:44.245 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][31/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16391_sync_16384_7440720796304225096 WAIT 2024-11-24 06:03:44.254 GMT [4680][walsender] [pg_16391_sync_16384_7440720796304225096][:0] LOG: disconnection: session time: 0:00:00.083 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:44.697 GMT [4004][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:44.698 GMT [4004][walsender] [[unknown]][22/5:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:44.698 GMT [4004][walsender] [[unknown]][22/5:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub2 2024-11-24 06:03:44.703 GMT [4004][walsender] [tap_sub2][22/6:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-24 06:03:44.704 GMT [4004][walsender] [tap_sub2][22/7:0] LOG: statement: SELECT t.pubname FROM pg_catalog.pg_publication t WHERE t.pubname IN ('tap_pub') 2024-11-24 06:03:44.706 GMT [4004][walsender] [tap_sub2][22/8: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 ( 'tap_pub' )) AS gpt ON gpt.relid = c.oid 2024-11-24 06:03:44.711 GMT [4004][walsender] [tap_sub2][22/0:0] LOG: received replication command: CREATE_REPLICATION_SLOT "tap_sub2" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-24 06:03:44.711 GMT [4004][walsender] [tap_sub2][22/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub2" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-24 06:03:44.714 GMT [4004][walsender] [tap_sub2][22/0:0] LOG: logical decoding found consistent point at 0/1787F58 2024-11-24 06:03:44.714 GMT [4004][walsender] [tap_sub2][22/0:0] DETAIL: There are no running transactions. 2024-11-24 06:03:44.714 GMT [4004][walsender] [tap_sub2][22/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub2" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-24 06:03:44.715 GMT [4004][walsender] [tap_sub2][22/0:0] LOG: released logical replication slot "tap_sub2" 2024-11-24 06:03:44.715 GMT [4004][walsender] [tap_sub2][22/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub2" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-24 06:03:44.715 GMT [4004][walsender] [tap_sub2][:0] LOG: disconnection: session time: 0:00:00.024 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:44.766 GMT [972][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:44.767 GMT [972][walsender] [[unknown]][24/4:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:44.767 GMT [972][walsender] [[unknown]][24/4:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub2 2024-11-24 06:03:44.771 GMT [972][walsender] [tap_sub2][24/5:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-24 06:03:44.772 GMT [972][walsender] [tap_sub2][24/0:0] LOG: received replication command: IDENTIFY_SYSTEM 2024-11-24 06:03:44.772 GMT [972][walsender] [tap_sub2][24/0:0] STATEMENT: IDENTIFY_SYSTEM 2024-11-24 06:03:44.772 GMT [972][walsender] [tap_sub2][24/0:0] LOG: received replication command: START_REPLICATION SLOT "tap_sub2" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:44.772 GMT [972][walsender] [tap_sub2][24/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub2" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:44.772 GMT [972][walsender] [tap_sub2][24/0:0] LOG: acquired logical replication slot "tap_sub2" 2024-11-24 06:03:44.772 GMT [972][walsender] [tap_sub2][24/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub2" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:44.772 GMT [972][walsender] [tap_sub2][24/0:0] LOG: starting logical decoding for slot "tap_sub2" 2024-11-24 06:03:44.772 GMT [972][walsender] [tap_sub2][24/0:0] DETAIL: Streaming transactions committing after 0/1787F90, reading WAL from 0/1787F58. 2024-11-24 06:03:44.772 GMT [972][walsender] [tap_sub2][24/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub2" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:44.772 GMT [972][walsender] [tap_sub2][24/0:0] LOG: logical decoding found consistent point at 0/1787F58 2024-11-24 06:03:44.772 GMT [972][walsender] [tap_sub2][24/0:0] DETAIL: There are no running transactions. 2024-11-24 06:03:44.772 GMT [972][walsender] [tap_sub2][24/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub2" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:44.907 GMT [6868][walsender] [tap_sub][27/0:0] LOG: released logical replication slot "tap_sub" 2024-11-24 06:03:44.907 GMT [6868][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:01.120 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:44.961 GMT [1452][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:44.962 GMT [1452][walsender] [[unknown]][23/4:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:44.962 GMT [1452][walsender] [[unknown]][23/4:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-11-24 06:03:44.965 GMT [1452][walsender] [tap_sub][23/5:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-24 06:03:44.965 GMT [1452][walsender] [tap_sub][23/0:0] LOG: received replication command: DROP_REPLICATION_SLOT tap_sub WAIT 2024-11-24 06:03:44.965 GMT [1452][walsender] [tap_sub][23/0:0] STATEMENT: DROP_REPLICATION_SLOT tap_sub WAIT 2024-11-24 06:03:44.965 GMT [1452][walsender] [tap_sub][23/0:0] LOG: acquired logical replication slot "tap_sub" 2024-11-24 06:03:44.965 GMT [1452][walsender] [tap_sub][23/0:0] STATEMENT: DROP_REPLICATION_SLOT tap_sub WAIT 2024-11-24 06:03:44.966 GMT [1452][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:00.017 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:45.034 GMT [972][walsender] [tap_sub2][24/0:0] LOG: released logical replication slot "tap_sub2" 2024-11-24 06:03:45.035 GMT [972][walsender] [tap_sub2][:0] LOG: disconnection: session time: 0:00:00.271 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:45.071 GMT [1144][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:45.072 GMT [1144][walsender] [[unknown]][25/3:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:45.072 GMT [1144][walsender] [[unknown]][25/3:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub2 2024-11-24 06:03:45.075 GMT [1144][walsender] [tap_sub2][25/4:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-24 06:03:45.075 GMT [1144][walsender] [tap_sub2][25/0:0] LOG: received replication command: DROP_REPLICATION_SLOT tap_sub2 WAIT 2024-11-24 06:03:45.075 GMT [1144][walsender] [tap_sub2][25/0:0] STATEMENT: DROP_REPLICATION_SLOT tap_sub2 WAIT 2024-11-24 06:03:45.075 GMT [1144][walsender] [tap_sub2][25/0:0] LOG: acquired logical replication slot "tap_sub2" 2024-11-24 06:03:45.075 GMT [1144][walsender] [tap_sub2][25/0:0] STATEMENT: DROP_REPLICATION_SLOT tap_sub2 WAIT 2024-11-24 06:03:45.077 GMT [1144][walsender] [tap_sub2][:0] LOG: disconnection: session time: 0:00:00.009 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:45.480 GMT [6428][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:45.481 GMT [6428][walsender] [[unknown]][26/5:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:45.481 GMT [6428][walsender] [[unknown]][26/5:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-11-24 06:03:45.485 GMT [6428][walsender] [tap_sub][26/6:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-24 06:03:45.485 GMT [6428][walsender] [tap_sub][26/7:0] LOG: statement: SELECT t.pubname FROM pg_catalog.pg_publication t WHERE t.pubname IN ('tap_pub') 2024-11-24 06:03:45.487 GMT [6428][walsender] [tap_sub][26/8: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 ( 'tap_pub' )) AS gpt ON gpt.relid = c.oid 2024-11-24 06:03:45.493 GMT [6428][walsender] [tap_sub][26/0:0] LOG: received replication command: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-24 06:03:45.493 GMT [6428][walsender] [tap_sub][26/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-24 06:03:45.500 GMT [6428][walsender] [tap_sub][26/0:0] LOG: logical decoding found consistent point at 0/1787F90 2024-11-24 06:03:45.500 GMT [6428][walsender] [tap_sub][26/0:0] DETAIL: There are no running transactions. 2024-11-24 06:03:45.500 GMT [6428][walsender] [tap_sub][26/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-24 06:03:45.501 GMT [6428][walsender] [tap_sub][26/0:0] LOG: released logical replication slot "tap_sub" 2024-11-24 06:03:45.501 GMT [6428][walsender] [tap_sub][26/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-24 06:03:45.501 GMT [6428][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:00.033 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:45.548 GMT [5240][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:45.549 GMT [5240][walsender] [[unknown]][28/4:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:45.549 GMT [5240][walsender] [[unknown]][28/4:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-11-24 06:03:45.552 GMT [5240][walsender] [tap_sub][28/5:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-24 06:03:45.552 GMT [5240][walsender] [tap_sub][28/0:0] LOG: received replication command: IDENTIFY_SYSTEM 2024-11-24 06:03:45.552 GMT [5240][walsender] [tap_sub][28/0:0] STATEMENT: IDENTIFY_SYSTEM 2024-11-24 06:03:45.553 GMT [5240][walsender] [tap_sub][28/0:0] LOG: received replication command: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:45.553 GMT [5240][walsender] [tap_sub][28/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:45.553 GMT [5240][walsender] [tap_sub][28/0:0] LOG: acquired logical replication slot "tap_sub" 2024-11-24 06:03:45.553 GMT [5240][walsender] [tap_sub][28/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:45.553 GMT [5240][walsender] [tap_sub][28/0:0] LOG: starting logical decoding for slot "tap_sub" 2024-11-24 06:03:45.553 GMT [5240][walsender] [tap_sub][28/0:0] DETAIL: Streaming transactions committing after 0/1787FC8, reading WAL from 0/1787F90. 2024-11-24 06:03:45.553 GMT [5240][walsender] [tap_sub][28/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:45.553 GMT [5240][walsender] [tap_sub][28/0:0] LOG: logical decoding found consistent point at 0/1787F90 2024-11-24 06:03:45.553 GMT [5240][walsender] [tap_sub][28/0:0] DETAIL: There are no running transactions. 2024-11-24 06:03:45.553 GMT [5240][walsender] [tap_sub][28/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:45.606 GMT [4844][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:45.608 GMT [4844][walsender] [[unknown]][29/4:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:45.608 GMT [4844][walsender] [[unknown]][29/4:0] LOG: replication connection authorized: user=SYSTEM application_name=pg_16393_sync_16384_7440720796304225096 2024-11-24 06:03:45.613 GMT [4844][walsender] [pg_16393_sync_16384_7440720796304225096][29/5:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-24 06:03:45.614 GMT [4844][walsender] [pg_16393_sync_16384_7440720796304225096][29/6:0] LOG: statement: BEGIN READ ONLY ISOLATION LEVEL REPEATABLE READ 2024-11-24 06:03:45.614 GMT [4844][walsender] [pg_16393_sync_16384_7440720796304225096][29/6:0] LOG: received replication command: CREATE_REPLICATION_SLOT "pg_16393_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:45.614 GMT [4844][walsender] [pg_16393_sync_16384_7440720796304225096][29/6:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16393_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:45.618 GMT [4844][walsender] [pg_16393_sync_16384_7440720796304225096][29/6:0] LOG: logical decoding found consistent point at 0/1787FC8 2024-11-24 06:03:45.618 GMT [4844][walsender] [pg_16393_sync_16384_7440720796304225096][29/6:0] DETAIL: There are no running transactions. 2024-11-24 06:03:45.618 GMT [4844][walsender] [pg_16393_sync_16384_7440720796304225096][29/6:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16393_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:45.619 GMT [4844][walsender] [pg_16393_sync_16384_7440720796304225096][29/6:0] LOG: released logical replication slot "pg_16393_sync_16384_7440720796304225096" 2024-11-24 06:03:45.619 GMT [4844][walsender] [pg_16393_sync_16384_7440720796304225096][29/6:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16393_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:45.620 GMT [4844][walsender] [pg_16393_sync_16384_7440720796304225096][29/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 = 'tab_rep' 2024-11-24 06:03:45.624 GMT [4844][walsender] [pg_16393_sync_16384_7440720796304225096][29/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 = 16384 AND c.oid = gpt.relid AND p.pubname IN ( 'tap_pub' ) 2024-11-24 06:03:45.627 GMT [4844][walsender] [pg_16393_sync_16384_7440720796304225096][29/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(16384)) WHERE a.attnum > 0::pg_catalog.int2 AND NOT a.attisdropped AND a.attrelid = 16384 ORDER BY a.attnum 2024-11-24 06:03:45.629 GMT [4844][walsender] [pg_16393_sync_16384_7440720796304225096][29/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 = 16384 AND p.pubname IN ( 'tap_pub' ) 2024-11-24 06:03:45.631 GMT [4844][walsender] [pg_16393_sync_16384_7440720796304225096][29/6:0] LOG: statement: COPY public.tab_rep (a) TO STDOUT 2024-11-24 06:03:45.632 GMT [4844][walsender] [pg_16393_sync_16384_7440720796304225096][29/6:0] LOG: statement: COMMIT 2024-11-24 06:03:45.632 GMT [4844][walsender] [pg_16393_sync_16384_7440720796304225096][29/0:0] LOG: received replication command: START_REPLICATION SLOT "pg_16393_sync_16384_7440720796304225096" LOGICAL 0/1788000 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:45.632 GMT [4844][walsender] [pg_16393_sync_16384_7440720796304225096][29/0:0] STATEMENT: START_REPLICATION SLOT "pg_16393_sync_16384_7440720796304225096" LOGICAL 0/1788000 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:45.632 GMT [4844][walsender] [pg_16393_sync_16384_7440720796304225096][29/0:0] LOG: acquired logical replication slot "pg_16393_sync_16384_7440720796304225096" 2024-11-24 06:03:45.632 GMT [4844][walsender] [pg_16393_sync_16384_7440720796304225096][29/0:0] STATEMENT: START_REPLICATION SLOT "pg_16393_sync_16384_7440720796304225096" LOGICAL 0/1788000 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:45.632 GMT [4844][walsender] [pg_16393_sync_16384_7440720796304225096][29/0:0] LOG: starting logical decoding for slot "pg_16393_sync_16384_7440720796304225096" 2024-11-24 06:03:45.632 GMT [4844][walsender] [pg_16393_sync_16384_7440720796304225096][29/0:0] DETAIL: Streaming transactions committing after 0/1788000, reading WAL from 0/1787FC8. 2024-11-24 06:03:45.632 GMT [4844][walsender] [pg_16393_sync_16384_7440720796304225096][29/0:0] STATEMENT: START_REPLICATION SLOT "pg_16393_sync_16384_7440720796304225096" LOGICAL 0/1788000 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:45.632 GMT [4844][walsender] [pg_16393_sync_16384_7440720796304225096][29/0:0] LOG: logical decoding found consistent point at 0/1787FC8 2024-11-24 06:03:45.632 GMT [4844][walsender] [pg_16393_sync_16384_7440720796304225096][29/0:0] DETAIL: There are no running transactions. 2024-11-24 06:03:45.632 GMT [4844][walsender] [pg_16393_sync_16384_7440720796304225096][29/0:0] STATEMENT: START_REPLICATION SLOT "pg_16393_sync_16384_7440720796304225096" LOGICAL 0/1788000 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:45.633 GMT [4844][walsender] [pg_16393_sync_16384_7440720796304225096][29/0:0] LOG: released logical replication slot "pg_16393_sync_16384_7440720796304225096" 2024-11-24 06:03:45.633 GMT [4844][walsender] [pg_16393_sync_16384_7440720796304225096][29/0:0] STATEMENT: START_REPLICATION SLOT "pg_16393_sync_16384_7440720796304225096" LOGICAL 0/1788000 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:45.633 GMT [4844][walsender] [pg_16393_sync_16384_7440720796304225096][29/0:0] LOG: received replication command: DROP_REPLICATION_SLOT pg_16393_sync_16384_7440720796304225096 WAIT 2024-11-24 06:03:45.633 GMT [4844][walsender] [pg_16393_sync_16384_7440720796304225096][29/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16393_sync_16384_7440720796304225096 WAIT 2024-11-24 06:03:45.633 GMT [4844][walsender] [pg_16393_sync_16384_7440720796304225096][29/0:0] LOG: acquired logical replication slot "pg_16393_sync_16384_7440720796304225096" 2024-11-24 06:03:45.633 GMT [4844][walsender] [pg_16393_sync_16384_7440720796304225096][29/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16393_sync_16384_7440720796304225096 WAIT 2024-11-24 06:03:45.634 GMT [4844][walsender] [pg_16393_sync_16384_7440720796304225096][:0] LOG: disconnection: session time: 0:00:00.030 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:46.120 GMT [4536][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:46.121 GMT [4536][client backend] [[unknown]][7/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:46.121 GMT [4536][client backend] [[unknown]][7/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=004_sync.pl 2024-11-24 06:03:46.125 GMT [4536][client backend] [004_sync.pl][7/2:0] LOG: statement: CREATE TABLE tab_rep_next (a) AS SELECT generate_series(1,10) 2024-11-24 06:03:46.130 GMT [4536][client backend] [004_sync.pl][:0] LOG: disconnection: session time: 0:00:00.013 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:46.184 GMT [1004][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:46.185 GMT [1004][client backend] [[unknown]][8/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:46.185 GMT [1004][client backend] [[unknown]][8/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=004_sync.pl 2024-11-24 06:03:46.189 GMT [1004][client backend] [004_sync.pl][8/2:0] LOG: statement: SELECT pg_is_in_recovery() 2024-11-24 06:03:46.193 GMT [1004][client backend] [004_sync.pl][:0] LOG: disconnection: session time: 0:00:00.012 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:46.245 GMT [5892][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:46.246 GMT [5892][client backend] [[unknown]][9/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:46.246 GMT [5892][client backend] [[unknown]][9/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=004_sync.pl 2024-11-24 06:03:46.249 GMT [5892][client backend] [004_sync.pl][9/2:0] LOG: statement: SELECT pg_current_wal_lsn() 2024-11-24 06:03:46.252 GMT [5892][client backend] [004_sync.pl][:0] LOG: disconnection: session time: 0:00:00.010 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:46.342 GMT [2604][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:46.344 GMT [2604][client backend] [[unknown]][0/3:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:46.344 GMT [2604][client backend] [[unknown]][0/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=004_sync.pl 2024-11-24 06:03:46.347 GMT [2604][client backend] [004_sync.pl][0/4:0] LOG: statement: SELECT '0/178B0E0' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-11-24 06:03:46.358 GMT [2604][client backend] [004_sync.pl][:0] LOG: disconnection: session time: 0:00:00.022 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:46.657 GMT [5744][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:46.658 GMT [5744][walsender] [[unknown]][30/4:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:46.658 GMT [5744][walsender] [[unknown]][30/4:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-11-24 06:03:46.675 GMT [5744][walsender] [tap_sub][30/5:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-24 06:03:46.676 GMT [5744][walsender] [tap_sub][30/6: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 ( 'tap_pub' )) AS gpt ON gpt.relid = c.oid 2024-11-24 06:03:46.683 GMT [5744][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:00.029 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:46.754 GMT [3304][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:46.756 GMT [3304][walsender] [[unknown]][31/4:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:46.756 GMT [3304][walsender] [[unknown]][31/4:0] LOG: replication connection authorized: user=SYSTEM application_name=pg_16393_sync_16394_7440720796304225096 2024-11-24 06:03:46.759 GMT [3304][walsender] [pg_16393_sync_16394_7440720796304225096][31/5:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-24 06:03:46.760 GMT [3304][walsender] [pg_16393_sync_16394_7440720796304225096][31/6:0] LOG: statement: BEGIN READ ONLY ISOLATION LEVEL REPEATABLE READ 2024-11-24 06:03:46.760 GMT [3304][walsender] [pg_16393_sync_16394_7440720796304225096][31/6:0] LOG: received replication command: CREATE_REPLICATION_SLOT "pg_16393_sync_16394_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:46.760 GMT [3304][walsender] [pg_16393_sync_16394_7440720796304225096][31/6:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16393_sync_16394_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:46.764 GMT [3304][walsender] [pg_16393_sync_16394_7440720796304225096][31/6:0] LOG: logical decoding found consistent point at 0/178B0E0 2024-11-24 06:03:46.764 GMT [3304][walsender] [pg_16393_sync_16394_7440720796304225096][31/6:0] DETAIL: There are no running transactions. 2024-11-24 06:03:46.764 GMT [3304][walsender] [pg_16393_sync_16394_7440720796304225096][31/6:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16393_sync_16394_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:46.765 GMT [3304][walsender] [pg_16393_sync_16394_7440720796304225096][31/6:0] LOG: released logical replication slot "pg_16393_sync_16394_7440720796304225096" 2024-11-24 06:03:46.765 GMT [3304][walsender] [pg_16393_sync_16394_7440720796304225096][31/6:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16393_sync_16394_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:46.765 GMT [3304][walsender] [pg_16393_sync_16394_7440720796304225096][31/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 = 'tab_rep_next' 2024-11-24 06:03:46.769 GMT [3304][walsender] [pg_16393_sync_16394_7440720796304225096][31/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 = 16391 AND c.oid = gpt.relid AND p.pubname IN ( 'tap_pub' ) 2024-11-24 06:03:46.773 GMT [3304][walsender] [pg_16393_sync_16394_7440720796304225096][31/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(16391)) WHERE a.attnum > 0::pg_catalog.int2 AND NOT a.attisdropped AND a.attrelid = 16391 ORDER BY a.attnum 2024-11-24 06:03:46.775 GMT [3304][walsender] [pg_16393_sync_16394_7440720796304225096][31/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 = 16391 AND p.pubname IN ( 'tap_pub' ) 2024-11-24 06:03:46.776 GMT [3304][walsender] [pg_16393_sync_16394_7440720796304225096][31/6:0] LOG: statement: COPY public.tab_rep_next (a) TO STDOUT 2024-11-24 06:03:46.777 GMT [3304][walsender] [pg_16393_sync_16394_7440720796304225096][31/6:0] LOG: statement: COMMIT 2024-11-24 06:03:46.777 GMT [3304][walsender] [pg_16393_sync_16394_7440720796304225096][31/0:0] LOG: received replication command: START_REPLICATION SLOT "pg_16393_sync_16394_7440720796304225096" LOGICAL 0/178B118 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:46.777 GMT [3304][walsender] [pg_16393_sync_16394_7440720796304225096][31/0:0] STATEMENT: START_REPLICATION SLOT "pg_16393_sync_16394_7440720796304225096" LOGICAL 0/178B118 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:46.777 GMT [3304][walsender] [pg_16393_sync_16394_7440720796304225096][31/0:0] LOG: acquired logical replication slot "pg_16393_sync_16394_7440720796304225096" 2024-11-24 06:03:46.777 GMT [3304][walsender] [pg_16393_sync_16394_7440720796304225096][31/0:0] STATEMENT: START_REPLICATION SLOT "pg_16393_sync_16394_7440720796304225096" LOGICAL 0/178B118 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:46.778 GMT [3304][walsender] [pg_16393_sync_16394_7440720796304225096][31/0:0] LOG: starting logical decoding for slot "pg_16393_sync_16394_7440720796304225096" 2024-11-24 06:03:46.778 GMT [3304][walsender] [pg_16393_sync_16394_7440720796304225096][31/0:0] DETAIL: Streaming transactions committing after 0/178B118, reading WAL from 0/178B0E0. 2024-11-24 06:03:46.778 GMT [3304][walsender] [pg_16393_sync_16394_7440720796304225096][31/0:0] STATEMENT: START_REPLICATION SLOT "pg_16393_sync_16394_7440720796304225096" LOGICAL 0/178B118 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:46.778 GMT [3304][walsender] [pg_16393_sync_16394_7440720796304225096][31/0:0] LOG: logical decoding found consistent point at 0/178B0E0 2024-11-24 06:03:46.778 GMT [3304][walsender] [pg_16393_sync_16394_7440720796304225096][31/0:0] DETAIL: There are no running transactions. 2024-11-24 06:03:46.778 GMT [3304][walsender] [pg_16393_sync_16394_7440720796304225096][31/0:0] STATEMENT: START_REPLICATION SLOT "pg_16393_sync_16394_7440720796304225096" LOGICAL 0/178B118 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:46.778 GMT [3304][walsender] [pg_16393_sync_16394_7440720796304225096][31/0:0] LOG: released logical replication slot "pg_16393_sync_16394_7440720796304225096" 2024-11-24 06:03:46.778 GMT [3304][walsender] [pg_16393_sync_16394_7440720796304225096][31/0:0] STATEMENT: START_REPLICATION SLOT "pg_16393_sync_16394_7440720796304225096" LOGICAL 0/178B118 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:46.778 GMT [3304][walsender] [pg_16393_sync_16394_7440720796304225096][31/0:0] LOG: received replication command: DROP_REPLICATION_SLOT pg_16393_sync_16394_7440720796304225096 WAIT 2024-11-24 06:03:46.778 GMT [3304][walsender] [pg_16393_sync_16394_7440720796304225096][31/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16393_sync_16394_7440720796304225096 WAIT 2024-11-24 06:03:46.778 GMT [3304][walsender] [pg_16393_sync_16394_7440720796304225096][31/0:0] LOG: acquired logical replication slot "pg_16393_sync_16394_7440720796304225096" 2024-11-24 06:03:46.778 GMT [3304][walsender] [pg_16393_sync_16394_7440720796304225096][31/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16393_sync_16394_7440720796304225096 WAIT 2024-11-24 06:03:46.779 GMT [3304][walsender] [pg_16393_sync_16394_7440720796304225096][:0] LOG: disconnection: session time: 0:00:00.028 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:47.203 GMT [4228][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:47.205 GMT [4228][client backend] [[unknown]][1/3:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:47.205 GMT [4228][client backend] [[unknown]][1/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=004_sync.pl 2024-11-24 06:03:47.208 GMT [4228][client backend] [004_sync.pl][1/4:0] LOG: statement: INSERT INTO tab_rep_next SELECT generate_series(1,10) 2024-11-24 06:03:47.210 GMT [4228][client backend] [004_sync.pl][:0] LOG: disconnection: session time: 0:00:00.012 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:47.317 GMT [8][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:47.318 GMT [8][client backend] [[unknown]][2/3:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:47.318 GMT [8][client backend] [[unknown]][2/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=004_sync.pl 2024-11-24 06:03:47.321 GMT [8][client backend] [004_sync.pl][2/4:0] LOG: statement: SELECT pg_is_in_recovery() 2024-11-24 06:03:47.327 GMT [8][client backend] [004_sync.pl][:0] LOG: disconnection: session time: 0:00:00.015 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:47.405 GMT [5372][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:47.407 GMT [5372][client backend] [[unknown]][3/3:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:47.407 GMT [5372][client backend] [[unknown]][3/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=004_sync.pl 2024-11-24 06:03:47.410 GMT [5372][client backend] [004_sync.pl][3/4:0] LOG: statement: SELECT pg_current_wal_lsn() 2024-11-24 06:03:47.414 GMT [5372][client backend] [004_sync.pl][:0] LOG: disconnection: session time: 0:00:00.013 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:47.458 GMT [6088][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:47.460 GMT [6088][client backend] [[unknown]][4/3:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:47.460 GMT [6088][client backend] [[unknown]][4/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=004_sync.pl 2024-11-24 06:03:47.462 GMT [6088][client backend] [004_sync.pl][4/4:0] LOG: statement: SELECT '0/178B3C8' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-11-24 06:03:47.471 GMT [6088][client backend] [004_sync.pl][:0] LOG: disconnection: session time: 0:00:00.015 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:47.630 GMT [1152][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:47.631 GMT [1152][client backend] [[unknown]][5/3:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:47.631 GMT [1152][client backend] [[unknown]][5/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=004_sync.pl 2024-11-24 06:03:47.633 GMT [1152][client backend] [004_sync.pl][5/4:0] LOG: statement: DROP TABLE tab_rep_next 2024-11-24 06:03:47.638 GMT [1152][client backend] [004_sync.pl][:0] LOG: disconnection: session time: 0:00:00.011 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:47.957 GMT [5240][walsender] [tap_sub][28/0:0] LOG: released logical replication slot "tap_sub" 2024-11-24 06:03:47.957 GMT [5240][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:02.411 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:47.991 GMT [5108][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:47.992 GMT [5108][walsender] [[unknown]][22/9:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:47.992 GMT [5108][walsender] [[unknown]][22/9:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-11-24 06:03:47.994 GMT [5108][walsender] [tap_sub][22/10:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-24 06:03:47.995 GMT [5108][walsender] [tap_sub][22/0:0] LOG: received replication command: DROP_REPLICATION_SLOT tap_sub WAIT 2024-11-24 06:03:47.995 GMT [5108][walsender] [tap_sub][22/0:0] STATEMENT: DROP_REPLICATION_SLOT tap_sub WAIT 2024-11-24 06:03:47.995 GMT [5108][walsender] [tap_sub][22/0:0] LOG: acquired logical replication slot "tap_sub" 2024-11-24 06:03:47.995 GMT [5108][walsender] [tap_sub][22/0:0] STATEMENT: DROP_REPLICATION_SLOT tap_sub WAIT 2024-11-24 06:03:47.996 GMT [5108][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:00.008 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:48.129 GMT [4604][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:48.130 GMT [4604][walsender] [[unknown]][27/4:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:48.130 GMT [4604][walsender] [[unknown]][27/4:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-11-24 06:03:48.133 GMT [4604][walsender] [tap_sub][27/5:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-24 06:03:48.133 GMT [4604][walsender] [tap_sub][27/6:0] LOG: statement: SELECT t.pubname FROM pg_catalog.pg_publication t WHERE t.pubname IN ('tap_pub') 2024-11-24 06:03:48.135 GMT [4604][walsender] [tap_sub][27/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 ( 'tap_pub' )) AS gpt ON gpt.relid = c.oid 2024-11-24 06:03:48.142 GMT [4604][walsender] [tap_sub][27/0:0] LOG: received replication command: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-24 06:03:48.142 GMT [4604][walsender] [tap_sub][27/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-24 06:03:48.146 GMT [4604][walsender] [tap_sub][27/0:0] LOG: logical decoding found consistent point at 0/178BE20 2024-11-24 06:03:48.146 GMT [4604][walsender] [tap_sub][27/0:0] DETAIL: There are no running transactions. 2024-11-24 06:03:48.146 GMT [4604][walsender] [tap_sub][27/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-24 06:03:48.147 GMT [4604][walsender] [tap_sub][27/0:0] LOG: released logical replication slot "tap_sub" 2024-11-24 06:03:48.147 GMT [4604][walsender] [tap_sub][27/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-24 06:03:48.147 GMT [4604][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:00.020 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:48.231 GMT [3340][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:48.234 GMT [3340][walsender] [[unknown]][23/6:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:48.234 GMT [3340][walsender] [[unknown]][23/6:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-11-24 06:03:48.252 GMT [3340][walsender] [tap_sub][23/7:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-24 06:03:48.253 GMT [3340][walsender] [tap_sub][23/0:0] LOG: received replication command: IDENTIFY_SYSTEM 2024-11-24 06:03:48.253 GMT [3340][walsender] [tap_sub][23/0:0] STATEMENT: IDENTIFY_SYSTEM 2024-11-24 06:03:48.253 GMT [3340][walsender] [tap_sub][23/0:0] LOG: received replication command: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:48.253 GMT [3340][walsender] [tap_sub][23/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:48.253 GMT [3340][walsender] [tap_sub][23/0:0] LOG: acquired logical replication slot "tap_sub" 2024-11-24 06:03:48.253 GMT [3340][walsender] [tap_sub][23/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:48.254 GMT [3340][walsender] [tap_sub][23/0:0] LOG: starting logical decoding for slot "tap_sub" 2024-11-24 06:03:48.254 GMT [3340][walsender] [tap_sub][23/0:0] DETAIL: Streaming transactions committing after 0/178BE58, reading WAL from 0/178BE20. 2024-11-24 06:03:48.254 GMT [3340][walsender] [tap_sub][23/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:48.254 GMT [3340][walsender] [tap_sub][23/0:0] LOG: logical decoding found consistent point at 0/178BE20 2024-11-24 06:03:48.254 GMT [3340][walsender] [tap_sub][23/0:0] DETAIL: There are no running transactions. 2024-11-24 06:03:48.254 GMT [3340][walsender] [tap_sub][23/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-24 06:03:48.332 GMT [1036][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:48.333 GMT [1036][walsender] [[unknown]][24/7:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:48.333 GMT [1036][walsender] [[unknown]][24/7:0] LOG: replication connection authorized: user=SYSTEM application_name=pg_16397_sync_16384_7440720796304225096 2024-11-24 06:03:48.337 GMT [1036][walsender] [pg_16397_sync_16384_7440720796304225096][24/8:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-24 06:03:48.338 GMT [1036][walsender] [pg_16397_sync_16384_7440720796304225096][24/9:0] LOG: statement: BEGIN READ ONLY ISOLATION LEVEL REPEATABLE READ 2024-11-24 06:03:48.338 GMT [1036][walsender] [pg_16397_sync_16384_7440720796304225096][24/9:0] LOG: received replication command: CREATE_REPLICATION_SLOT "pg_16397_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:48.338 GMT [1036][walsender] [pg_16397_sync_16384_7440720796304225096][24/9:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16397_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:48.344 GMT [1036][walsender] [pg_16397_sync_16384_7440720796304225096][24/9:0] LOG: logical decoding found consistent point at 0/178BE58 2024-11-24 06:03:48.344 GMT [1036][walsender] [pg_16397_sync_16384_7440720796304225096][24/9:0] DETAIL: There are no running transactions. 2024-11-24 06:03:48.344 GMT [1036][walsender] [pg_16397_sync_16384_7440720796304225096][24/9:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16397_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:48.345 GMT [1036][walsender] [pg_16397_sync_16384_7440720796304225096][24/9:0] LOG: released logical replication slot "pg_16397_sync_16384_7440720796304225096" 2024-11-24 06:03:48.345 GMT [1036][walsender] [pg_16397_sync_16384_7440720796304225096][24/9:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16397_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:48.345 GMT [1036][walsender] [pg_16397_sync_16384_7440720796304225096][24/9: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 = 'tab_rep' 2024-11-24 06:03:48.349 GMT [1036][walsender] [pg_16397_sync_16384_7440720796304225096][24/9: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 ( 'tap_pub' ) 2024-11-24 06:03:48.353 GMT [1036][walsender] [pg_16397_sync_16384_7440720796304225096][24/9: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 2024-11-24 06:03:48.355 GMT [1036][walsender] [pg_16397_sync_16384_7440720796304225096][24/9: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 ( 'tap_pub' ) 2024-11-24 06:03:48.356 GMT [1036][walsender] [pg_16397_sync_16384_7440720796304225096][24/9:0] LOG: statement: COPY public.tab_rep (a) TO STDOUT 2024-11-24 06:03:48.357 GMT [1036][walsender] [pg_16397_sync_16384_7440720796304225096][:0] LOG: disconnection: session time: 0:00:00.028 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:48.560 GMT [7056][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:48.561 GMT [7056][walsender] [[unknown]][25/5:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:48.561 GMT [7056][walsender] [[unknown]][25/5:0] LOG: replication connection authorized: user=SYSTEM application_name=pg_16397_sync_16384_7440720796304225096 2024-11-24 06:03:48.565 GMT [7056][walsender] [pg_16397_sync_16384_7440720796304225096][25/6:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-24 06:03:48.565 GMT [7056][walsender] [pg_16397_sync_16384_7440720796304225096][25/0:0] LOG: received replication command: DROP_REPLICATION_SLOT pg_16397_sync_16384_7440720796304225096 WAIT 2024-11-24 06:03:48.565 GMT [7056][walsender] [pg_16397_sync_16384_7440720796304225096][25/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16397_sync_16384_7440720796304225096 WAIT 2024-11-24 06:03:48.565 GMT [7056][walsender] [pg_16397_sync_16384_7440720796304225096][25/0:0] LOG: acquired logical replication slot "pg_16397_sync_16384_7440720796304225096" 2024-11-24 06:03:48.565 GMT [7056][walsender] [pg_16397_sync_16384_7440720796304225096][25/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16397_sync_16384_7440720796304225096 WAIT 2024-11-24 06:03:48.567 GMT [7056][walsender] [pg_16397_sync_16384_7440720796304225096][25/7:0] LOG: statement: BEGIN READ ONLY ISOLATION LEVEL REPEATABLE READ 2024-11-24 06:03:48.567 GMT [7056][walsender] [pg_16397_sync_16384_7440720796304225096][25/7:0] LOG: received replication command: CREATE_REPLICATION_SLOT "pg_16397_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:48.567 GMT [7056][walsender] [pg_16397_sync_16384_7440720796304225096][25/7:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16397_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:48.570 GMT [7056][walsender] [pg_16397_sync_16384_7440720796304225096][25/7:0] LOG: logical decoding found consistent point at 0/178BE90 2024-11-24 06:03:48.570 GMT [7056][walsender] [pg_16397_sync_16384_7440720796304225096][25/7:0] DETAIL: There are no running transactions. 2024-11-24 06:03:48.570 GMT [7056][walsender] [pg_16397_sync_16384_7440720796304225096][25/7:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16397_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:48.571 GMT [7056][walsender] [pg_16397_sync_16384_7440720796304225096][25/7:0] LOG: released logical replication slot "pg_16397_sync_16384_7440720796304225096" 2024-11-24 06:03:48.571 GMT [7056][walsender] [pg_16397_sync_16384_7440720796304225096][25/7:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16397_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:48.572 GMT [7056][walsender] [pg_16397_sync_16384_7440720796304225096][25/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 = 'tab_rep' 2024-11-24 06:03:48.576 GMT [7056][walsender] [pg_16397_sync_16384_7440720796304225096][25/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 = 16384 AND c.oid = gpt.relid AND p.pubname IN ( 'tap_pub' ) 2024-11-24 06:03:48.579 GMT [7056][walsender] [pg_16397_sync_16384_7440720796304225096][25/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(16384)) WHERE a.attnum > 0::pg_catalog.int2 AND NOT a.attisdropped AND a.attrelid = 16384 ORDER BY a.attnum 2024-11-24 06:03:48.581 GMT [7056][walsender] [pg_16397_sync_16384_7440720796304225096][25/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 = 16384 AND p.pubname IN ( 'tap_pub' ) 2024-11-24 06:03:48.583 GMT [7056][walsender] [pg_16397_sync_16384_7440720796304225096][25/7:0] LOG: statement: COPY public.tab_rep (a) TO STDOUT 2024-11-24 06:03:48.584 GMT [7056][walsender] [pg_16397_sync_16384_7440720796304225096][:0] LOG: disconnection: session time: 0:00:00.027 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:48.734 GMT [6868][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:48.736 GMT [6868][walsender] [[unknown]][26/9:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:48.736 GMT [6868][walsender] [[unknown]][26/9:0] LOG: replication connection authorized: user=SYSTEM application_name=pg_16397_sync_16384_7440720796304225096 2024-11-24 06:03:48.740 GMT [6868][walsender] [pg_16397_sync_16384_7440720796304225096][26/10:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-24 06:03:48.741 GMT [6868][walsender] [pg_16397_sync_16384_7440720796304225096][26/0:0] LOG: received replication command: DROP_REPLICATION_SLOT pg_16397_sync_16384_7440720796304225096 WAIT 2024-11-24 06:03:48.741 GMT [6868][walsender] [pg_16397_sync_16384_7440720796304225096][26/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16397_sync_16384_7440720796304225096 WAIT 2024-11-24 06:03:48.741 GMT [6868][walsender] [pg_16397_sync_16384_7440720796304225096][26/0:0] LOG: acquired logical replication slot "pg_16397_sync_16384_7440720796304225096" 2024-11-24 06:03:48.741 GMT [6868][walsender] [pg_16397_sync_16384_7440720796304225096][26/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16397_sync_16384_7440720796304225096 WAIT 2024-11-24 06:03:48.743 GMT [6868][walsender] [pg_16397_sync_16384_7440720796304225096][26/11:0] LOG: statement: BEGIN READ ONLY ISOLATION LEVEL REPEATABLE READ 2024-11-24 06:03:48.743 GMT [6868][walsender] [pg_16397_sync_16384_7440720796304225096][26/11:0] LOG: received replication command: CREATE_REPLICATION_SLOT "pg_16397_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:48.743 GMT [6868][walsender] [pg_16397_sync_16384_7440720796304225096][26/11:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16397_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:48.747 GMT [6868][walsender] [pg_16397_sync_16384_7440720796304225096][26/11:0] LOG: logical decoding found consistent point at 0/178BEC8 2024-11-24 06:03:48.747 GMT [6868][walsender] [pg_16397_sync_16384_7440720796304225096][26/11:0] DETAIL: There are no running transactions. 2024-11-24 06:03:48.747 GMT [6868][walsender] [pg_16397_sync_16384_7440720796304225096][26/11:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16397_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:48.748 GMT [6868][walsender] [pg_16397_sync_16384_7440720796304225096][26/11:0] LOG: released logical replication slot "pg_16397_sync_16384_7440720796304225096" 2024-11-24 06:03:48.748 GMT [6868][walsender] [pg_16397_sync_16384_7440720796304225096][26/11:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16397_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-24 06:03:48.749 GMT [6868][walsender] [pg_16397_sync_16384_7440720796304225096][26/11: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 = 'tab_rep' 2024-11-24 06:03:48.753 GMT [6868][walsender] [pg_16397_sync_16384_7440720796304225096][26/11: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 ( 'tap_pub' ) 2024-11-24 06:03:48.759 GMT [6868][walsender] [pg_16397_sync_16384_7440720796304225096][26/11: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 2024-11-24 06:03:48.761 GMT [6868][walsender] [pg_16397_sync_16384_7440720796304225096][26/11: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 ( 'tap_pub' ) 2024-11-24 06:03:48.762 GMT [6868][walsender] [pg_16397_sync_16384_7440720796304225096][26/11:0] LOG: statement: COPY public.tab_rep (a) TO STDOUT 2024-11-24 06:03:48.763 GMT [6868][walsender] [pg_16397_sync_16384_7440720796304225096][:0] LOG: disconnection: session time: 0:00:00.033 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:48.780 GMT [3340][walsender] [tap_sub][23/0:0] LOG: released logical replication slot "tap_sub" 2024-11-24 06:03:48.780 GMT [3340][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:00.558 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:48.839 GMT [5080][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:48.841 GMT [5080][walsender] [[unknown]][29/7:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:48.841 GMT [5080][walsender] [[unknown]][29/7:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-11-24 06:03:48.845 GMT [5080][walsender] [tap_sub][29/8:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-24 06:03:48.846 GMT [5080][walsender] [tap_sub][29/0:0] LOG: received replication command: DROP_REPLICATION_SLOT pg_16397_sync_16384_7440720796304225096 WAIT 2024-11-24 06:03:48.846 GMT [5080][walsender] [tap_sub][29/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16397_sync_16384_7440720796304225096 WAIT 2024-11-24 06:03:48.846 GMT [5080][walsender] [tap_sub][29/0:0] LOG: acquired logical replication slot "pg_16397_sync_16384_7440720796304225096" 2024-11-24 06:03:48.846 GMT [5080][walsender] [tap_sub][29/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16397_sync_16384_7440720796304225096 WAIT 2024-11-24 06:03:48.847 GMT [5080][walsender] [tap_sub][29/0:0] LOG: received replication command: DROP_REPLICATION_SLOT tap_sub WAIT 2024-11-24 06:03:48.847 GMT [5080][walsender] [tap_sub][29/0:0] STATEMENT: DROP_REPLICATION_SLOT tap_sub WAIT 2024-11-24 06:03:48.847 GMT [5080][walsender] [tap_sub][29/0:0] LOG: acquired logical replication slot "tap_sub" 2024-11-24 06:03:48.847 GMT [5080][walsender] [tap_sub][29/0:0] STATEMENT: DROP_REPLICATION_SLOT tap_sub WAIT 2024-11-24 06:03:48.850 GMT [5080][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:00.013 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:49.030 GMT [3928][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-24 06:03:49.031 GMT [3928][client backend] [[unknown]][6/3:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/004_sync/data/t_004_sync_publisher_data/pgdata/pg_hba.conf:117) 2024-11-24 06:03:49.031 GMT [3928][client backend] [[unknown]][6/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=004_sync.pl 2024-11-24 06:03:49.035 GMT [3928][client backend] [004_sync.pl][6/4:0] LOG: statement: SELECT count(*) = 0 FROM pg_replication_slots 2024-11-24 06:03:49.043 GMT [3928][client backend] [004_sync.pl][:0] LOG: disconnection: session time: 0:00:00.016 user=SYSTEM database=postgres host=[local] 2024-11-24 06:03:50.487 GMT [3500][postmaster] LOG: received immediate shutdown request TRAP: failed Assert("(remainMask.mask | targetMask.mask) == BTYPE_MASK_ALL.mask"), File: "../src/backend/postmaster/postmaster.c", Line: 2887, PID: 3500 abort() has been called