2025-01-15 10:14:46.863 GMT [7296][postmaster] LOG: starting PostgreSQL 18devel on x86_64-windows, compiled by msvc-19.29.30157, 64-bit 2025-01-15 10:14:46.867 GMT [7296][postmaster] LOG: listening on Unix socket "C:/Windows/TEMP/B8khqeYbIW/.s.PGSQL.13765" 2025-01-15 10:14:46.893 GMT [4028][startup] LOG: database system was shut down at 2025-01-15 10:06:17 GMT 2025-01-15 10:14:46.911 GMT [7296][postmaster] LOG: database system is ready to accept connections 2025-01-15 10:14:48.924 GMT [6436][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-15 10:14:48.926 GMT [6436][client backend] [[unknown]][0/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/020_messages/data/t_020_messages_publisher_data/pgdata/pg_hba.conf:117) 2025-01-15 10:14:48.926 GMT [6436][client backend] [[unknown]][0/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=020_messages.pl 2025-01-15 10:14:48.941 GMT [6436][client backend] [020_messages.pl][0/2:0] LOG: statement: CREATE TABLE tab_test (a int primary key) 2025-01-15 10:14:48.952 GMT [6436][client backend] [020_messages.pl][:0] LOG: disconnection: session time: 0:00:00.030 user=SYSTEM database=postgres host=[local] 2025-01-15 10:14:49.156 GMT [7604][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-15 10:14:49.157 GMT [7604][client backend] [[unknown]][1/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/020_messages/data/t_020_messages_publisher_data/pgdata/pg_hba.conf:117) 2025-01-15 10:14:49.157 GMT [7604][client backend] [[unknown]][1/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=020_messages.pl 2025-01-15 10:14:49.162 GMT [7604][client backend] [020_messages.pl][1/2:0] LOG: statement: CREATE PUBLICATION tap_pub FOR TABLE tab_test 2025-01-15 10:14:49.165 GMT [7604][client backend] [020_messages.pl][:0] LOG: disconnection: session time: 0:00:00.014 user=SYSTEM database=postgres host=[local] 2025-01-15 10:14:49.269 GMT [3728][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-15 10:14:49.270 GMT [3728][walsender] [[unknown]][23/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/020_messages/data/t_020_messages_publisher_data/pgdata/pg_hba.conf:117) 2025-01-15 10:14:49.270 GMT [3728][walsender] [[unknown]][23/1:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2025-01-15 10:14:49.273 GMT [3728][walsender] [tap_sub][23/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2025-01-15 10:14:49.274 GMT [3728][walsender] [tap_sub][23/3:0] LOG: statement: SELECT t.pubname FROM pg_catalog.pg_publication t WHERE t.pubname IN ('tap_pub') 2025-01-15 10:14:49.287 GMT [3728][walsender] [tap_sub][23/4:0] LOG: statement: SELECT DISTINCT n.nspname, c.relname, gpt.attrs FROM pg_class c JOIN pg_namespace n ON n.oid = c.relnamespace JOIN ( SELECT (pg_get_publication_tables(VARIADIC array_agg(pubname::text))).* FROM pg_publication WHERE pubname IN ( 'tap_pub' )) AS gpt ON gpt.relid = c.oid 2025-01-15 10:14:49.296 GMT [3728][walsender] [tap_sub][23/0:0] LOG: received replication command: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2025-01-15 10:14:49.296 GMT [3728][walsender] [tap_sub][23/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2025-01-15 10:14:49.312 GMT [3728][walsender] [tap_sub][23/0:0] LOG: logical decoding found consistent point at 0/1787A50 2025-01-15 10:14:49.312 GMT [3728][walsender] [tap_sub][23/0:0] DETAIL: There are no running transactions. 2025-01-15 10:14:49.312 GMT [3728][walsender] [tap_sub][23/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2025-01-15 10:14:49.322 GMT [3728][walsender] [tap_sub][23/0:0] LOG: released logical replication slot "tap_sub" 2025-01-15 10:14:49.322 GMT [3728][walsender] [tap_sub][23/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2025-01-15 10:14:49.323 GMT [3728][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:00.057 user=SYSTEM database=postgres host=[local] 2025-01-15 10:14:49.408 GMT [5660][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-15 10:14:49.409 GMT [5660][walsender] [[unknown]][24/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/020_messages/data/t_020_messages_publisher_data/pgdata/pg_hba.conf:117) 2025-01-15 10:14:49.409 GMT [5660][walsender] [[unknown]][24/1:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2025-01-15 10:14:49.415 GMT [5660][walsender] [tap_sub][24/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2025-01-15 10:14:49.416 GMT [5660][walsender] [tap_sub][24/0:0] LOG: received replication command: IDENTIFY_SYSTEM 2025-01-15 10:14:49.416 GMT [5660][walsender] [tap_sub][24/0:0] STATEMENT: IDENTIFY_SYSTEM 2025-01-15 10:14:49.416 GMT [5660][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"') 2025-01-15 10:14:49.416 GMT [5660][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"') 2025-01-15 10:14:49.416 GMT [5660][walsender] [tap_sub][24/0:0] LOG: acquired logical replication slot "tap_sub" 2025-01-15 10:14:49.416 GMT [5660][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"') 2025-01-15 10:14:49.417 GMT [5660][walsender] [tap_sub][24/0:0] LOG: starting logical decoding for slot "tap_sub" 2025-01-15 10:14:49.417 GMT [5660][walsender] [tap_sub][24/0:0] DETAIL: Streaming transactions committing after 0/1787A88, reading WAL from 0/1787A50. 2025-01-15 10:14:49.417 GMT [5660][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"') 2025-01-15 10:14:49.417 GMT [5660][walsender] [tap_sub][24/0:0] LOG: logical decoding found consistent point at 0/1787A50 2025-01-15 10:14:49.417 GMT [5660][walsender] [tap_sub][24/0:0] DETAIL: There are no running transactions. 2025-01-15 10:14:49.417 GMT [5660][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"') 2025-01-15 10:14:49.445 GMT [1380][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-15 10:14:49.446 GMT [1380][client backend] [[unknown]][2/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/020_messages/data/t_020_messages_publisher_data/pgdata/pg_hba.conf:117) 2025-01-15 10:14:49.446 GMT [1380][client backend] [[unknown]][2/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=020_messages.pl 2025-01-15 10:14:49.470 GMT [1380][client backend] [020_messages.pl][2/2:0] LOG: statement: SELECT pg_is_in_recovery() 2025-01-15 10:14:49.475 GMT [1380][client backend] [020_messages.pl][:0] LOG: disconnection: session time: 0:00:00.033 user=SYSTEM database=postgres host=[local] 2025-01-15 10:14:49.489 GMT [2864][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-15 10:14:49.490 GMT [2864][walsender] [[unknown]][25/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/020_messages/data/t_020_messages_publisher_data/pgdata/pg_hba.conf:117) 2025-01-15 10:14:49.490 GMT [2864][walsender] [[unknown]][25/1:0] LOG: replication connection authorized: user=SYSTEM application_name=pg_16390_sync_16384_7460081493434569100 2025-01-15 10:14:49.493 GMT [2864][walsender] [pg_16390_sync_16384_7460081493434569100][25/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2025-01-15 10:14:49.494 GMT [2864][walsender] [pg_16390_sync_16384_7460081493434569100][25/3:0] LOG: statement: BEGIN READ ONLY ISOLATION LEVEL REPEATABLE READ 2025-01-15 10:14:49.494 GMT [2864][walsender] [pg_16390_sync_16384_7460081493434569100][25/3:0] LOG: received replication command: CREATE_REPLICATION_SLOT "pg_16390_sync_16384_7460081493434569100" LOGICAL pgoutput (SNAPSHOT 'use') 2025-01-15 10:14:49.494 GMT [2864][walsender] [pg_16390_sync_16384_7460081493434569100][25/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16390_sync_16384_7460081493434569100" LOGICAL pgoutput (SNAPSHOT 'use') 2025-01-15 10:14:49.497 GMT [2864][walsender] [pg_16390_sync_16384_7460081493434569100][25/3:0] LOG: logical decoding found consistent point at 0/1787A88 2025-01-15 10:14:49.497 GMT [2864][walsender] [pg_16390_sync_16384_7460081493434569100][25/3:0] DETAIL: There are no running transactions. 2025-01-15 10:14:49.497 GMT [2864][walsender] [pg_16390_sync_16384_7460081493434569100][25/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16390_sync_16384_7460081493434569100" LOGICAL pgoutput (SNAPSHOT 'use') 2025-01-15 10:14:49.498 GMT [2864][walsender] [pg_16390_sync_16384_7460081493434569100][25/3:0] LOG: released logical replication slot "pg_16390_sync_16384_7460081493434569100" 2025-01-15 10:14:49.498 GMT [2864][walsender] [pg_16390_sync_16384_7460081493434569100][25/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16390_sync_16384_7460081493434569100" LOGICAL pgoutput (SNAPSHOT 'use') 2025-01-15 10:14:49.499 GMT [2864][walsender] [pg_16390_sync_16384_7460081493434569100][25/3:0] LOG: statement: SELECT c.oid, c.relreplident, c.relkind FROM pg_catalog.pg_class c INNER JOIN pg_catalog.pg_namespace n ON (c.relnamespace = n.oid) WHERE n.nspname = 'public' AND c.relname = 'tab_test' 2025-01-15 10:14:49.507 GMT [2864][walsender] [pg_16390_sync_16384_7460081493434569100][25/3:0] LOG: statement: SELECT DISTINCT (CASE WHEN (array_length(gpt.attrs, 1) = c.relnatts) THEN NULL ELSE gpt.attrs END) FROM pg_publication p, LATERAL pg_get_publication_tables(p.pubname) gpt, pg_class c WHERE gpt.relid = 16384 AND c.oid = gpt.relid AND p.pubname IN ( 'tap_pub' ) 2025-01-15 10:14:49.512 GMT [2864][walsender] [pg_16390_sync_16384_7460081493434569100][25/3:0] LOG: statement: SELECT a.attnum, a.attname, a.atttypid, a.attnum = ANY(i.indkey), a.attgenerated != '' FROM pg_catalog.pg_attribute a LEFT JOIN pg_catalog.pg_index i ON (i.indexrelid = pg_get_replica_identity_index(16384)) WHERE a.attnum > 0::pg_catalog.int2 AND NOT a.attisdropped AND a.attrelid = 16384 ORDER BY a.attnum 2025-01-15 10:14:49.515 GMT [2864][walsender] [pg_16390_sync_16384_7460081493434569100][25/3:0] LOG: statement: SELECT DISTINCT pg_get_expr(gpt.qual, gpt.relid) FROM pg_publication p, LATERAL pg_get_publication_tables(p.pubname) gpt WHERE gpt.relid = 16384 AND p.pubname IN ( 'tap_pub' ) 2025-01-15 10:14:49.517 GMT [2864][walsender] [pg_16390_sync_16384_7460081493434569100][25/3:0] LOG: statement: COPY public.tab_test (a) TO STDOUT 2025-01-15 10:14:49.517 GMT [2864][walsender] [pg_16390_sync_16384_7460081493434569100][25/3:0] LOG: statement: COMMIT 2025-01-15 10:14:49.518 GMT [2864][walsender] [pg_16390_sync_16384_7460081493434569100][25/0:0] LOG: received replication command: START_REPLICATION SLOT "pg_16390_sync_16384_7460081493434569100" LOGICAL 0/1787AC0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2025-01-15 10:14:49.518 GMT [2864][walsender] [pg_16390_sync_16384_7460081493434569100][25/0:0] STATEMENT: START_REPLICATION SLOT "pg_16390_sync_16384_7460081493434569100" LOGICAL 0/1787AC0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2025-01-15 10:14:49.518 GMT [2864][walsender] [pg_16390_sync_16384_7460081493434569100][25/0:0] LOG: acquired logical replication slot "pg_16390_sync_16384_7460081493434569100" 2025-01-15 10:14:49.518 GMT [2864][walsender] [pg_16390_sync_16384_7460081493434569100][25/0:0] STATEMENT: START_REPLICATION SLOT "pg_16390_sync_16384_7460081493434569100" LOGICAL 0/1787AC0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2025-01-15 10:14:49.518 GMT [2864][walsender] [pg_16390_sync_16384_7460081493434569100][25/0:0] LOG: starting logical decoding for slot "pg_16390_sync_16384_7460081493434569100" 2025-01-15 10:14:49.518 GMT [2864][walsender] [pg_16390_sync_16384_7460081493434569100][25/0:0] DETAIL: Streaming transactions committing after 0/1787AC0, reading WAL from 0/1787A88. 2025-01-15 10:14:49.518 GMT [2864][walsender] [pg_16390_sync_16384_7460081493434569100][25/0:0] STATEMENT: START_REPLICATION SLOT "pg_16390_sync_16384_7460081493434569100" LOGICAL 0/1787AC0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2025-01-15 10:14:49.518 GMT [2864][walsender] [pg_16390_sync_16384_7460081493434569100][25/0:0] LOG: logical decoding found consistent point at 0/1787A88 2025-01-15 10:14:49.518 GMT [2864][walsender] [pg_16390_sync_16384_7460081493434569100][25/0:0] DETAIL: There are no running transactions. 2025-01-15 10:14:49.518 GMT [2864][walsender] [pg_16390_sync_16384_7460081493434569100][25/0:0] STATEMENT: START_REPLICATION SLOT "pg_16390_sync_16384_7460081493434569100" LOGICAL 0/1787AC0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2025-01-15 10:14:49.519 GMT [2864][walsender] [pg_16390_sync_16384_7460081493434569100][25/0:0] LOG: released logical replication slot "pg_16390_sync_16384_7460081493434569100" 2025-01-15 10:14:49.519 GMT [2864][walsender] [pg_16390_sync_16384_7460081493434569100][25/0:0] STATEMENT: START_REPLICATION SLOT "pg_16390_sync_16384_7460081493434569100" LOGICAL 0/1787AC0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2025-01-15 10:14:49.519 GMT [2864][walsender] [pg_16390_sync_16384_7460081493434569100][25/0:0] LOG: received replication command: DROP_REPLICATION_SLOT pg_16390_sync_16384_7460081493434569100 WAIT 2025-01-15 10:14:49.519 GMT [2864][walsender] [pg_16390_sync_16384_7460081493434569100][25/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16390_sync_16384_7460081493434569100 WAIT 2025-01-15 10:14:49.519 GMT [2864][walsender] [pg_16390_sync_16384_7460081493434569100][25/0:0] LOG: acquired logical replication slot "pg_16390_sync_16384_7460081493434569100" 2025-01-15 10:14:49.519 GMT [2864][walsender] [pg_16390_sync_16384_7460081493434569100][25/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16390_sync_16384_7460081493434569100 WAIT 2025-01-15 10:14:49.522 GMT [2864][walsender] [pg_16390_sync_16384_7460081493434569100][:0] LOG: disconnection: session time: 0:00:00.036 user=SYSTEM database=postgres host=[local] 2025-01-15 10:14:49.600 GMT [7280][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-15 10:14:49.602 GMT [7280][client backend] [[unknown]][3/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/020_messages/data/t_020_messages_publisher_data/pgdata/pg_hba.conf:117) 2025-01-15 10:14:49.602 GMT [7280][client backend] [[unknown]][3/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=020_messages.pl 2025-01-15 10:14:49.605 GMT [7280][client backend] [020_messages.pl][3/2:0] LOG: statement: SELECT pg_current_wal_lsn() 2025-01-15 10:14:49.609 GMT [7280][client backend] [020_messages.pl][:0] LOG: disconnection: session time: 0:00:00.012 user=SYSTEM database=postgres host=[local] 2025-01-15 10:14:49.754 GMT [7908][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-15 10:14:49.757 GMT [7908][client backend] [[unknown]][4/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/020_messages/data/t_020_messages_publisher_data/pgdata/pg_hba.conf:117) 2025-01-15 10:14:49.757 GMT [7908][client backend] [[unknown]][4/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=020_messages.pl 2025-01-15 10:14:49.760 GMT [7908][client backend] [020_messages.pl][4/2:0] LOG: statement: SELECT '0/1787AC0' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2025-01-15 10:14:49.773 GMT [7908][client backend] [020_messages.pl][:0] LOG: disconnection: session time: 0:00:00.034 user=SYSTEM database=postgres host=[local] 2025-01-15 10:14:49.870 GMT [5660][walsender] [tap_sub][24/0:0] LOG: released logical replication slot "tap_sub" 2025-01-15 10:14:49.870 GMT [5660][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:00.467 user=SYSTEM database=postgres host=[local] 2025-01-15 10:14:50.068 GMT [3656][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-15 10:14:50.069 GMT [3656][client backend] [[unknown]][5/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/020_messages/data/t_020_messages_publisher_data/pgdata/pg_hba.conf:117) 2025-01-15 10:14:50.069 GMT [3656][client backend] [[unknown]][5/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=020_messages.pl 2025-01-15 10:14:50.072 GMT [3656][client backend] [020_messages.pl][5/2:0] LOG: statement: SELECT COUNT(*) FROM pg_catalog.pg_replication_slots WHERE slot_name = 'tap_sub' AND active='f' 2025-01-15 10:14:50.080 GMT [3656][client backend] [020_messages.pl][:0] LOG: disconnection: session time: 0:00:00.015 user=SYSTEM database=postgres host=[local] 2025-01-15 10:14:50.139 GMT [2456][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-15 10:14:50.140 GMT [2456][client backend] [[unknown]][6/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/020_messages/data/t_020_messages_publisher_data/pgdata/pg_hba.conf:117) 2025-01-15 10:14:50.140 GMT [2456][client backend] [[unknown]][6/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=020_messages.pl 2025-01-15 10:14:50.143 GMT [2456][client backend] [020_messages.pl][6/2:0] LOG: statement: SELECT pg_logical_emit_message(true, 'pgoutput', 'a transactional message') 2025-01-15 10:14:50.148 GMT [2456][client backend] [020_messages.pl][:0] LOG: disconnection: session time: 0:00:00.012 user=SYSTEM database=postgres host=[local] 2025-01-15 10:14:50.224 GMT [6864][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-15 10:14:50.225 GMT [6864][client backend] [[unknown]][7/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/020_messages/data/t_020_messages_publisher_data/pgdata/pg_hba.conf:117) 2025-01-15 10:14:50.226 GMT [6864][client backend] [[unknown]][7/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=020_messages.pl 2025-01-15 10:14:50.228 GMT [6864][client backend] [020_messages.pl][7/2:0] LOG: statement: SELECT get_byte(data, 0) FROM pg_logical_slot_peek_binary_changes('tap_sub', NULL, NULL, 'proto_version', '1', 'publication_names', 'tap_pub', 'messages', 'true') 2025-01-15 10:14:50.229 GMT [6864][client backend] [020_messages.pl][7/2:0] LOG: starting logical decoding for slot "tap_sub" 2025-01-15 10:14:50.229 GMT [6864][client backend] [020_messages.pl][7/2:0] DETAIL: Streaming transactions committing after 0/1787AC0, reading WAL from 0/1787A88. 2025-01-15 10:14:50.229 GMT [6864][client backend] [020_messages.pl][7/2:0] STATEMENT: SELECT get_byte(data, 0) FROM pg_logical_slot_peek_binary_changes('tap_sub', NULL, NULL, 'proto_version', '1', 'publication_names', 'tap_pub', 'messages', 'true') 2025-01-15 10:14:50.230 GMT [6864][client backend] [020_messages.pl][7/2:0] LOG: logical decoding found consistent point at 0/1787A88 2025-01-15 10:14:50.230 GMT [6864][client backend] [020_messages.pl][7/2:0] DETAIL: There are no running transactions. 2025-01-15 10:14:50.230 GMT [6864][client backend] [020_messages.pl][7/2:0] STATEMENT: SELECT get_byte(data, 0) FROM pg_logical_slot_peek_binary_changes('tap_sub', NULL, NULL, 'proto_version', '1', 'publication_names', 'tap_pub', 'messages', 'true') 2025-01-15 10:14:50.233 GMT [6864][client backend] [020_messages.pl][:0] LOG: disconnection: session time: 0:00:00.011 user=SYSTEM database=postgres host=[local] 2025-01-15 10:14:50.336 GMT [6400][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-15 10:14:50.338 GMT [6400][client backend] [[unknown]][8/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/020_messages/data/t_020_messages_publisher_data/pgdata/pg_hba.conf:117) 2025-01-15 10:14:50.338 GMT [6400][client backend] [[unknown]][8/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=020_messages.pl 2025-01-15 10:14:50.341 GMT [6400][client backend] [020_messages.pl][8/2:0] LOG: statement: SELECT get_byte(data, 1), encode(substr(data, 11, 8), 'escape') FROM pg_logical_slot_peek_binary_changes('tap_sub', NULL, NULL, 'proto_version', '1', 'publication_names', 'tap_pub', 'messages', 'true') OFFSET 1 LIMIT 1 2025-01-15 10:14:50.343 GMT [6400][client backend] [020_messages.pl][8/2:0] LOG: starting logical decoding for slot "tap_sub" 2025-01-15 10:14:50.343 GMT [6400][client backend] [020_messages.pl][8/2:0] DETAIL: Streaming transactions committing after 0/1787AC0, reading WAL from 0/1787A88. 2025-01-15 10:14:50.343 GMT [6400][client backend] [020_messages.pl][8/2:0] STATEMENT: SELECT get_byte(data, 1), encode(substr(data, 11, 8), 'escape') FROM pg_logical_slot_peek_binary_changes('tap_sub', NULL, NULL, 'proto_version', '1', 'publication_names', 'tap_pub', 'messages', 'true') OFFSET 1 LIMIT 1 2025-01-15 10:14:50.343 GMT [6400][client backend] [020_messages.pl][8/2:0] LOG: logical decoding found consistent point at 0/1787A88 2025-01-15 10:14:50.343 GMT [6400][client backend] [020_messages.pl][8/2:0] DETAIL: There are no running transactions. 2025-01-15 10:14:50.343 GMT [6400][client backend] [020_messages.pl][8/2:0] STATEMENT: SELECT get_byte(data, 1), encode(substr(data, 11, 8), 'escape') FROM pg_logical_slot_peek_binary_changes('tap_sub', NULL, NULL, 'proto_version', '1', 'publication_names', 'tap_pub', 'messages', 'true') OFFSET 1 LIMIT 1 2025-01-15 10:14:50.346 GMT [6400][client backend] [020_messages.pl][:0] LOG: disconnection: session time: 0:00:00.018 user=SYSTEM database=postgres host=[local] 2025-01-15 10:14:50.489 GMT [4364][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-15 10:14:50.490 GMT [4364][client backend] [[unknown]][9/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/020_messages/data/t_020_messages_publisher_data/pgdata/pg_hba.conf:117) 2025-01-15 10:14:50.490 GMT [4364][client backend] [[unknown]][9/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=020_messages.pl 2025-01-15 10:14:50.493 GMT [4364][client backend] [020_messages.pl][9/2:0] LOG: statement: SELECT get_byte(data, 0) FROM pg_logical_slot_get_binary_changes('tap_sub', NULL, NULL, 'proto_version', '1', 'publication_names', 'tap_pub') 2025-01-15 10:14:50.494 GMT [4364][client backend] [020_messages.pl][9/2:0] LOG: starting logical decoding for slot "tap_sub" 2025-01-15 10:14:50.494 GMT [4364][client backend] [020_messages.pl][9/2:0] DETAIL: Streaming transactions committing after 0/1787AC0, reading WAL from 0/1787A88. 2025-01-15 10:14:50.494 GMT [4364][client backend] [020_messages.pl][9/2:0] STATEMENT: SELECT get_byte(data, 0) FROM pg_logical_slot_get_binary_changes('tap_sub', NULL, NULL, 'proto_version', '1', 'publication_names', 'tap_pub') 2025-01-15 10:14:50.494 GMT [4364][client backend] [020_messages.pl][9/2:0] LOG: logical decoding found consistent point at 0/1787A88 2025-01-15 10:14:50.494 GMT [4364][client backend] [020_messages.pl][9/2:0] DETAIL: There are no running transactions. 2025-01-15 10:14:50.494 GMT [4364][client backend] [020_messages.pl][9/2:0] STATEMENT: SELECT get_byte(data, 0) FROM pg_logical_slot_get_binary_changes('tap_sub', NULL, NULL, 'proto_version', '1', 'publication_names', 'tap_pub') 2025-01-15 10:14:50.495 GMT [4364][client backend] [020_messages.pl][:0] LOG: disconnection: session time: 0:00:00.009 user=SYSTEM database=postgres host=[local] 2025-01-15 10:14:50.664 GMT [4720][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-15 10:14:50.666 GMT [4720][client backend] [[unknown]][0/3:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/020_messages/data/t_020_messages_publisher_data/pgdata/pg_hba.conf:117) 2025-01-15 10:14:50.666 GMT [4720][client backend] [[unknown]][0/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=020_messages.pl 2025-01-15 10:14:50.677 GMT [4720][client backend] [020_messages.pl][0/4:0] LOG: statement: INSERT INTO tab_test VALUES (1) 2025-01-15 10:14:50.678 GMT [4720][client backend] [020_messages.pl][:0] LOG: disconnection: session time: 0:00:00.047 user=SYSTEM database=postgres host=[local] 2025-01-15 10:14:50.753 GMT [1572][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-15 10:14:50.755 GMT [1572][client backend] [[unknown]][1/3:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/020_messages/data/t_020_messages_publisher_data/pgdata/pg_hba.conf:117) 2025-01-15 10:14:50.755 GMT [1572][client backend] [[unknown]][1/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=020_messages.pl 2025-01-15 10:14:50.760 GMT [1572][client backend] [020_messages.pl][1/4:0] LOG: statement: SELECT pg_logical_emit_message(false, 'pgoutput', 'a non-transactional message') 2025-01-15 10:14:50.763 GMT [1572][client backend] [020_messages.pl][:0] LOG: disconnection: session time: 0:00:00.013 user=SYSTEM database=postgres host=[local] 2025-01-15 10:14:50.834 GMT [5244][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-15 10:14:50.835 GMT [5244][client backend] [[unknown]][2/3:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/020_messages/data/t_020_messages_publisher_data/pgdata/pg_hba.conf:117) 2025-01-15 10:14:50.835 GMT [5244][client backend] [[unknown]][2/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=020_messages.pl 2025-01-15 10:14:50.837 GMT [5244][client backend] [020_messages.pl][2/4:0] LOG: statement: INSERT INTO tab_test VALUES (2) 2025-01-15 10:14:50.838 GMT [5244][client backend] [020_messages.pl][:0] LOG: disconnection: session time: 0:00:00.008 user=SYSTEM database=postgres host=[local] 2025-01-15 10:14:50.917 GMT [1272][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-15 10:14:50.918 GMT [1272][client backend] [[unknown]][3/3:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/020_messages/data/t_020_messages_publisher_data/pgdata/pg_hba.conf:117) 2025-01-15 10:14:50.918 GMT [1272][client backend] [[unknown]][3/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=020_messages.pl 2025-01-15 10:14:50.921 GMT [1272][client backend] [020_messages.pl][3/4:0] LOG: statement: SELECT get_byte(data, 0), get_byte(data, 1) FROM pg_logical_slot_get_binary_changes('tap_sub', NULL, NULL, 'proto_version', '1', 'publication_names', 'tap_pub', 'messages', 'true') WHERE lsn = '0/1787CB0' AND xid = 0 2025-01-15 10:14:50.923 GMT [1272][client backend] [020_messages.pl][3/4:0] LOG: starting logical decoding for slot "tap_sub" 2025-01-15 10:14:50.923 GMT [1272][client backend] [020_messages.pl][3/4:0] DETAIL: Streaming transactions committing after 0/1787B48, reading WAL from 0/1787A88. 2025-01-15 10:14:50.923 GMT [1272][client backend] [020_messages.pl][3/4:0] STATEMENT: SELECT get_byte(data, 0), get_byte(data, 1) FROM pg_logical_slot_get_binary_changes('tap_sub', NULL, NULL, 'proto_version', '1', 'publication_names', 'tap_pub', 'messages', 'true') WHERE lsn = '0/1787CB0' AND xid = 0 2025-01-15 10:14:50.923 GMT [1272][client backend] [020_messages.pl][3/4:0] LOG: logical decoding found consistent point at 0/1787A88 2025-01-15 10:14:50.923 GMT [1272][client backend] [020_messages.pl][3/4:0] DETAIL: There are no running transactions. 2025-01-15 10:14:50.923 GMT [1272][client backend] [020_messages.pl][3/4:0] STATEMENT: SELECT get_byte(data, 0), get_byte(data, 1) FROM pg_logical_slot_get_binary_changes('tap_sub', NULL, NULL, 'proto_version', '1', 'publication_names', 'tap_pub', 'messages', 'true') WHERE lsn = '0/1787CB0' AND xid = 0 2025-01-15 10:14:50.928 GMT [1272][client backend] [020_messages.pl][:0] LOG: disconnection: session time: 0:00:00.015 user=SYSTEM database=postgres host=[local] 2025-01-15 10:14:51.047 GMT [996][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-15 10:14:51.048 GMT [996][client backend] [[unknown]][4/3:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/020_messages/data/t_020_messages_publisher_data/pgdata/pg_hba.conf:117) 2025-01-15 10:14:51.048 GMT [996][client backend] [[unknown]][4/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=020_messages.pl 2025-01-15 10:14:51.050 GMT [996][client backend] [020_messages.pl][4/4:0] LOG: statement: BEGIN; 2025-01-15 10:14:51.051 GMT [996][client backend] [020_messages.pl][4/4:0] LOG: statement: SELECT pg_logical_emit_message(false, 'pgoutput', 'a non-transactional message is available even if the transaction is aborted 1'); 2025-01-15 10:14:51.053 GMT [996][client backend] [020_messages.pl][4/4:0] LOG: statement: INSERT INTO tab_test VALUES (3); 2025-01-15 10:14:51.054 GMT [996][client backend] [020_messages.pl][4/4:752] LOG: statement: SELECT pg_logical_emit_message(true, 'pgoutput', 'a transactional message is not available if the transaction is aborted'); 2025-01-15 10:14:51.054 GMT [996][client backend] [020_messages.pl][4/4:752] LOG: statement: SELECT pg_logical_emit_message(false, 'pgoutput', 'a non-transactional message is available even if the transaction is aborted 2'); 2025-01-15 10:14:51.056 GMT [996][client backend] [020_messages.pl][4/4:752] LOG: statement: ROLLBACK; 2025-01-15 10:14:51.056 GMT [996][client backend] [020_messages.pl][4/5:0] LOG: statement: SELECT pg_switch_wal(); 2025-01-15 10:14:51.062 GMT [996][client backend] [020_messages.pl][:0] LOG: disconnection: session time: 0:00:00.018 user=SYSTEM database=postgres host=[local] 2025-01-15 10:14:51.155 GMT [3536][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2025-01-15 10:14:51.156 GMT [3536][client backend] [[unknown]][5/3:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/020_messages/data/t_020_messages_publisher_data/pgdata/pg_hba.conf:117) 2025-01-15 10:14:51.156 GMT [3536][client backend] [[unknown]][5/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=020_messages.pl 2025-01-15 10:14:51.159 GMT [3536][client backend] [020_messages.pl][5/4:0] LOG: statement: SELECT get_byte(data, 0), get_byte(data, 1) FROM pg_logical_slot_peek_binary_changes('tap_sub', NULL, NULL, 'proto_version', '1', 'publication_names', 'tap_pub', 'messages', 'true') 2025-01-15 10:14:51.160 GMT [3536][client backend] [020_messages.pl][5/4:0] LOG: starting logical decoding for slot "tap_sub" 2025-01-15 10:14:51.160 GMT [3536][client backend] [020_messages.pl][5/4:0] DETAIL: Streaming transactions committing after 0/1787D60, reading WAL from 0/1787A88. 2025-01-15 10:14:51.160 GMT [3536][client backend] [020_messages.pl][5/4:0] STATEMENT: SELECT get_byte(data, 0), get_byte(data, 1) FROM pg_logical_slot_peek_binary_changes('tap_sub', NULL, NULL, 'proto_version', '1', 'publication_names', 'tap_pub', 'messages', 'true') 2025-01-15 10:14:51.160 GMT [3536][client backend] [020_messages.pl][5/4:0] LOG: logical decoding found consistent point at 0/1787A88 2025-01-15 10:14:51.160 GMT [3536][client backend] [020_messages.pl][5/4:0] DETAIL: There are no running transactions. 2025-01-15 10:14:51.160 GMT [3536][client backend] [020_messages.pl][5/4:0] STATEMENT: SELECT get_byte(data, 0), get_byte(data, 1) FROM pg_logical_slot_peek_binary_changes('tap_sub', NULL, NULL, 'proto_version', '1', 'publication_names', 'tap_pub', 'messages', 'true') 2025-01-15 10:14:51.163 GMT [3536][client backend] [020_messages.pl][:0] LOG: disconnection: session time: 0:00:00.011 user=SYSTEM database=postgres host=[local] 2025-01-15 10:14:52.568 GMT [7296][postmaster] LOG: received immediate shutdown request TRAP: failed Assert("(remainMask.mask | targetMask.mask) == BTYPE_MASK_ALL.mask"), File: "../src/backend/postmaster/postmaster.c", Line: 2909, PID: 7296 abort() has been called