2024-11-14 22:04:53.495 GMT [5668][postmaster] LOG: starting PostgreSQL 18devel on x86_64-windows, compiled by msvc-19.29.30157, 64-bit 2024-11-14 22:04:53.497 GMT [5668][postmaster] LOG: listening on Unix socket "C:/Windows/TEMP/T6NB0fqOsd/.s.PGSQL.18952" 2024-11-14 22:04:53.554 GMT [4280][startup] LOG: database system was shut down at 2024-11-14 21:57:22 GMT 2024-11-14 22:04:53.585 GMT [5668][postmaster] LOG: database system is ready to accept connections 2024-11-14 22:04:55.472 GMT [4440][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:04:55.473 GMT [4440][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-14 22:04:55.481 GMT [4440][client backend] [[unknown]][0/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=004_sync.pl 2024-11-14 22:04:55.503 GMT [4440][client backend] [004_sync.pl][0/2:0] LOG: statement: CREATE TABLE tab_rep (a int primary key) 2024-11-14 22:04:55.544 GMT [4440][client backend] [004_sync.pl][:0] LOG: disconnection: session time: 0:00:00.074 user=SYSTEM database=postgres host=[local] 2024-11-14 22:04:55.702 GMT [2408][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:04:55.704 GMT [2408][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-14 22:04:55.704 GMT [2408][client backend] [[unknown]][1/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=004_sync.pl 2024-11-14 22:04:55.711 GMT [2408][client backend] [004_sync.pl][1/2:0] LOG: statement: INSERT INTO tab_rep SELECT generate_series(1,10) 2024-11-14 22:04:55.714 GMT [2408][client backend] [004_sync.pl][:0] LOG: disconnection: session time: 0:00:00.014 user=SYSTEM database=postgres host=[local] 2024-11-14 22:04:55.998 GMT [8176][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:04:55.999 GMT [8176][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-14 22:04:55.999 GMT [8176][client backend] [[unknown]][2/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=004_sync.pl 2024-11-14 22:04:56.002 GMT [8176][client backend] [004_sync.pl][2/2:0] LOG: statement: CREATE PUBLICATION tap_pub FOR ALL TABLES 2024-11-14 22:04:56.007 GMT [8176][client backend] [004_sync.pl][:0] LOG: disconnection: session time: 0:00:00.012 user=SYSTEM database=postgres host=[local] 2024-11-14 22:04:56.180 GMT [7524][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:04:56.181 GMT [7524][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-14 22:04:56.181 GMT [7524][walsender] [[unknown]][22/1:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-11-14 22:04:56.196 GMT [7524][walsender] [tap_sub][22/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-14 22:04:56.197 GMT [7524][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-14 22:04:56.200 GMT [7524][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-14 22:04:56.207 GMT [7524][walsender] [tap_sub][22/0:0] LOG: received replication command: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-14 22:04:56.207 GMT [7524][walsender] [tap_sub][22/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-14 22:04:56.211 GMT [7524][walsender] [tap_sub][22/0:0] LOG: logical decoding found consistent point at 0/17878A0 2024-11-14 22:04:56.211 GMT [7524][walsender] [tap_sub][22/0:0] DETAIL: There are no running transactions. 2024-11-14 22:04:56.211 GMT [7524][walsender] [tap_sub][22/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-14 22:04:56.212 GMT [7524][walsender] [tap_sub][22/0:0] LOG: released logical replication slot "tap_sub" 2024-11-14 22:04:56.212 GMT [7524][walsender] [tap_sub][22/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-14 22:04:56.212 GMT [7524][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:00.035 user=SYSTEM database=postgres host=[local] 2024-11-14 22:04:56.271 GMT [3932][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:04:56.273 GMT [3932][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-14 22:04:56.273 GMT [3932][walsender] [[unknown]][23/1:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-11-14 22:04:56.279 GMT [3932][walsender] [tap_sub][23/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-14 22:04:56.280 GMT [3932][walsender] [tap_sub][23/0:0] LOG: received replication command: IDENTIFY_SYSTEM 2024-11-14 22:04:56.280 GMT [3932][walsender] [tap_sub][23/0:0] STATEMENT: IDENTIFY_SYSTEM 2024-11-14 22:04:56.280 GMT [3932][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-14 22:04:56.280 GMT [3932][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-14 22:04:56.280 GMT [3932][walsender] [tap_sub][23/0:0] LOG: acquired logical replication slot "tap_sub" 2024-11-14 22:04:56.280 GMT [3932][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-14 22:04:56.281 GMT [3932][walsender] [tap_sub][23/0:0] LOG: starting logical decoding for slot "tap_sub" 2024-11-14 22:04:56.281 GMT [3932][walsender] [tap_sub][23/0:0] DETAIL: Streaming transactions committing after 0/17878D8, reading WAL from 0/17878A0. 2024-11-14 22:04:56.281 GMT [3932][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-14 22:04:56.281 GMT [3932][walsender] [tap_sub][23/0:0] LOG: logical decoding found consistent point at 0/17878A0 2024-11-14 22:04:56.281 GMT [3932][walsender] [tap_sub][23/0:0] DETAIL: There are no running transactions. 2024-11-14 22:04:56.281 GMT [3932][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-14 22:04:56.338 GMT [7416][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:04:56.339 GMT [7416][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-14 22:04:56.339 GMT [7416][walsender] [[unknown]][24/1:0] LOG: replication connection authorized: user=SYSTEM application_name=pg_16390_sync_16384_7437257455562885528 2024-11-14 22:04:56.342 GMT [7416][walsender] [pg_16390_sync_16384_7437257455562885528][24/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-14 22:04:56.343 GMT [7416][walsender] [pg_16390_sync_16384_7437257455562885528][24/3:0] LOG: statement: BEGIN READ ONLY ISOLATION LEVEL REPEATABLE READ 2024-11-14 22:04:56.343 GMT [7416][walsender] [pg_16390_sync_16384_7437257455562885528][24/3:0] LOG: received replication command: CREATE_REPLICATION_SLOT "pg_16390_sync_16384_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:04:56.343 GMT [7416][walsender] [pg_16390_sync_16384_7437257455562885528][24/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16390_sync_16384_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:04:56.353 GMT [7416][walsender] [pg_16390_sync_16384_7437257455562885528][24/3:0] LOG: logical decoding found consistent point at 0/17878D8 2024-11-14 22:04:56.353 GMT [7416][walsender] [pg_16390_sync_16384_7437257455562885528][24/3:0] DETAIL: There are no running transactions. 2024-11-14 22:04:56.353 GMT [7416][walsender] [pg_16390_sync_16384_7437257455562885528][24/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16390_sync_16384_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:04:56.354 GMT [7416][walsender] [pg_16390_sync_16384_7437257455562885528][24/3:0] LOG: released logical replication slot "pg_16390_sync_16384_7437257455562885528" 2024-11-14 22:04:56.354 GMT [7416][walsender] [pg_16390_sync_16384_7437257455562885528][24/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16390_sync_16384_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:04:56.355 GMT [7416][walsender] [pg_16390_sync_16384_7437257455562885528][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-14 22:04:56.360 GMT [7416][walsender] [pg_16390_sync_16384_7437257455562885528][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-14 22:04:56.364 GMT [7416][walsender] [pg_16390_sync_16384_7437257455562885528][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-14 22:04:56.366 GMT [7416][walsender] [pg_16390_sync_16384_7437257455562885528][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-14 22:04:56.368 GMT [7416][walsender] [pg_16390_sync_16384_7437257455562885528][24/3:0] LOG: statement: COPY public.tab_rep (a) TO STDOUT 2024-11-14 22:04:56.369 GMT [7416][walsender] [pg_16390_sync_16384_7437257455562885528][24/3:0] LOG: statement: COMMIT 2024-11-14 22:04:56.369 GMT [7416][walsender] [pg_16390_sync_16384_7437257455562885528][24/0:0] LOG: received replication command: START_REPLICATION SLOT "pg_16390_sync_16384_7437257455562885528" LOGICAL 0/1787910 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:04:56.369 GMT [7416][walsender] [pg_16390_sync_16384_7437257455562885528][24/0:0] STATEMENT: START_REPLICATION SLOT "pg_16390_sync_16384_7437257455562885528" LOGICAL 0/1787910 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:04:56.369 GMT [7416][walsender] [pg_16390_sync_16384_7437257455562885528][24/0:0] LOG: acquired logical replication slot "pg_16390_sync_16384_7437257455562885528" 2024-11-14 22:04:56.369 GMT [7416][walsender] [pg_16390_sync_16384_7437257455562885528][24/0:0] STATEMENT: START_REPLICATION SLOT "pg_16390_sync_16384_7437257455562885528" LOGICAL 0/1787910 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:04:56.369 GMT [7416][walsender] [pg_16390_sync_16384_7437257455562885528][24/0:0] LOG: starting logical decoding for slot "pg_16390_sync_16384_7437257455562885528" 2024-11-14 22:04:56.369 GMT [7416][walsender] [pg_16390_sync_16384_7437257455562885528][24/0:0] DETAIL: Streaming transactions committing after 0/1787910, reading WAL from 0/17878D8. 2024-11-14 22:04:56.369 GMT [7416][walsender] [pg_16390_sync_16384_7437257455562885528][24/0:0] STATEMENT: START_REPLICATION SLOT "pg_16390_sync_16384_7437257455562885528" LOGICAL 0/1787910 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:04:56.370 GMT [7416][walsender] [pg_16390_sync_16384_7437257455562885528][24/0:0] LOG: logical decoding found consistent point at 0/17878D8 2024-11-14 22:04:56.370 GMT [7416][walsender] [pg_16390_sync_16384_7437257455562885528][24/0:0] DETAIL: There are no running transactions. 2024-11-14 22:04:56.370 GMT [7416][walsender] [pg_16390_sync_16384_7437257455562885528][24/0:0] STATEMENT: START_REPLICATION SLOT "pg_16390_sync_16384_7437257455562885528" LOGICAL 0/1787910 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:04:56.370 GMT [7416][walsender] [pg_16390_sync_16384_7437257455562885528][24/0:0] LOG: released logical replication slot "pg_16390_sync_16384_7437257455562885528" 2024-11-14 22:04:56.370 GMT [7416][walsender] [pg_16390_sync_16384_7437257455562885528][24/0:0] STATEMENT: START_REPLICATION SLOT "pg_16390_sync_16384_7437257455562885528" LOGICAL 0/1787910 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:04:56.370 GMT [7416][walsender] [pg_16390_sync_16384_7437257455562885528][24/0:0] LOG: received replication command: DROP_REPLICATION_SLOT pg_16390_sync_16384_7437257455562885528 WAIT 2024-11-14 22:04:56.370 GMT [7416][walsender] [pg_16390_sync_16384_7437257455562885528][24/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16390_sync_16384_7437257455562885528 WAIT 2024-11-14 22:04:56.370 GMT [7416][walsender] [pg_16390_sync_16384_7437257455562885528][24/0:0] LOG: acquired logical replication slot "pg_16390_sync_16384_7437257455562885528" 2024-11-14 22:04:56.370 GMT [7416][walsender] [pg_16390_sync_16384_7437257455562885528][24/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16390_sync_16384_7437257455562885528 WAIT 2024-11-14 22:04:56.372 GMT [7416][walsender] [pg_16390_sync_16384_7437257455562885528][:0] LOG: disconnection: session time: 0:00:00.037 user=SYSTEM database=postgres host=[local] 2024-11-14 22:04:56.486 GMT [3648][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:04:56.488 GMT [3648][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-14 22:04:56.488 GMT [3648][client backend] [[unknown]][3/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=004_sync.pl 2024-11-14 22:04:56.491 GMT [3648][client backend] [004_sync.pl][3/2:0] LOG: statement: SELECT pg_is_in_recovery() 2024-11-14 22:04:56.494 GMT [3648][client backend] [004_sync.pl][:0] LOG: disconnection: session time: 0:00:00.011 user=SYSTEM database=postgres host=[local] 2024-11-14 22:04:56.594 GMT [3688][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:04:56.596 GMT [3688][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-14 22:04:56.596 GMT [3688][client backend] [[unknown]][4/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=004_sync.pl 2024-11-14 22:04:56.600 GMT [3688][client backend] [004_sync.pl][4/2:0] LOG: statement: SELECT pg_current_wal_lsn() 2024-11-14 22:04:56.604 GMT [3688][client backend] [004_sync.pl][:0] LOG: disconnection: session time: 0:00:00.013 user=SYSTEM database=postgres host=[local] 2024-11-14 22:04:56.691 GMT [5816][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:04:56.692 GMT [5816][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-14 22:04:56.692 GMT [5816][client backend] [[unknown]][5/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=004_sync.pl 2024-11-14 22:04:56.695 GMT [5816][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-14 22:04:56.704 GMT [5816][client backend] [004_sync.pl][:0] LOG: disconnection: session time: 0:00:00.016 user=SYSTEM database=postgres host=[local] 2024-11-14 22:04:56.966 GMT [3932][walsender] [tap_sub][23/0:0] LOG: released logical replication slot "tap_sub" 2024-11-14 22:04:56.966 GMT [3932][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:00.698 user=SYSTEM database=postgres host=[local] 2024-11-14 22:04:57.007 GMT [2440][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:04:57.008 GMT [2440][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-14 22:04:57.008 GMT [2440][walsender] [[unknown]][25/1:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-11-14 22:04:57.011 GMT [2440][walsender] [tap_sub][25/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-14 22:04:57.012 GMT [2440][walsender] [tap_sub][25/0:0] LOG: received replication command: DROP_REPLICATION_SLOT tap_sub WAIT 2024-11-14 22:04:57.012 GMT [2440][walsender] [tap_sub][25/0:0] STATEMENT: DROP_REPLICATION_SLOT tap_sub WAIT 2024-11-14 22:04:57.012 GMT [2440][walsender] [tap_sub][25/0:0] LOG: acquired logical replication slot "tap_sub" 2024-11-14 22:04:57.012 GMT [2440][walsender] [tap_sub][25/0:0] STATEMENT: DROP_REPLICATION_SLOT tap_sub WAIT 2024-11-14 22:04:57.013 GMT [2440][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:00.009 user=SYSTEM database=postgres host=[local] 2024-11-14 22:04:57.188 GMT [7776][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:04:57.189 GMT [7776][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-14 22:04:57.189 GMT [7776][client backend] [[unknown]][6/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=004_sync.pl 2024-11-14 22:04:57.192 GMT [7776][client backend] [004_sync.pl][6/2:0] LOG: statement: INSERT INTO tab_rep SELECT generate_series(11,20) 2024-11-14 22:04:57.194 GMT [7776][client backend] [004_sync.pl][:0] LOG: disconnection: session time: 0:00:00.015 user=SYSTEM database=postgres host=[local] 2024-11-14 22:04:57.316 GMT [4564][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:04:57.318 GMT [4564][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-14 22:04:57.318 GMT [4564][walsender] [[unknown]][26/1:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-11-14 22:04:57.321 GMT [4564][walsender] [tap_sub][26/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-14 22:04:57.322 GMT [4564][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-14 22:04:57.324 GMT [4564][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-14 22:04:57.331 GMT [4564][walsender] [tap_sub][26/0:0] LOG: received replication command: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-14 22:04:57.331 GMT [4564][walsender] [tap_sub][26/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-14 22:04:57.334 GMT [4564][walsender] [tap_sub][26/0:0] LOG: logical decoding found consistent point at 0/1787E40 2024-11-14 22:04:57.334 GMT [4564][walsender] [tap_sub][26/0:0] DETAIL: There are no running transactions. 2024-11-14 22:04:57.334 GMT [4564][walsender] [tap_sub][26/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-14 22:04:57.338 GMT [4564][walsender] [tap_sub][26/0:0] LOG: released logical replication slot "tap_sub" 2024-11-14 22:04:57.338 GMT [4564][walsender] [tap_sub][26/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-14 22:04:57.338 GMT [4564][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:00.025 user=SYSTEM database=postgres host=[local] 2024-11-14 22:04:57.392 GMT [7136][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:04:57.394 GMT [7136][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-14 22:04:57.394 GMT [7136][walsender] [[unknown]][27/1:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-11-14 22:04:57.396 GMT [7136][walsender] [tap_sub][27/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-14 22:04:57.397 GMT [7136][walsender] [tap_sub][27/0:0] LOG: received replication command: IDENTIFY_SYSTEM 2024-11-14 22:04:57.397 GMT [7136][walsender] [tap_sub][27/0:0] STATEMENT: IDENTIFY_SYSTEM 2024-11-14 22:04:57.398 GMT [7136][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-14 22:04:57.398 GMT [7136][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-14 22:04:57.398 GMT [7136][walsender] [tap_sub][27/0:0] LOG: acquired logical replication slot "tap_sub" 2024-11-14 22:04:57.398 GMT [7136][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-14 22:04:57.398 GMT [7136][walsender] [tap_sub][27/0:0] LOG: starting logical decoding for slot "tap_sub" 2024-11-14 22:04:57.398 GMT [7136][walsender] [tap_sub][27/0:0] DETAIL: Streaming transactions committing after 0/1787E78, reading WAL from 0/1787E40. 2024-11-14 22:04:57.398 GMT [7136][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-14 22:04:57.398 GMT [7136][walsender] [tap_sub][27/0:0] LOG: logical decoding found consistent point at 0/1787E40 2024-11-14 22:04:57.398 GMT [7136][walsender] [tap_sub][27/0:0] DETAIL: There are no running transactions. 2024-11-14 22:04:57.398 GMT [7136][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-14 22:04:57.456 GMT [7272][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:04:57.458 GMT [7272][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-14 22:04:57.458 GMT [7272][walsender] [[unknown]][28/1:0] LOG: replication connection authorized: user=SYSTEM application_name=pg_16391_sync_16384_7437257455562885528 2024-11-14 22:04:57.461 GMT [7272][walsender] [pg_16391_sync_16384_7437257455562885528][28/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-14 22:04:57.462 GMT [7272][walsender] [pg_16391_sync_16384_7437257455562885528][28/3:0] LOG: statement: BEGIN READ ONLY ISOLATION LEVEL REPEATABLE READ 2024-11-14 22:04:57.462 GMT [7272][walsender] [pg_16391_sync_16384_7437257455562885528][28/3:0] LOG: received replication command: CREATE_REPLICATION_SLOT "pg_16391_sync_16384_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:04:57.462 GMT [7272][walsender] [pg_16391_sync_16384_7437257455562885528][28/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16391_sync_16384_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:04:57.465 GMT [7272][walsender] [pg_16391_sync_16384_7437257455562885528][28/3:0] LOG: logical decoding found consistent point at 0/1787E78 2024-11-14 22:04:57.465 GMT [7272][walsender] [pg_16391_sync_16384_7437257455562885528][28/3:0] DETAIL: There are no running transactions. 2024-11-14 22:04:57.465 GMT [7272][walsender] [pg_16391_sync_16384_7437257455562885528][28/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16391_sync_16384_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:04:57.469 GMT [7272][walsender] [pg_16391_sync_16384_7437257455562885528][28/3:0] LOG: released logical replication slot "pg_16391_sync_16384_7437257455562885528" 2024-11-14 22:04:57.469 GMT [7272][walsender] [pg_16391_sync_16384_7437257455562885528][28/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16391_sync_16384_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:04:57.470 GMT [7272][walsender] [pg_16391_sync_16384_7437257455562885528][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-14 22:04:57.474 GMT [7272][walsender] [pg_16391_sync_16384_7437257455562885528][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-14 22:04:57.479 GMT [7272][walsender] [pg_16391_sync_16384_7437257455562885528][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-14 22:04:57.482 GMT [7272][walsender] [pg_16391_sync_16384_7437257455562885528][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-14 22:04:57.483 GMT [7272][walsender] [pg_16391_sync_16384_7437257455562885528][28/3:0] LOG: statement: COPY public.tab_rep (a) TO STDOUT 2024-11-14 22:04:57.485 GMT [7272][walsender] [pg_16391_sync_16384_7437257455562885528][:0] LOG: disconnection: session time: 0:00:00.031 user=SYSTEM database=postgres host=[local] 2024-11-14 22:04:57.582 GMT [1728][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:04:57.584 GMT [1728][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-14 22:04:57.584 GMT [1728][walsender] [[unknown]][29/1:0] LOG: replication connection authorized: user=SYSTEM application_name=pg_16391_sync_16384_7437257455562885528 2024-11-14 22:04:57.587 GMT [1728][walsender] [pg_16391_sync_16384_7437257455562885528][29/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-14 22:04:57.589 GMT [1728][walsender] [pg_16391_sync_16384_7437257455562885528][29/0:0] LOG: received replication command: DROP_REPLICATION_SLOT pg_16391_sync_16384_7437257455562885528 WAIT 2024-11-14 22:04:57.589 GMT [1728][walsender] [pg_16391_sync_16384_7437257455562885528][29/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16391_sync_16384_7437257455562885528 WAIT 2024-11-14 22:04:57.589 GMT [1728][walsender] [pg_16391_sync_16384_7437257455562885528][29/0:0] LOG: acquired logical replication slot "pg_16391_sync_16384_7437257455562885528" 2024-11-14 22:04:57.589 GMT [1728][walsender] [pg_16391_sync_16384_7437257455562885528][29/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16391_sync_16384_7437257455562885528 WAIT 2024-11-14 22:04:57.591 GMT [1728][walsender] [pg_16391_sync_16384_7437257455562885528][29/3:0] LOG: statement: BEGIN READ ONLY ISOLATION LEVEL REPEATABLE READ 2024-11-14 22:04:57.591 GMT [1728][walsender] [pg_16391_sync_16384_7437257455562885528][29/3:0] LOG: received replication command: CREATE_REPLICATION_SLOT "pg_16391_sync_16384_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:04:57.591 GMT [1728][walsender] [pg_16391_sync_16384_7437257455562885528][29/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16391_sync_16384_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:04:57.594 GMT [1728][walsender] [pg_16391_sync_16384_7437257455562885528][29/3:0] LOG: logical decoding found consistent point at 0/1787EB0 2024-11-14 22:04:57.594 GMT [1728][walsender] [pg_16391_sync_16384_7437257455562885528][29/3:0] DETAIL: There are no running transactions. 2024-11-14 22:04:57.594 GMT [1728][walsender] [pg_16391_sync_16384_7437257455562885528][29/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16391_sync_16384_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:04:57.595 GMT [1728][walsender] [pg_16391_sync_16384_7437257455562885528][29/3:0] LOG: released logical replication slot "pg_16391_sync_16384_7437257455562885528" 2024-11-14 22:04:57.595 GMT [1728][walsender] [pg_16391_sync_16384_7437257455562885528][29/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16391_sync_16384_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:04:57.596 GMT [1728][walsender] [pg_16391_sync_16384_7437257455562885528][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-14 22:04:57.601 GMT [1728][walsender] [pg_16391_sync_16384_7437257455562885528][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-14 22:04:57.605 GMT [1728][walsender] [pg_16391_sync_16384_7437257455562885528][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-14 22:04:57.608 GMT [1728][walsender] [pg_16391_sync_16384_7437257455562885528][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-14 22:04:57.609 GMT [1728][walsender] [pg_16391_sync_16384_7437257455562885528][29/3:0] LOG: statement: COPY public.tab_rep (a) TO STDOUT 2024-11-14 22:04:57.611 GMT [1728][walsender] [pg_16391_sync_16384_7437257455562885528][:0] LOG: disconnection: session time: 0:00:00.033 user=SYSTEM database=postgres host=[local] 2024-11-14 22:04:57.745 GMT [7720][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:04:57.747 GMT [7720][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-14 22:04:57.747 GMT [7720][walsender] [[unknown]][30/1:0] LOG: replication connection authorized: user=SYSTEM application_name=pg_16391_sync_16384_7437257455562885528 2024-11-14 22:04:57.751 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][30/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-14 22:04:57.752 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][30/0:0] LOG: received replication command: DROP_REPLICATION_SLOT pg_16391_sync_16384_7437257455562885528 WAIT 2024-11-14 22:04:57.752 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][30/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16391_sync_16384_7437257455562885528 WAIT 2024-11-14 22:04:57.752 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][30/0:0] LOG: acquired logical replication slot "pg_16391_sync_16384_7437257455562885528" 2024-11-14 22:04:57.752 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][30/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16391_sync_16384_7437257455562885528 WAIT 2024-11-14 22:04:57.754 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][30/3:0] LOG: statement: BEGIN READ ONLY ISOLATION LEVEL REPEATABLE READ 2024-11-14 22:04:57.754 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][30/3:0] LOG: received replication command: CREATE_REPLICATION_SLOT "pg_16391_sync_16384_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:04:57.754 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][30/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16391_sync_16384_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:04:57.757 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][30/3:0] LOG: logical decoding found consistent point at 0/1787EE8 2024-11-14 22:04:57.757 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][30/3:0] DETAIL: There are no running transactions. 2024-11-14 22:04:57.757 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][30/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16391_sync_16384_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:04:57.758 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][30/3:0] LOG: released logical replication slot "pg_16391_sync_16384_7437257455562885528" 2024-11-14 22:04:57.758 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][30/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16391_sync_16384_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:04:57.759 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][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-14 22:04:57.764 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][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-14 22:04:57.768 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][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-14 22:04:57.770 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][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-14 22:04:57.772 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][30/3:0] LOG: statement: COPY public.tab_rep (a) TO STDOUT 2024-11-14 22:04:57.773 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][30/3:0] LOG: statement: COMMIT 2024-11-14 22:04:57.773 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][30/0:0] LOG: received replication command: START_REPLICATION SLOT "pg_16391_sync_16384_7437257455562885528" LOGICAL 0/1787F20 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:04:57.773 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][30/0:0] STATEMENT: START_REPLICATION SLOT "pg_16391_sync_16384_7437257455562885528" LOGICAL 0/1787F20 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:04:57.773 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][30/0:0] LOG: acquired logical replication slot "pg_16391_sync_16384_7437257455562885528" 2024-11-14 22:04:57.773 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][30/0:0] STATEMENT: START_REPLICATION SLOT "pg_16391_sync_16384_7437257455562885528" LOGICAL 0/1787F20 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:04:57.774 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][30/0:0] LOG: starting logical decoding for slot "pg_16391_sync_16384_7437257455562885528" 2024-11-14 22:04:57.774 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][30/0:0] DETAIL: Streaming transactions committing after 0/1787F20, reading WAL from 0/1787EE8. 2024-11-14 22:04:57.774 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][30/0:0] STATEMENT: START_REPLICATION SLOT "pg_16391_sync_16384_7437257455562885528" LOGICAL 0/1787F20 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:04:57.774 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][30/0:0] LOG: logical decoding found consistent point at 0/1787EE8 2024-11-14 22:04:57.774 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][30/0:0] DETAIL: There are no running transactions. 2024-11-14 22:04:57.774 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][30/0:0] STATEMENT: START_REPLICATION SLOT "pg_16391_sync_16384_7437257455562885528" LOGICAL 0/1787F20 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:04:57.774 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][30/0:0] LOG: released logical replication slot "pg_16391_sync_16384_7437257455562885528" 2024-11-14 22:04:57.774 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][30/0:0] STATEMENT: START_REPLICATION SLOT "pg_16391_sync_16384_7437257455562885528" LOGICAL 0/1787F20 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:04:57.775 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][30/0:0] LOG: received replication command: DROP_REPLICATION_SLOT pg_16391_sync_16384_7437257455562885528 WAIT 2024-11-14 22:04:57.775 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][30/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16391_sync_16384_7437257455562885528 WAIT 2024-11-14 22:04:57.775 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][30/0:0] LOG: acquired logical replication slot "pg_16391_sync_16384_7437257455562885528" 2024-11-14 22:04:57.775 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][30/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16391_sync_16384_7437257455562885528 WAIT 2024-11-14 22:04:57.776 GMT [7720][walsender] [pg_16391_sync_16384_7437257455562885528][:0] LOG: disconnection: session time: 0:00:00.034 user=SYSTEM database=postgres host=[local] 2024-11-14 22:04:58.031 GMT [2324][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:04:58.033 GMT [2324][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-14 22:04:58.033 GMT [2324][walsender] [[unknown]][31/1:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub2 2024-11-14 22:04:58.039 GMT [2324][walsender] [tap_sub2][31/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-14 22:04:58.040 GMT [2324][walsender] [tap_sub2][31/3:0] LOG: statement: SELECT t.pubname FROM pg_catalog.pg_publication t WHERE t.pubname IN ('tap_pub') 2024-11-14 22:04:58.043 GMT [2324][walsender] [tap_sub2][31/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-14 22:04:58.049 GMT [2324][walsender] [tap_sub2][31/0:0] LOG: received replication command: CREATE_REPLICATION_SLOT "tap_sub2" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-14 22:04:58.049 GMT [2324][walsender] [tap_sub2][31/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub2" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-14 22:04:58.052 GMT [2324][walsender] [tap_sub2][31/0:0] LOG: logical decoding found consistent point at 0/1787F20 2024-11-14 22:04:58.052 GMT [2324][walsender] [tap_sub2][31/0:0] DETAIL: There are no running transactions. 2024-11-14 22:04:58.052 GMT [2324][walsender] [tap_sub2][31/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub2" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-14 22:04:58.053 GMT [2324][walsender] [tap_sub2][31/0:0] LOG: released logical replication slot "tap_sub2" 2024-11-14 22:04:58.053 GMT [2324][walsender] [tap_sub2][31/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub2" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-14 22:04:58.054 GMT [2324][walsender] [tap_sub2][:0] LOG: disconnection: session time: 0:00:00.026 user=SYSTEM database=postgres host=[local] 2024-11-14 22:04:58.113 GMT [4420][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:04:58.116 GMT [4420][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-14 22:04:58.116 GMT [4420][walsender] [[unknown]][22/5:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub2 2024-11-14 22:04:58.122 GMT [4420][walsender] [tap_sub2][22/6:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-14 22:04:58.123 GMT [4420][walsender] [tap_sub2][22/0:0] LOG: received replication command: IDENTIFY_SYSTEM 2024-11-14 22:04:58.123 GMT [4420][walsender] [tap_sub2][22/0:0] STATEMENT: IDENTIFY_SYSTEM 2024-11-14 22:04:58.124 GMT [4420][walsender] [tap_sub2][22/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-14 22:04:58.124 GMT [4420][walsender] [tap_sub2][22/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub2" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:04:58.124 GMT [4420][walsender] [tap_sub2][22/0:0] LOG: acquired logical replication slot "tap_sub2" 2024-11-14 22:04:58.124 GMT [4420][walsender] [tap_sub2][22/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub2" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:04:58.132 GMT [4420][walsender] [tap_sub2][22/0:0] LOG: starting logical decoding for slot "tap_sub2" 2024-11-14 22:04:58.132 GMT [4420][walsender] [tap_sub2][22/0:0] DETAIL: Streaming transactions committing after 0/1787F58, reading WAL from 0/1787F20. 2024-11-14 22:04:58.132 GMT [4420][walsender] [tap_sub2][22/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub2" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:04:58.132 GMT [4420][walsender] [tap_sub2][22/0:0] LOG: logical decoding found consistent point at 0/1787F20 2024-11-14 22:04:58.132 GMT [4420][walsender] [tap_sub2][22/0:0] DETAIL: There are no running transactions. 2024-11-14 22:04:58.132 GMT [4420][walsender] [tap_sub2][22/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub2" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:04:58.296 GMT [7136][walsender] [tap_sub][27/0:0] LOG: released logical replication slot "tap_sub" 2024-11-14 22:04:58.297 GMT [7136][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:00.907 user=SYSTEM database=postgres host=[local] 2024-11-14 22:04:58.333 GMT [836][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:04:58.335 GMT [836][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-14 22:04:58.335 GMT [836][walsender] [[unknown]][24/4:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-11-14 22:04:58.338 GMT [836][walsender] [tap_sub][24/5:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-14 22:04:58.339 GMT [836][walsender] [tap_sub][24/0:0] LOG: received replication command: DROP_REPLICATION_SLOT tap_sub WAIT 2024-11-14 22:04:58.339 GMT [836][walsender] [tap_sub][24/0:0] STATEMENT: DROP_REPLICATION_SLOT tap_sub WAIT 2024-11-14 22:04:58.339 GMT [836][walsender] [tap_sub][24/0:0] LOG: acquired logical replication slot "tap_sub" 2024-11-14 22:04:58.339 GMT [836][walsender] [tap_sub][24/0:0] STATEMENT: DROP_REPLICATION_SLOT tap_sub WAIT 2024-11-14 22:04:58.341 GMT [836][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:00.011 user=SYSTEM database=postgres host=[local] 2024-11-14 22:04:58.464 GMT [4420][walsender] [tap_sub2][22/0:0] LOG: released logical replication slot "tap_sub2" 2024-11-14 22:04:58.464 GMT [4420][walsender] [tap_sub2][:0] LOG: disconnection: session time: 0:00:00.357 user=SYSTEM database=postgres host=[local] 2024-11-14 22:04:58.486 GMT [4220][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:04:58.488 GMT [4220][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-14 22:04:58.488 GMT [4220][walsender] [[unknown]][23/4:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub2 2024-11-14 22:04:58.492 GMT [4220][walsender] [tap_sub2][23/5:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-14 22:04:58.493 GMT [4220][walsender] [tap_sub2][23/0:0] LOG: received replication command: DROP_REPLICATION_SLOT tap_sub2 WAIT 2024-11-14 22:04:58.493 GMT [4220][walsender] [tap_sub2][23/0:0] STATEMENT: DROP_REPLICATION_SLOT tap_sub2 WAIT 2024-11-14 22:04:58.493 GMT [4220][walsender] [tap_sub2][23/0:0] LOG: acquired logical replication slot "tap_sub2" 2024-11-14 22:04:58.493 GMT [4220][walsender] [tap_sub2][23/0:0] STATEMENT: DROP_REPLICATION_SLOT tap_sub2 WAIT 2024-11-14 22:04:58.494 GMT [4220][walsender] [tap_sub2][:0] LOG: disconnection: session time: 0:00:00.011 user=SYSTEM database=postgres host=[local] 2024-11-14 22:04:58.891 GMT [6616][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:04:58.892 GMT [6616][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-14 22:04:58.892 GMT [6616][walsender] [[unknown]][25/3:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-11-14 22:04:58.895 GMT [6616][walsender] [tap_sub][25/4:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-14 22:04:58.896 GMT [6616][walsender] [tap_sub][25/5:0] LOG: statement: SELECT t.pubname FROM pg_catalog.pg_publication t WHERE t.pubname IN ('tap_pub') 2024-11-14 22:04:58.898 GMT [6616][walsender] [tap_sub][25/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-14 22:04:58.904 GMT [6616][walsender] [tap_sub][25/0:0] LOG: received replication command: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-14 22:04:58.904 GMT [6616][walsender] [tap_sub][25/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-14 22:04:58.910 GMT [6616][walsender] [tap_sub][25/0:0] LOG: logical decoding found consistent point at 0/1787F58 2024-11-14 22:04:58.910 GMT [6616][walsender] [tap_sub][25/0:0] DETAIL: There are no running transactions. 2024-11-14 22:04:58.910 GMT [6616][walsender] [tap_sub][25/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-14 22:04:58.921 GMT [6616][walsender] [tap_sub][25/0:0] LOG: released logical replication slot "tap_sub" 2024-11-14 22:04:58.921 GMT [6616][walsender] [tap_sub][25/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-14 22:04:58.922 GMT [6616][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:00.034 user=SYSTEM database=postgres host=[local] 2024-11-14 22:04:58.978 GMT [4436][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:04:58.979 GMT [4436][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-14 22:04:58.979 GMT [4436][walsender] [[unknown]][26/5:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-11-14 22:04:58.982 GMT [4436][walsender] [tap_sub][26/6:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-14 22:04:58.983 GMT [4436][walsender] [tap_sub][26/0:0] LOG: received replication command: IDENTIFY_SYSTEM 2024-11-14 22:04:58.983 GMT [4436][walsender] [tap_sub][26/0:0] STATEMENT: IDENTIFY_SYSTEM 2024-11-14 22:04:58.983 GMT [4436][walsender] [tap_sub][26/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-14 22:04:58.983 GMT [4436][walsender] [tap_sub][26/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:04:58.983 GMT [4436][walsender] [tap_sub][26/0:0] LOG: acquired logical replication slot "tap_sub" 2024-11-14 22:04:58.983 GMT [4436][walsender] [tap_sub][26/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:04:58.984 GMT [4436][walsender] [tap_sub][26/0:0] LOG: starting logical decoding for slot "tap_sub" 2024-11-14 22:04:58.984 GMT [4436][walsender] [tap_sub][26/0:0] DETAIL: Streaming transactions committing after 0/1787F90, reading WAL from 0/1787F58. 2024-11-14 22:04:58.984 GMT [4436][walsender] [tap_sub][26/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:04:58.984 GMT [4436][walsender] [tap_sub][26/0:0] LOG: logical decoding found consistent point at 0/1787F58 2024-11-14 22:04:58.984 GMT [4436][walsender] [tap_sub][26/0:0] DETAIL: There are no running transactions. 2024-11-14 22:04:58.984 GMT [4436][walsender] [tap_sub][26/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:04:59.036 GMT [4192][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:04:59.037 GMT [4192][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-14 22:04:59.037 GMT [4192][walsender] [[unknown]][28/4:0] LOG: replication connection authorized: user=SYSTEM application_name=pg_16393_sync_16384_7437257455562885528 2024-11-14 22:04:59.040 GMT [4192][walsender] [pg_16393_sync_16384_7437257455562885528][28/5:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-14 22:04:59.041 GMT [4192][walsender] [pg_16393_sync_16384_7437257455562885528][28/6:0] LOG: statement: BEGIN READ ONLY ISOLATION LEVEL REPEATABLE READ 2024-11-14 22:04:59.042 GMT [4192][walsender] [pg_16393_sync_16384_7437257455562885528][28/6:0] LOG: received replication command: CREATE_REPLICATION_SLOT "pg_16393_sync_16384_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:04:59.042 GMT [4192][walsender] [pg_16393_sync_16384_7437257455562885528][28/6:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16393_sync_16384_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:04:59.045 GMT [4192][walsender] [pg_16393_sync_16384_7437257455562885528][28/6:0] LOG: logical decoding found consistent point at 0/1787F90 2024-11-14 22:04:59.045 GMT [4192][walsender] [pg_16393_sync_16384_7437257455562885528][28/6:0] DETAIL: There are no running transactions. 2024-11-14 22:04:59.045 GMT [4192][walsender] [pg_16393_sync_16384_7437257455562885528][28/6:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16393_sync_16384_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:04:59.046 GMT [4192][walsender] [pg_16393_sync_16384_7437257455562885528][28/6:0] LOG: released logical replication slot "pg_16393_sync_16384_7437257455562885528" 2024-11-14 22:04:59.046 GMT [4192][walsender] [pg_16393_sync_16384_7437257455562885528][28/6:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16393_sync_16384_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:04:59.047 GMT [4192][walsender] [pg_16393_sync_16384_7437257455562885528][28/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-14 22:04:59.052 GMT [4192][walsender] [pg_16393_sync_16384_7437257455562885528][28/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-14 22:04:59.056 GMT [4192][walsender] [pg_16393_sync_16384_7437257455562885528][28/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-14 22:04:59.058 GMT [4192][walsender] [pg_16393_sync_16384_7437257455562885528][28/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-14 22:04:59.060 GMT [4192][walsender] [pg_16393_sync_16384_7437257455562885528][28/6:0] LOG: statement: COPY public.tab_rep (a) TO STDOUT 2024-11-14 22:04:59.060 GMT [4192][walsender] [pg_16393_sync_16384_7437257455562885528][28/6:0] LOG: statement: COMMIT 2024-11-14 22:04:59.061 GMT [4192][walsender] [pg_16393_sync_16384_7437257455562885528][28/0:0] LOG: received replication command: START_REPLICATION SLOT "pg_16393_sync_16384_7437257455562885528" LOGICAL 0/1787FC8 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:04:59.061 GMT [4192][walsender] [pg_16393_sync_16384_7437257455562885528][28/0:0] STATEMENT: START_REPLICATION SLOT "pg_16393_sync_16384_7437257455562885528" LOGICAL 0/1787FC8 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:04:59.061 GMT [4192][walsender] [pg_16393_sync_16384_7437257455562885528][28/0:0] LOG: acquired logical replication slot "pg_16393_sync_16384_7437257455562885528" 2024-11-14 22:04:59.061 GMT [4192][walsender] [pg_16393_sync_16384_7437257455562885528][28/0:0] STATEMENT: START_REPLICATION SLOT "pg_16393_sync_16384_7437257455562885528" LOGICAL 0/1787FC8 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:04:59.061 GMT [4192][walsender] [pg_16393_sync_16384_7437257455562885528][28/0:0] LOG: starting logical decoding for slot "pg_16393_sync_16384_7437257455562885528" 2024-11-14 22:04:59.061 GMT [4192][walsender] [pg_16393_sync_16384_7437257455562885528][28/0:0] DETAIL: Streaming transactions committing after 0/1787FC8, reading WAL from 0/1787F90. 2024-11-14 22:04:59.061 GMT [4192][walsender] [pg_16393_sync_16384_7437257455562885528][28/0:0] STATEMENT: START_REPLICATION SLOT "pg_16393_sync_16384_7437257455562885528" LOGICAL 0/1787FC8 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:04:59.061 GMT [4192][walsender] [pg_16393_sync_16384_7437257455562885528][28/0:0] LOG: logical decoding found consistent point at 0/1787F90 2024-11-14 22:04:59.061 GMT [4192][walsender] [pg_16393_sync_16384_7437257455562885528][28/0:0] DETAIL: There are no running transactions. 2024-11-14 22:04:59.061 GMT [4192][walsender] [pg_16393_sync_16384_7437257455562885528][28/0:0] STATEMENT: START_REPLICATION SLOT "pg_16393_sync_16384_7437257455562885528" LOGICAL 0/1787FC8 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:04:59.062 GMT [4192][walsender] [pg_16393_sync_16384_7437257455562885528][28/0:0] LOG: released logical replication slot "pg_16393_sync_16384_7437257455562885528" 2024-11-14 22:04:59.062 GMT [4192][walsender] [pg_16393_sync_16384_7437257455562885528][28/0:0] STATEMENT: START_REPLICATION SLOT "pg_16393_sync_16384_7437257455562885528" LOGICAL 0/1787FC8 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:04:59.062 GMT [4192][walsender] [pg_16393_sync_16384_7437257455562885528][28/0:0] LOG: received replication command: DROP_REPLICATION_SLOT pg_16393_sync_16384_7437257455562885528 WAIT 2024-11-14 22:04:59.062 GMT [4192][walsender] [pg_16393_sync_16384_7437257455562885528][28/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16393_sync_16384_7437257455562885528 WAIT 2024-11-14 22:04:59.062 GMT [4192][walsender] [pg_16393_sync_16384_7437257455562885528][28/0:0] LOG: acquired logical replication slot "pg_16393_sync_16384_7437257455562885528" 2024-11-14 22:04:59.062 GMT [4192][walsender] [pg_16393_sync_16384_7437257455562885528][28/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16393_sync_16384_7437257455562885528 WAIT 2024-11-14 22:04:59.063 GMT [4192][walsender] [pg_16393_sync_16384_7437257455562885528][:0] LOG: disconnection: session time: 0:00:00.030 user=SYSTEM database=postgres host=[local] 2024-11-14 22:04:59.423 GMT [484][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:04:59.425 GMT [484][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-14 22:04:59.425 GMT [484][client backend] [[unknown]][7/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=004_sync.pl 2024-11-14 22:04:59.429 GMT [484][client backend] [004_sync.pl][7/2:0] LOG: statement: CREATE TABLE tab_rep_next (a) AS SELECT generate_series(1,10) 2024-11-14 22:04:59.434 GMT [484][client backend] [004_sync.pl][:0] LOG: disconnection: session time: 0:00:00.014 user=SYSTEM database=postgres host=[local] 2024-11-14 22:04:59.533 GMT [8180][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:04:59.535 GMT [8180][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-14 22:04:59.535 GMT [8180][client backend] [[unknown]][8/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=004_sync.pl 2024-11-14 22:04:59.539 GMT [8180][client backend] [004_sync.pl][8/2:0] LOG: statement: SELECT pg_is_in_recovery() 2024-11-14 22:04:59.541 GMT [8180][client backend] [004_sync.pl][:0] LOG: disconnection: session time: 0:00:00.011 user=SYSTEM database=postgres host=[local] 2024-11-14 22:04:59.609 GMT [6660][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:04:59.611 GMT [6660][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-14 22:04:59.611 GMT [6660][client backend] [[unknown]][9/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=004_sync.pl 2024-11-14 22:04:59.613 GMT [6660][client backend] [004_sync.pl][9/2:0] LOG: statement: SELECT pg_current_wal_lsn() 2024-11-14 22:04:59.616 GMT [6660][client backend] [004_sync.pl][:0] LOG: disconnection: session time: 0:00:00.009 user=SYSTEM database=postgres host=[local] 2024-11-14 22:04:59.671 GMT [1380][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:04:59.672 GMT [1380][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-14 22:04:59.672 GMT [1380][client backend] [[unknown]][0/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=004_sync.pl 2024-11-14 22:04:59.675 GMT [1380][client backend] [004_sync.pl][0/4:0] LOG: statement: SELECT '0/178B0A8' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-11-14 22:04:59.686 GMT [1380][client backend] [004_sync.pl][:0] LOG: disconnection: session time: 0:00:00.018 user=SYSTEM database=postgres host=[local] 2024-11-14 22:04:59.851 GMT [3504][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:04:59.853 GMT [3504][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-14 22:04:59.853 GMT [3504][walsender] [[unknown]][29/4:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-11-14 22:04:59.856 GMT [3504][walsender] [tap_sub][29/5:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-14 22:04:59.856 GMT [3504][walsender] [tap_sub][29/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-14 22:04:59.864 GMT [3504][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:00.016 user=SYSTEM database=postgres host=[local] 2024-11-14 22:04:59.949 GMT [2828][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:04:59.959 GMT [2828][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-14 22:04:59.959 GMT [2828][walsender] [[unknown]][30/4:0] LOG: replication connection authorized: user=SYSTEM application_name=pg_16393_sync_16394_7437257455562885528 2024-11-14 22:04:59.966 GMT [2828][walsender] [pg_16393_sync_16394_7437257455562885528][30/5:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-14 22:04:59.967 GMT [2828][walsender] [pg_16393_sync_16394_7437257455562885528][30/6:0] LOG: statement: BEGIN READ ONLY ISOLATION LEVEL REPEATABLE READ 2024-11-14 22:04:59.968 GMT [2828][walsender] [pg_16393_sync_16394_7437257455562885528][30/6:0] LOG: received replication command: CREATE_REPLICATION_SLOT "pg_16393_sync_16394_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:04:59.968 GMT [2828][walsender] [pg_16393_sync_16394_7437257455562885528][30/6:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16393_sync_16394_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:04:59.972 GMT [2828][walsender] [pg_16393_sync_16394_7437257455562885528][30/6:0] LOG: logical decoding found consistent point at 0/178B0A8 2024-11-14 22:04:59.972 GMT [2828][walsender] [pg_16393_sync_16394_7437257455562885528][30/6:0] DETAIL: There are no running transactions. 2024-11-14 22:04:59.972 GMT [2828][walsender] [pg_16393_sync_16394_7437257455562885528][30/6:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16393_sync_16394_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:04:59.973 GMT [2828][walsender] [pg_16393_sync_16394_7437257455562885528][30/6:0] LOG: released logical replication slot "pg_16393_sync_16394_7437257455562885528" 2024-11-14 22:04:59.973 GMT [2828][walsender] [pg_16393_sync_16394_7437257455562885528][30/6:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16393_sync_16394_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:04:59.973 GMT [2828][walsender] [pg_16393_sync_16394_7437257455562885528][30/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-14 22:04:59.977 GMT [2828][walsender] [pg_16393_sync_16394_7437257455562885528][30/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-14 22:04:59.982 GMT [2828][walsender] [pg_16393_sync_16394_7437257455562885528][30/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-14 22:04:59.984 GMT [2828][walsender] [pg_16393_sync_16394_7437257455562885528][30/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-14 22:04:59.986 GMT [2828][walsender] [pg_16393_sync_16394_7437257455562885528][30/6:0] LOG: statement: COPY public.tab_rep_next (a) TO STDOUT 2024-11-14 22:04:59.987 GMT [2828][walsender] [pg_16393_sync_16394_7437257455562885528][30/6:0] LOG: statement: COMMIT 2024-11-14 22:04:59.987 GMT [2828][walsender] [pg_16393_sync_16394_7437257455562885528][30/0:0] LOG: received replication command: START_REPLICATION SLOT "pg_16393_sync_16394_7437257455562885528" LOGICAL 0/178B0E0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:04:59.987 GMT [2828][walsender] [pg_16393_sync_16394_7437257455562885528][30/0:0] STATEMENT: START_REPLICATION SLOT "pg_16393_sync_16394_7437257455562885528" LOGICAL 0/178B0E0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:04:59.987 GMT [2828][walsender] [pg_16393_sync_16394_7437257455562885528][30/0:0] LOG: acquired logical replication slot "pg_16393_sync_16394_7437257455562885528" 2024-11-14 22:04:59.987 GMT [2828][walsender] [pg_16393_sync_16394_7437257455562885528][30/0:0] STATEMENT: START_REPLICATION SLOT "pg_16393_sync_16394_7437257455562885528" LOGICAL 0/178B0E0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:04:59.988 GMT [2828][walsender] [pg_16393_sync_16394_7437257455562885528][30/0:0] LOG: starting logical decoding for slot "pg_16393_sync_16394_7437257455562885528" 2024-11-14 22:04:59.988 GMT [2828][walsender] [pg_16393_sync_16394_7437257455562885528][30/0:0] DETAIL: Streaming transactions committing after 0/178B0E0, reading WAL from 0/178B0A8. 2024-11-14 22:04:59.988 GMT [2828][walsender] [pg_16393_sync_16394_7437257455562885528][30/0:0] STATEMENT: START_REPLICATION SLOT "pg_16393_sync_16394_7437257455562885528" LOGICAL 0/178B0E0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:04:59.988 GMT [2828][walsender] [pg_16393_sync_16394_7437257455562885528][30/0:0] LOG: logical decoding found consistent point at 0/178B0A8 2024-11-14 22:04:59.988 GMT [2828][walsender] [pg_16393_sync_16394_7437257455562885528][30/0:0] DETAIL: There are no running transactions. 2024-11-14 22:04:59.988 GMT [2828][walsender] [pg_16393_sync_16394_7437257455562885528][30/0:0] STATEMENT: START_REPLICATION SLOT "pg_16393_sync_16394_7437257455562885528" LOGICAL 0/178B0E0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:04:59.988 GMT [2828][walsender] [pg_16393_sync_16394_7437257455562885528][30/0:0] LOG: released logical replication slot "pg_16393_sync_16394_7437257455562885528" 2024-11-14 22:04:59.988 GMT [2828][walsender] [pg_16393_sync_16394_7437257455562885528][30/0:0] STATEMENT: START_REPLICATION SLOT "pg_16393_sync_16394_7437257455562885528" LOGICAL 0/178B0E0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:04:59.988 GMT [2828][walsender] [pg_16393_sync_16394_7437257455562885528][30/0:0] LOG: received replication command: DROP_REPLICATION_SLOT pg_16393_sync_16394_7437257455562885528 WAIT 2024-11-14 22:04:59.988 GMT [2828][walsender] [pg_16393_sync_16394_7437257455562885528][30/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16393_sync_16394_7437257455562885528 WAIT 2024-11-14 22:04:59.988 GMT [2828][walsender] [pg_16393_sync_16394_7437257455562885528][30/0:0] LOG: acquired logical replication slot "pg_16393_sync_16394_7437257455562885528" 2024-11-14 22:04:59.988 GMT [2828][walsender] [pg_16393_sync_16394_7437257455562885528][30/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16393_sync_16394_7437257455562885528 WAIT 2024-11-14 22:05:00.017 GMT [2828][walsender] [pg_16393_sync_16394_7437257455562885528][:0] LOG: disconnection: session time: 0:00:00.071 user=SYSTEM database=postgres host=[local] 2024-11-14 22:05:00.403 GMT [5180][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:05:00.412 GMT [5180][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-14 22:05:00.412 GMT [5180][client backend] [[unknown]][1/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=004_sync.pl 2024-11-14 22:05:00.416 GMT [5180][client backend] [004_sync.pl][1/4:0] LOG: statement: INSERT INTO tab_rep_next SELECT generate_series(1,10) 2024-11-14 22:05:00.418 GMT [5180][client backend] [004_sync.pl][:0] LOG: disconnection: session time: 0:00:00.018 user=SYSTEM database=postgres host=[local] 2024-11-14 22:05:00.557 GMT [7172][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:05:00.559 GMT [7172][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-14 22:05:00.559 GMT [7172][client backend] [[unknown]][2/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=004_sync.pl 2024-11-14 22:05:00.564 GMT [7172][client backend] [004_sync.pl][2/4:0] LOG: statement: SELECT pg_is_in_recovery() 2024-11-14 22:05:00.566 GMT [7172][client backend] [004_sync.pl][:0] LOG: disconnection: session time: 0:00:00.013 user=SYSTEM database=postgres host=[local] 2024-11-14 22:05:00.653 GMT [4812][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:05:00.655 GMT [4812][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-14 22:05:00.655 GMT [4812][client backend] [[unknown]][3/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=004_sync.pl 2024-11-14 22:05:00.658 GMT [4812][client backend] [004_sync.pl][3/4:0] LOG: statement: SELECT pg_current_wal_lsn() 2024-11-14 22:05:00.662 GMT [4812][client backend] [004_sync.pl][:0] LOG: disconnection: session time: 0:00:00.011 user=SYSTEM database=postgres host=[local] 2024-11-14 22:05:00.838 GMT [7020][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:05:00.839 GMT [7020][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-14 22:05:00.839 GMT [7020][client backend] [[unknown]][4/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=004_sync.pl 2024-11-14 22:05:00.855 GMT [7020][client backend] [004_sync.pl][4/4:0] LOG: statement: SELECT '0/178B390' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-11-14 22:05:00.868 GMT [7020][client backend] [004_sync.pl][:0] LOG: disconnection: session time: 0:00:00.032 user=SYSTEM database=postgres host=[local] 2024-11-14 22:05:01.106 GMT [6276][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:05:01.107 GMT [6276][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-14 22:05:01.107 GMT [6276][client backend] [[unknown]][5/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=004_sync.pl 2024-11-14 22:05:01.110 GMT [6276][client backend] [004_sync.pl][5/4:0] LOG: statement: DROP TABLE tab_rep_next 2024-11-14 22:05:01.116 GMT [6276][client backend] [004_sync.pl][:0] LOG: disconnection: session time: 0:00:00.013 user=SYSTEM database=postgres host=[local] 2024-11-14 22:05:01.327 GMT [4436][walsender] [tap_sub][26/0:0] LOG: released logical replication slot "tap_sub" 2024-11-14 22:05:01.327 GMT [4436][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:02.352 user=SYSTEM database=postgres host=[local] 2024-11-14 22:05:01.379 GMT [824][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:05:01.380 GMT [824][walsender] [[unknown]][31/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-14 22:05:01.380 GMT [824][walsender] [[unknown]][31/5:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-11-14 22:05:01.383 GMT [824][walsender] [tap_sub][31/6:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-14 22:05:01.384 GMT [824][walsender] [tap_sub][31/0:0] LOG: received replication command: DROP_REPLICATION_SLOT tap_sub WAIT 2024-11-14 22:05:01.384 GMT [824][walsender] [tap_sub][31/0:0] STATEMENT: DROP_REPLICATION_SLOT tap_sub WAIT 2024-11-14 22:05:01.384 GMT [824][walsender] [tap_sub][31/0:0] LOG: acquired logical replication slot "tap_sub" 2024-11-14 22:05:01.384 GMT [824][walsender] [tap_sub][31/0:0] STATEMENT: DROP_REPLICATION_SLOT tap_sub WAIT 2024-11-14 22:05:01.386 GMT [824][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:00.015 user=SYSTEM database=postgres host=[local] 2024-11-14 22:05:01.520 GMT [7704][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:05:01.521 GMT [7704][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-14 22:05:01.521 GMT [7704][walsender] [[unknown]][27/4:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-11-14 22:05:01.524 GMT [7704][walsender] [tap_sub][27/5:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-14 22:05:01.525 GMT [7704][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-14 22:05:01.527 GMT [7704][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-14 22:05:01.533 GMT [7704][walsender] [tap_sub][27/0:0] LOG: received replication command: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-14 22:05:01.533 GMT [7704][walsender] [tap_sub][27/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-14 22:05:01.537 GMT [7704][walsender] [tap_sub][27/0:0] LOG: logical decoding found consistent point at 0/178BDE8 2024-11-14 22:05:01.537 GMT [7704][walsender] [tap_sub][27/0:0] DETAIL: There are no running transactions. 2024-11-14 22:05:01.537 GMT [7704][walsender] [tap_sub][27/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-14 22:05:01.539 GMT [7704][walsender] [tap_sub][27/0:0] LOG: released logical replication slot "tap_sub" 2024-11-14 22:05:01.539 GMT [7704][walsender] [tap_sub][27/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-11-14 22:05:01.539 GMT [7704][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:00.026 user=SYSTEM database=postgres host=[local] 2024-11-14 22:05:01.636 GMT [2936][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:05:01.645 GMT [2936][walsender] [[unknown]][24/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-14 22:05:01.645 GMT [2936][walsender] [[unknown]][24/6:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-11-14 22:05:01.669 GMT [2936][walsender] [tap_sub][24/7:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-14 22:05:01.669 GMT [2936][walsender] [tap_sub][24/0:0] LOG: received replication command: IDENTIFY_SYSTEM 2024-11-14 22:05:01.669 GMT [2936][walsender] [tap_sub][24/0:0] STATEMENT: IDENTIFY_SYSTEM 2024-11-14 22:05:01.670 GMT [2936][walsender] [tap_sub][24/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-14 22:05:01.670 GMT [2936][walsender] [tap_sub][24/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:05:01.670 GMT [2936][walsender] [tap_sub][24/0:0] LOG: acquired logical replication slot "tap_sub" 2024-11-14 22:05:01.670 GMT [2936][walsender] [tap_sub][24/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:05:01.670 GMT [2936][walsender] [tap_sub][24/0:0] LOG: starting logical decoding for slot "tap_sub" 2024-11-14 22:05:01.670 GMT [2936][walsender] [tap_sub][24/0:0] DETAIL: Streaming transactions committing after 0/178BE20, reading WAL from 0/178BDE8. 2024-11-14 22:05:01.670 GMT [2936][walsender] [tap_sub][24/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:05:01.672 GMT [2936][walsender] [tap_sub][24/0:0] LOG: logical decoding found consistent point at 0/178BDE8 2024-11-14 22:05:01.672 GMT [2936][walsender] [tap_sub][24/0:0] DETAIL: There are no running transactions. 2024-11-14 22:05:01.672 GMT [2936][walsender] [tap_sub][24/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-11-14 22:05:01.755 GMT [3160][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:05:01.757 GMT [3160][walsender] [[unknown]][22/8: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-14 22:05:01.757 GMT [3160][walsender] [[unknown]][22/8:0] LOG: replication connection authorized: user=SYSTEM application_name=pg_16397_sync_16384_7437257455562885528 2024-11-14 22:05:01.760 GMT [3160][walsender] [pg_16397_sync_16384_7437257455562885528][22/9:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-14 22:05:01.761 GMT [3160][walsender] [pg_16397_sync_16384_7437257455562885528][22/10:0] LOG: statement: BEGIN READ ONLY ISOLATION LEVEL REPEATABLE READ 2024-11-14 22:05:01.761 GMT [3160][walsender] [pg_16397_sync_16384_7437257455562885528][22/10:0] LOG: received replication command: CREATE_REPLICATION_SLOT "pg_16397_sync_16384_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:05:01.761 GMT [3160][walsender] [pg_16397_sync_16384_7437257455562885528][22/10:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16397_sync_16384_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:05:01.765 GMT [3160][walsender] [pg_16397_sync_16384_7437257455562885528][22/10:0] LOG: logical decoding found consistent point at 0/178BE20 2024-11-14 22:05:01.765 GMT [3160][walsender] [pg_16397_sync_16384_7437257455562885528][22/10:0] DETAIL: There are no running transactions. 2024-11-14 22:05:01.765 GMT [3160][walsender] [pg_16397_sync_16384_7437257455562885528][22/10:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16397_sync_16384_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:05:01.766 GMT [3160][walsender] [pg_16397_sync_16384_7437257455562885528][22/10:0] LOG: released logical replication slot "pg_16397_sync_16384_7437257455562885528" 2024-11-14 22:05:01.766 GMT [3160][walsender] [pg_16397_sync_16384_7437257455562885528][22/10:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16397_sync_16384_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:05:01.766 GMT [3160][walsender] [pg_16397_sync_16384_7437257455562885528][22/10: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-14 22:05:01.771 GMT [3160][walsender] [pg_16397_sync_16384_7437257455562885528][22/10: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-14 22:05:01.775 GMT [3160][walsender] [pg_16397_sync_16384_7437257455562885528][22/10: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-14 22:05:01.776 GMT [3160][walsender] [pg_16397_sync_16384_7437257455562885528][22/10: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-14 22:05:01.778 GMT [3160][walsender] [pg_16397_sync_16384_7437257455562885528][22/10:0] LOG: statement: COPY public.tab_rep (a) TO STDOUT 2024-11-14 22:05:01.779 GMT [3160][walsender] [pg_16397_sync_16384_7437257455562885528][:0] LOG: disconnection: session time: 0:00:00.027 user=SYSTEM database=postgres host=[local] 2024-11-14 22:05:01.847 GMT [5928][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:05:01.849 GMT [5928][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-14 22:05:01.849 GMT [5928][walsender] [[unknown]][23/6:0] LOG: replication connection authorized: user=SYSTEM application_name=pg_16397_sync_16384_7437257455562885528 2024-11-14 22:05:01.853 GMT [5928][walsender] [pg_16397_sync_16384_7437257455562885528][23/7:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-14 22:05:01.854 GMT [5928][walsender] [pg_16397_sync_16384_7437257455562885528][23/0:0] LOG: received replication command: DROP_REPLICATION_SLOT pg_16397_sync_16384_7437257455562885528 WAIT 2024-11-14 22:05:01.854 GMT [5928][walsender] [pg_16397_sync_16384_7437257455562885528][23/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16397_sync_16384_7437257455562885528 WAIT 2024-11-14 22:05:01.854 GMT [5928][walsender] [pg_16397_sync_16384_7437257455562885528][23/0:0] LOG: acquired logical replication slot "pg_16397_sync_16384_7437257455562885528" 2024-11-14 22:05:01.854 GMT [5928][walsender] [pg_16397_sync_16384_7437257455562885528][23/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16397_sync_16384_7437257455562885528 WAIT 2024-11-14 22:05:01.856 GMT [5928][walsender] [pg_16397_sync_16384_7437257455562885528][23/8:0] LOG: statement: BEGIN READ ONLY ISOLATION LEVEL REPEATABLE READ 2024-11-14 22:05:01.856 GMT [5928][walsender] [pg_16397_sync_16384_7437257455562885528][23/8:0] LOG: received replication command: CREATE_REPLICATION_SLOT "pg_16397_sync_16384_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:05:01.856 GMT [5928][walsender] [pg_16397_sync_16384_7437257455562885528][23/8:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16397_sync_16384_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:05:01.859 GMT [5928][walsender] [pg_16397_sync_16384_7437257455562885528][23/8:0] LOG: logical decoding found consistent point at 0/178BE58 2024-11-14 22:05:01.859 GMT [5928][walsender] [pg_16397_sync_16384_7437257455562885528][23/8:0] DETAIL: There are no running transactions. 2024-11-14 22:05:01.859 GMT [5928][walsender] [pg_16397_sync_16384_7437257455562885528][23/8:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16397_sync_16384_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:05:01.860 GMT [5928][walsender] [pg_16397_sync_16384_7437257455562885528][23/8:0] LOG: released logical replication slot "pg_16397_sync_16384_7437257455562885528" 2024-11-14 22:05:01.860 GMT [5928][walsender] [pg_16397_sync_16384_7437257455562885528][23/8:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16397_sync_16384_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:05:01.860 GMT [5928][walsender] [pg_16397_sync_16384_7437257455562885528][23/8: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-14 22:05:01.872 GMT [5928][walsender] [pg_16397_sync_16384_7437257455562885528][23/8: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-14 22:05:01.879 GMT [5928][walsender] [pg_16397_sync_16384_7437257455562885528][23/8: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-14 22:05:01.881 GMT [5928][walsender] [pg_16397_sync_16384_7437257455562885528][23/8: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-14 22:05:01.883 GMT [5928][walsender] [pg_16397_sync_16384_7437257455562885528][23/8:0] LOG: statement: COPY public.tab_rep (a) TO STDOUT 2024-11-14 22:05:01.884 GMT [5928][walsender] [pg_16397_sync_16384_7437257455562885528][:0] LOG: disconnection: session time: 0:00:00.041 user=SYSTEM database=postgres host=[local] 2024-11-14 22:05:01.953 GMT [7868][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:05:01.954 GMT [7868][walsender] [[unknown]][25/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-14 22:05:01.954 GMT [7868][walsender] [[unknown]][25/7:0] LOG: replication connection authorized: user=SYSTEM application_name=pg_16397_sync_16384_7437257455562885528 2024-11-14 22:05:01.958 GMT [7868][walsender] [pg_16397_sync_16384_7437257455562885528][25/8:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-14 22:05:01.959 GMT [7868][walsender] [pg_16397_sync_16384_7437257455562885528][25/0:0] LOG: received replication command: DROP_REPLICATION_SLOT pg_16397_sync_16384_7437257455562885528 WAIT 2024-11-14 22:05:01.959 GMT [7868][walsender] [pg_16397_sync_16384_7437257455562885528][25/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16397_sync_16384_7437257455562885528 WAIT 2024-11-14 22:05:01.959 GMT [7868][walsender] [pg_16397_sync_16384_7437257455562885528][25/0:0] LOG: acquired logical replication slot "pg_16397_sync_16384_7437257455562885528" 2024-11-14 22:05:01.959 GMT [7868][walsender] [pg_16397_sync_16384_7437257455562885528][25/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16397_sync_16384_7437257455562885528 WAIT 2024-11-14 22:05:01.961 GMT [7868][walsender] [pg_16397_sync_16384_7437257455562885528][25/9:0] LOG: statement: BEGIN READ ONLY ISOLATION LEVEL REPEATABLE READ 2024-11-14 22:05:01.961 GMT [7868][walsender] [pg_16397_sync_16384_7437257455562885528][25/9:0] LOG: received replication command: CREATE_REPLICATION_SLOT "pg_16397_sync_16384_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:05:01.961 GMT [7868][walsender] [pg_16397_sync_16384_7437257455562885528][25/9:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16397_sync_16384_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:05:01.965 GMT [7868][walsender] [pg_16397_sync_16384_7437257455562885528][25/9:0] LOG: logical decoding found consistent point at 0/178BE90 2024-11-14 22:05:01.965 GMT [7868][walsender] [pg_16397_sync_16384_7437257455562885528][25/9:0] DETAIL: There are no running transactions. 2024-11-14 22:05:01.965 GMT [7868][walsender] [pg_16397_sync_16384_7437257455562885528][25/9:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16397_sync_16384_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:05:01.966 GMT [7868][walsender] [pg_16397_sync_16384_7437257455562885528][25/9:0] LOG: released logical replication slot "pg_16397_sync_16384_7437257455562885528" 2024-11-14 22:05:01.966 GMT [7868][walsender] [pg_16397_sync_16384_7437257455562885528][25/9:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16397_sync_16384_7437257455562885528" LOGICAL pgoutput (SNAPSHOT 'use') 2024-11-14 22:05:01.967 GMT [7868][walsender] [pg_16397_sync_16384_7437257455562885528][25/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-14 22:05:01.971 GMT [7868][walsender] [pg_16397_sync_16384_7437257455562885528][25/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-14 22:05:01.976 GMT [7868][walsender] [pg_16397_sync_16384_7437257455562885528][25/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-14 22:05:01.979 GMT [7868][walsender] [pg_16397_sync_16384_7437257455562885528][25/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-14 22:05:01.980 GMT [7868][walsender] [pg_16397_sync_16384_7437257455562885528][25/9:0] LOG: statement: COPY public.tab_rep (a) TO STDOUT 2024-11-14 22:05:01.982 GMT [7868][walsender] [pg_16397_sync_16384_7437257455562885528][:0] LOG: disconnection: session time: 0:00:00.032 user=SYSTEM database=postgres host=[local] 2024-11-14 22:05:02.074 GMT [2936][walsender] [tap_sub][24/0:0] LOG: released logical replication slot "tap_sub" 2024-11-14 22:05:02.074 GMT [2936][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:00.455 user=SYSTEM database=postgres host=[local] 2024-11-14 22:05:02.084 GMT [1272][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:05:02.088 GMT [1272][walsender] [[unknown]][28/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-14 22:05:02.088 GMT [1272][walsender] [[unknown]][28/7:0] LOG: replication connection authorized: user=SYSTEM application_name=pg_16397_sync_16384_7437257455562885528 2024-11-14 22:05:02.094 GMT [1272][walsender] [pg_16397_sync_16384_7437257455562885528][28/0:0] LOG: could not receive data from client: An existing connection was forcibly closed by the remote host. 2024-11-14 22:05:02.094 GMT [1272][walsender] [pg_16397_sync_16384_7437257455562885528][:0] LOG: disconnection: session time: 0:00:00.017 user=SYSTEM database=postgres host=[local] 2024-11-14 22:05:02.120 GMT [7812][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:05:02.122 GMT [7812][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-14 22:05:02.122 GMT [7812][walsender] [[unknown]][29/7:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-11-14 22:05:02.125 GMT [7812][walsender] [tap_sub][29/8:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-11-14 22:05:02.126 GMT [7812][walsender] [tap_sub][29/0:0] LOG: received replication command: DROP_REPLICATION_SLOT pg_16397_sync_16384_7437257455562885528 WAIT 2024-11-14 22:05:02.126 GMT [7812][walsender] [tap_sub][29/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16397_sync_16384_7437257455562885528 WAIT 2024-11-14 22:05:02.126 GMT [7812][walsender] [tap_sub][29/0:0] LOG: acquired logical replication slot "pg_16397_sync_16384_7437257455562885528" 2024-11-14 22:05:02.126 GMT [7812][walsender] [tap_sub][29/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16397_sync_16384_7437257455562885528 WAIT 2024-11-14 22:05:02.127 GMT [7812][walsender] [tap_sub][29/0:0] LOG: received replication command: DROP_REPLICATION_SLOT tap_sub WAIT 2024-11-14 22:05:02.127 GMT [7812][walsender] [tap_sub][29/0:0] STATEMENT: DROP_REPLICATION_SLOT tap_sub WAIT 2024-11-14 22:05:02.127 GMT [7812][walsender] [tap_sub][29/0:0] LOG: acquired logical replication slot "tap_sub" 2024-11-14 22:05:02.127 GMT [7812][walsender] [tap_sub][29/0:0] STATEMENT: DROP_REPLICATION_SLOT tap_sub WAIT 2024-11-14 22:05:02.130 GMT [7812][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:00.012 user=SYSTEM database=postgres host=[local] 2024-11-14 22:05:02.322 GMT [6908][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-11-14 22:05:02.323 GMT [6908][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-14 22:05:02.323 GMT [6908][client backend] [[unknown]][6/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=004_sync.pl 2024-11-14 22:05:02.332 GMT [6908][client backend] [004_sync.pl][6/4:0] LOG: statement: SELECT count(*) = 0 FROM pg_replication_slots 2024-11-14 22:05:02.345 GMT [6908][client backend] [004_sync.pl][:0] LOG: disconnection: session time: 0:00:00.026 user=SYSTEM database=postgres host=[local] 2024-11-14 22:05:03.687 GMT [5668][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: 5668 abort() has been called