2024-12-24 06:12:20.534 GMT [1692][postmaster] LOG: starting PostgreSQL 18devel on x86_64-windows, compiled by msvc-19.29.30157, 64-bit 2024-12-24 06:12:20.535 GMT [1692][postmaster] LOG: listening on Unix socket "C:/Windows/TEMP/Hj5IVjh0iw/.s.PGSQL.27951" 2024-12-24 06:12:20.559 GMT [6236][startup] LOG: database system was shut down at 2024-12-24 06:04:52 GMT 2024-12-24 06:12:20.570 GMT [1692][postmaster] LOG: database system is ready to accept connections 2024-12-24 06:12:22.179 GMT [2352][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:22.181 GMT [2352][client backend] [[unknown]][0/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:22.181 GMT [2352][client backend] [[unknown]][0/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:22.204 GMT [2352][client backend] [015_stream.pl][0/2:0] LOG: statement: CREATE TABLE test_tab (a int primary key, b bytea) 2024-12-24 06:12:22.220 GMT [2352][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.046 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:22.283 GMT [4848][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:22.285 GMT [4848][client backend] [[unknown]][1/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:22.285 GMT [4848][client backend] [[unknown]][1/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:22.290 GMT [4848][client backend] [015_stream.pl][1/2:0] LOG: statement: INSERT INTO test_tab VALUES (1, 'foo'), (2, 'bar') 2024-12-24 06:12:22.291 GMT [4848][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.011 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:22.355 GMT [408][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:22.356 GMT [408][client backend] [[unknown]][2/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:22.356 GMT [408][client backend] [[unknown]][2/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:22.359 GMT [408][client backend] [015_stream.pl][2/2:0] LOG: statement: CREATE TABLE test_tab_2 (a int) 2024-12-24 06:12:22.364 GMT [408][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.012 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:22.810 GMT [5124][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:22.812 GMT [5124][client backend] [[unknown]][3/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:22.812 GMT [5124][client backend] [[unknown]][3/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:22.814 GMT [5124][client backend] [015_stream.pl][3/2:0] LOG: statement: CREATE PUBLICATION tap_pub FOR TABLE test_tab, test_tab_2 2024-12-24 06:12:22.817 GMT [5124][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.010 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:22.897 GMT [5848][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:22.899 GMT [5848][walsender] [[unknown]][22/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:22.899 GMT [5848][walsender] [[unknown]][22/1:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-12-24 06:12:22.907 GMT [5848][walsender] [tap_sub][22/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-12-24 06:12:22.909 GMT [5848][walsender] [tap_sub][22/3:0] LOG: statement: SELECT t.pubname FROM pg_catalog.pg_publication t WHERE t.pubname IN ('tap_pub') 2024-12-24 06:12:22.913 GMT [5848][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-12-24 06:12:22.923 GMT [5848][walsender] [tap_sub][22/0:0] LOG: received replication command: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-12-24 06:12:22.923 GMT [5848][walsender] [tap_sub][22/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-12-24 06:12:22.926 GMT [5848][walsender] [tap_sub][22/0:0] LOG: logical decoding found consistent point at 0/1792980 2024-12-24 06:12:22.926 GMT [5848][walsender] [tap_sub][22/0:0] DETAIL: There are no running transactions. 2024-12-24 06:12:22.926 GMT [5848][walsender] [tap_sub][22/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-12-24 06:12:22.927 GMT [5848][walsender] [tap_sub][22/0:0] LOG: released logical replication slot "tap_sub" 2024-12-24 06:12:22.927 GMT [5848][walsender] [tap_sub][22/0:0] STATEMENT: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing') 2024-12-24 06:12:22.927 GMT [5848][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:00.032 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:22.973 GMT [3232][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:22.974 GMT [3232][walsender] [[unknown]][23/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:22.974 GMT [3232][walsender] [[unknown]][23/1:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-12-24 06:12:22.978 GMT [3232][walsender] [tap_sub][23/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-12-24 06:12:22.979 GMT [3232][walsender] [tap_sub][23/0:0] LOG: received replication command: IDENTIFY_SYSTEM 2024-12-24 06:12:22.979 GMT [3232][walsender] [tap_sub][23/0:0] STATEMENT: IDENTIFY_SYSTEM 2024-12-24 06:12:22.979 GMT [3232][walsender] [tap_sub][23/0:0] LOG: received replication command: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"') 2024-12-24 06:12:22.979 GMT [3232][walsender] [tap_sub][23/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"') 2024-12-24 06:12:22.979 GMT [3232][walsender] [tap_sub][23/0:0] LOG: acquired logical replication slot "tap_sub" 2024-12-24 06:12:22.979 GMT [3232][walsender] [tap_sub][23/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"') 2024-12-24 06:12:22.980 GMT [3232][walsender] [tap_sub][23/0:0] LOG: starting logical decoding for slot "tap_sub" 2024-12-24 06:12:22.980 GMT [3232][walsender] [tap_sub][23/0:0] DETAIL: Streaming transactions committing after 0/17929B8, reading WAL from 0/1792980. 2024-12-24 06:12:22.980 GMT [3232][walsender] [tap_sub][23/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"') 2024-12-24 06:12:22.980 GMT [3232][walsender] [tap_sub][23/0:0] LOG: logical decoding found consistent point at 0/1792980 2024-12-24 06:12:22.980 GMT [3232][walsender] [tap_sub][23/0:0] DETAIL: There are no running transactions. 2024-12-24 06:12:22.980 GMT [3232][walsender] [tap_sub][23/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/0 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"') 2024-12-24 06:12:23.030 GMT [1736][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:23.032 GMT [1736][walsender] [[unknown]][24/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:23.032 GMT [1736][walsender] [[unknown]][24/1:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-12-24 06:12:23.035 GMT [1736][walsender] [tap_sub][24/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-12-24 06:12:23.035 GMT [1736][walsender] [tap_sub][24/3:0] LOG: statement: BEGIN READ ONLY ISOLATION LEVEL REPEATABLE READ 2024-12-24 06:12:23.036 GMT [1736][walsender] [tap_sub][24/3:0] LOG: received replication command: CREATE_REPLICATION_SLOT "pg_16398_sync_16394_7451855407062627244" LOGICAL pgoutput (SNAPSHOT 'use') 2024-12-24 06:12:23.036 GMT [1736][walsender] [tap_sub][24/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16398_sync_16394_7451855407062627244" LOGICAL pgoutput (SNAPSHOT 'use') 2024-12-24 06:12:23.039 GMT [1736][walsender] [tap_sub][24/3:0] LOG: logical decoding found consistent point at 0/17929B8 2024-12-24 06:12:23.039 GMT [1736][walsender] [tap_sub][24/3:0] DETAIL: There are no running transactions. 2024-12-24 06:12:23.039 GMT [1736][walsender] [tap_sub][24/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16398_sync_16394_7451855407062627244" LOGICAL pgoutput (SNAPSHOT 'use') 2024-12-24 06:12:23.039 GMT [1736][walsender] [tap_sub][24/3:0] LOG: released logical replication slot "pg_16398_sync_16394_7451855407062627244" 2024-12-24 06:12:23.039 GMT [1736][walsender] [tap_sub][24/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16398_sync_16394_7451855407062627244" LOGICAL pgoutput (SNAPSHOT 'use') 2024-12-24 06:12:23.040 GMT [1736][walsender] [tap_sub][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 = 'test_tab_2' 2024-12-24 06:12:23.045 GMT [1736][walsender] [tap_sub][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 = 16392 AND c.oid = gpt.relid AND p.pubname IN ( 'tap_pub' ) 2024-12-24 06:12:23.047 GMT [6484][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:23.049 GMT [6484][walsender] [[unknown]][25/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:23.049 GMT [6484][walsender] [[unknown]][25/1:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-12-24 06:12:23.049 GMT [1736][walsender] [tap_sub][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(16392)) WHERE a.attnum > 0::pg_catalog.int2 AND NOT a.attisdropped AND a.attrelid = 16392 ORDER BY a.attnum 2024-12-24 06:12:23.052 GMT [1736][walsender] [tap_sub][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 = 16392 AND p.pubname IN ( 'tap_pub' ) 2024-12-24 06:12:23.053 GMT [6484][walsender] [tap_sub][25/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-12-24 06:12:23.054 GMT [6484][walsender] [tap_sub][25/3:0] LOG: statement: BEGIN READ ONLY ISOLATION LEVEL REPEATABLE READ 2024-12-24 06:12:23.054 GMT [1736][walsender] [tap_sub][24/3:0] LOG: statement: COPY public.test_tab_2 (a) TO STDOUT 2024-12-24 06:12:23.054 GMT [6484][walsender] [tap_sub][25/3:0] LOG: received replication command: CREATE_REPLICATION_SLOT "pg_16398_sync_16384_7451855407062627244" LOGICAL pgoutput (SNAPSHOT 'use') 2024-12-24 06:12:23.054 GMT [6484][walsender] [tap_sub][25/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16398_sync_16384_7451855407062627244" LOGICAL pgoutput (SNAPSHOT 'use') 2024-12-24 06:12:23.054 GMT [1736][walsender] [tap_sub][24/3:0] LOG: statement: COMMIT 2024-12-24 06:12:23.055 GMT [1736][walsender] [tap_sub][24/0:0] LOG: received replication command: START_REPLICATION SLOT "pg_16398_sync_16394_7451855407062627244" LOGICAL 0/17929F0 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"') 2024-12-24 06:12:23.055 GMT [1736][walsender] [tap_sub][24/0:0] STATEMENT: START_REPLICATION SLOT "pg_16398_sync_16394_7451855407062627244" LOGICAL 0/17929F0 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"') 2024-12-24 06:12:23.055 GMT [1736][walsender] [tap_sub][24/0:0] LOG: acquired logical replication slot "pg_16398_sync_16394_7451855407062627244" 2024-12-24 06:12:23.055 GMT [1736][walsender] [tap_sub][24/0:0] STATEMENT: START_REPLICATION SLOT "pg_16398_sync_16394_7451855407062627244" LOGICAL 0/17929F0 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"') 2024-12-24 06:12:23.055 GMT [1736][walsender] [tap_sub][24/0:0] LOG: starting logical decoding for slot "pg_16398_sync_16394_7451855407062627244" 2024-12-24 06:12:23.055 GMT [1736][walsender] [tap_sub][24/0:0] DETAIL: Streaming transactions committing after 0/17929F0, reading WAL from 0/17929B8. 2024-12-24 06:12:23.055 GMT [1736][walsender] [tap_sub][24/0:0] STATEMENT: START_REPLICATION SLOT "pg_16398_sync_16394_7451855407062627244" LOGICAL 0/17929F0 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"') 2024-12-24 06:12:23.055 GMT [1736][walsender] [tap_sub][24/0:0] LOG: logical decoding found consistent point at 0/17929B8 2024-12-24 06:12:23.055 GMT [1736][walsender] [tap_sub][24/0:0] DETAIL: There are no running transactions. 2024-12-24 06:12:23.055 GMT [1736][walsender] [tap_sub][24/0:0] STATEMENT: START_REPLICATION SLOT "pg_16398_sync_16394_7451855407062627244" LOGICAL 0/17929F0 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"') 2024-12-24 06:12:23.055 GMT [1736][walsender] [tap_sub][24/0:0] LOG: released logical replication slot "pg_16398_sync_16394_7451855407062627244" 2024-12-24 06:12:23.055 GMT [1736][walsender] [tap_sub][24/0:0] STATEMENT: START_REPLICATION SLOT "pg_16398_sync_16394_7451855407062627244" LOGICAL 0/17929F0 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"') 2024-12-24 06:12:23.056 GMT [1736][walsender] [tap_sub][24/0:0] LOG: received replication command: DROP_REPLICATION_SLOT pg_16398_sync_16394_7451855407062627244 WAIT 2024-12-24 06:12:23.056 GMT [1736][walsender] [tap_sub][24/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16398_sync_16394_7451855407062627244 WAIT 2024-12-24 06:12:23.056 GMT [1736][walsender] [tap_sub][24/0:0] LOG: acquired logical replication slot "pg_16398_sync_16394_7451855407062627244" 2024-12-24 06:12:23.056 GMT [1736][walsender] [tap_sub][24/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16398_sync_16394_7451855407062627244 WAIT 2024-12-24 06:12:23.057 GMT [1736][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:00.029 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:23.058 GMT [6484][walsender] [tap_sub][25/3:0] LOG: logical decoding found consistent point at 0/17929F0 2024-12-24 06:12:23.058 GMT [6484][walsender] [tap_sub][25/3:0] DETAIL: There are no running transactions. 2024-12-24 06:12:23.058 GMT [6484][walsender] [tap_sub][25/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16398_sync_16384_7451855407062627244" LOGICAL pgoutput (SNAPSHOT 'use') 2024-12-24 06:12:23.058 GMT [6484][walsender] [tap_sub][25/3:0] LOG: released logical replication slot "pg_16398_sync_16384_7451855407062627244" 2024-12-24 06:12:23.058 GMT [6484][walsender] [tap_sub][25/3:0] STATEMENT: CREATE_REPLICATION_SLOT "pg_16398_sync_16384_7451855407062627244" LOGICAL pgoutput (SNAPSHOT 'use') 2024-12-24 06:12:23.059 GMT [6484][walsender] [tap_sub][25/3:0] LOG: statement: SELECT c.oid, c.relreplident, c.relkind FROM pg_catalog.pg_class c INNER JOIN pg_catalog.pg_namespace n ON (c.relnamespace = n.oid) WHERE n.nspname = 'public' AND c.relname = 'test_tab' 2024-12-24 06:12:23.063 GMT [6484][walsender] [tap_sub][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' ) 2024-12-24 06:12:23.069 GMT [6484][walsender] [tap_sub][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 2024-12-24 06:12:23.071 GMT [6484][walsender] [tap_sub][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' ) 2024-12-24 06:12:23.073 GMT [6484][walsender] [tap_sub][25/3:0] LOG: statement: COPY public.test_tab (a, b) TO STDOUT 2024-12-24 06:12:23.074 GMT [6484][walsender] [tap_sub][25/3:0] LOG: statement: COMMIT 2024-12-24 06:12:23.074 GMT [6484][walsender] [tap_sub][25/0:0] LOG: received replication command: START_REPLICATION SLOT "pg_16398_sync_16384_7451855407062627244" LOGICAL 0/1792A28 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"') 2024-12-24 06:12:23.074 GMT [6484][walsender] [tap_sub][25/0:0] STATEMENT: START_REPLICATION SLOT "pg_16398_sync_16384_7451855407062627244" LOGICAL 0/1792A28 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"') 2024-12-24 06:12:23.074 GMT [6484][walsender] [tap_sub][25/0:0] LOG: acquired logical replication slot "pg_16398_sync_16384_7451855407062627244" 2024-12-24 06:12:23.074 GMT [6484][walsender] [tap_sub][25/0:0] STATEMENT: START_REPLICATION SLOT "pg_16398_sync_16384_7451855407062627244" LOGICAL 0/1792A28 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"') 2024-12-24 06:12:23.075 GMT [6484][walsender] [tap_sub][25/0:0] LOG: starting logical decoding for slot "pg_16398_sync_16384_7451855407062627244" 2024-12-24 06:12:23.075 GMT [6484][walsender] [tap_sub][25/0:0] DETAIL: Streaming transactions committing after 0/1792A28, reading WAL from 0/17929F0. 2024-12-24 06:12:23.075 GMT [6484][walsender] [tap_sub][25/0:0] STATEMENT: START_REPLICATION SLOT "pg_16398_sync_16384_7451855407062627244" LOGICAL 0/1792A28 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"') 2024-12-24 06:12:23.075 GMT [6484][walsender] [tap_sub][25/0:0] LOG: logical decoding found consistent point at 0/17929F0 2024-12-24 06:12:23.075 GMT [6484][walsender] [tap_sub][25/0:0] DETAIL: There are no running transactions. 2024-12-24 06:12:23.075 GMT [6484][walsender] [tap_sub][25/0:0] STATEMENT: START_REPLICATION SLOT "pg_16398_sync_16384_7451855407062627244" LOGICAL 0/1792A28 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"') 2024-12-24 06:12:23.075 GMT [6484][walsender] [tap_sub][25/0:0] LOG: released logical replication slot "pg_16398_sync_16384_7451855407062627244" 2024-12-24 06:12:23.075 GMT [6484][walsender] [tap_sub][25/0:0] STATEMENT: START_REPLICATION SLOT "pg_16398_sync_16384_7451855407062627244" LOGICAL 0/1792A28 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"') 2024-12-24 06:12:23.075 GMT [6484][walsender] [tap_sub][25/0:0] LOG: received replication command: DROP_REPLICATION_SLOT pg_16398_sync_16384_7451855407062627244 WAIT 2024-12-24 06:12:23.075 GMT [6484][walsender] [tap_sub][25/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16398_sync_16384_7451855407062627244 WAIT 2024-12-24 06:12:23.075 GMT [6484][walsender] [tap_sub][25/0:0] LOG: acquired logical replication slot "pg_16398_sync_16384_7451855407062627244" 2024-12-24 06:12:23.075 GMT [6484][walsender] [tap_sub][25/0:0] STATEMENT: DROP_REPLICATION_SLOT pg_16398_sync_16384_7451855407062627244 WAIT 2024-12-24 06:12:23.076 GMT [6484][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:00.032 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:23.274 GMT [3720][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:23.276 GMT [3720][client backend] [[unknown]][4/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:23.276 GMT [3720][client backend] [[unknown]][4/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:23.280 GMT [3720][client backend] [015_stream.pl][4/2:0] LOG: statement: SELECT pg_is_in_recovery() 2024-12-24 06:12:23.283 GMT [3720][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.011 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:23.348 GMT [3704][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:23.349 GMT [3704][client backend] [[unknown]][5/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:23.349 GMT [3704][client backend] [[unknown]][5/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:23.352 GMT [3704][client backend] [015_stream.pl][5/2:0] LOG: statement: SELECT pg_current_wal_lsn() 2024-12-24 06:12:23.355 GMT [3704][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.009 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:23.432 GMT [6468][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:23.434 GMT [6468][client backend] [[unknown]][6/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:23.434 GMT [6468][client backend] [[unknown]][6/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:23.438 GMT [6468][client backend] [015_stream.pl][6/2:0] LOG: statement: SELECT '0/1792A28' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-12-24 06:12:23.448 GMT [6468][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.021 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:23.630 GMT [5724][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:23.631 GMT [5724][client backend] [[unknown]][7/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:23.631 GMT [5724][client backend] [[unknown]][7/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:23.742 GMT [5724][client backend] [015_stream.pl][7/2:0] LOG: statement: BEGIN; 2024-12-24 06:12:23.743 GMT [5724][client backend] [015_stream.pl][7/2:0] LOG: statement: INSERT INTO test_tab SELECT i, sha256(i::text::bytea) FROM generate_series(3, 5000) s(i); 2024-12-24 06:12:23.796 GMT [5724][client backend] [015_stream.pl][7/2:751] LOG: statement: UPDATE test_tab SET b = sha256(b) WHERE mod(a,2) = 0; 2024-12-24 06:12:23.853 GMT [5724][client backend] [015_stream.pl][7/2:751] LOG: statement: DELETE FROM test_tab WHERE mod(a,3) = 0; 2024-12-24 06:12:23.858 GMT [5724][client backend] [015_stream.pl][7/2:751] LOG: statement: ; 2024-12-24 06:12:23.894 GMT [2064][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:23.896 GMT [2064][client backend] [[unknown]][8/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:23.896 GMT [2064][client backend] [[unknown]][8/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:23.900 GMT [2064][client backend] [015_stream.pl][8/2:0] LOG: statement: BEGIN; 2024-12-24 06:12:23.900 GMT [2064][client backend] [015_stream.pl][8/2:0] LOG: statement: INSERT INTO test_tab SELECT i, sha256(i::text::bytea) FROM generate_series(5001, 9999) s(i); 2024-12-24 06:12:23.955 GMT [2064][client backend] [015_stream.pl][8/2:752] LOG: statement: DELETE FROM test_tab WHERE a > 5000; 2024-12-24 06:12:23.970 GMT [2064][client backend] [015_stream.pl][8/2:752] LOG: statement: COMMIT; 2024-12-24 06:12:23.971 GMT [2064][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.080 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:23.989 GMT [5724][client backend] [015_stream.pl][7/2:751] LOG: statement: COMMIT ; 2024-12-24 06:12:23.990 GMT [5724][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.363 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:24.106 GMT [4396][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:24.108 GMT [4396][client backend] [[unknown]][9/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:24.108 GMT [4396][client backend] [[unknown]][9/1:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:24.113 GMT [4396][client backend] [015_stream.pl][9/2:0] LOG: statement: SELECT pg_is_in_recovery() 2024-12-24 06:12:24.143 GMT [4396][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.040 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:24.222 GMT [5064][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:24.224 GMT [5064][client backend] [[unknown]][0/3:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:24.224 GMT [5064][client backend] [[unknown]][0/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:24.227 GMT [5064][client backend] [015_stream.pl][0/4:0] LOG: statement: SELECT pg_current_wal_lsn() 2024-12-24 06:12:24.230 GMT [5064][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.011 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:24.308 GMT [1164][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:24.310 GMT [1164][client backend] [[unknown]][1/3:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:24.310 GMT [1164][client backend] [[unknown]][1/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:24.318 GMT [1164][client backend] [015_stream.pl][1/4:0] LOG: statement: SELECT '0/1A21B48' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-12-24 06:12:24.332 GMT [1164][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.029 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:24.574 GMT [3520][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:24.575 GMT [3520][client backend] [[unknown]][2/3:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:24.575 GMT [3520][client backend] [[unknown]][2/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:24.585 GMT [3520][client backend] [015_stream.pl][2/4:0] LOG: statement: SELECT '0/1A21B48' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-12-24 06:12:24.596 GMT [3520][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.025 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:24.792 GMT [1124][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:24.793 GMT [1124][client backend] [[unknown]][3/3:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:24.793 GMT [1124][client backend] [[unknown]][3/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:24.796 GMT [1124][client backend] [015_stream.pl][3/4:0] LOG: statement: SELECT '0/1A21B48' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-12-24 06:12:24.804 GMT [1124][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.015 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:24.977 GMT [5064][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:24.978 GMT [5064][client backend] [[unknown]][4/3:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:24.978 GMT [5064][client backend] [[unknown]][4/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:24.981 GMT [5064][client backend] [015_stream.pl][4/4:0] LOG: statement: SELECT '0/1A21B48' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-12-24 06:12:24.990 GMT [5064][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.016 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:25.119 GMT [3232][walsender] [tap_sub][23/0:0] LOG: released logical replication slot "tap_sub" 2024-12-24 06:12:25.119 GMT [3232][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:02.151 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:25.166 GMT [2576][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:25.167 GMT [2576][walsender] [[unknown]][26/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:25.168 GMT [2576][walsender] [[unknown]][26/1:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-12-24 06:12:25.176 GMT [2576][walsender] [tap_sub][26/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-12-24 06:12:25.177 GMT [2576][walsender] [tap_sub][26/0:0] LOG: received replication command: IDENTIFY_SYSTEM 2024-12-24 06:12:25.177 GMT [2576][walsender] [tap_sub][26/0:0] STATEMENT: IDENTIFY_SYSTEM 2024-12-24 06:12:25.177 GMT [2576][walsender] [tap_sub][26/0:0] LOG: received replication command: START_REPLICATION SLOT "tap_sub" LOGICAL 0/1A21B48 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"', binary 'true') 2024-12-24 06:12:25.177 GMT [2576][walsender] [tap_sub][26/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/1A21B48 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"', binary 'true') 2024-12-24 06:12:25.177 GMT [2576][walsender] [tap_sub][26/0:0] LOG: acquired logical replication slot "tap_sub" 2024-12-24 06:12:25.177 GMT [2576][walsender] [tap_sub][26/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/1A21B48 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"', binary 'true') 2024-12-24 06:12:25.178 GMT [2576][walsender] [tap_sub][26/0:0] LOG: starting logical decoding for slot "tap_sub" 2024-12-24 06:12:25.178 GMT [2576][walsender] [tap_sub][26/0:0] DETAIL: Streaming transactions committing after 0/1A21B48, reading WAL from 0/17929F0. 2024-12-24 06:12:25.178 GMT [2576][walsender] [tap_sub][26/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/1A21B48 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"', binary 'true') 2024-12-24 06:12:25.178 GMT [2576][walsender] [tap_sub][26/0:0] LOG: logical decoding found consistent point at 0/17929F0 2024-12-24 06:12:25.178 GMT [2576][walsender] [tap_sub][26/0:0] DETAIL: There are no running transactions. 2024-12-24 06:12:25.178 GMT [2576][walsender] [tap_sub][26/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/1A21B48 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"', binary 'true') 2024-12-24 06:12:25.206 GMT [6252][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:25.208 GMT [6252][client backend] [[unknown]][5/3:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:25.208 GMT [6252][client backend] [[unknown]][5/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:25.211 GMT [6252][client backend] [015_stream.pl][5/4:0] LOG: statement: BEGIN; 2024-12-24 06:12:25.212 GMT [6252][client backend] [015_stream.pl][5/4:0] LOG: statement: INSERT INTO test_tab SELECT i, sha256(i::text::bytea) FROM generate_series(5001, 10000) s(i); 2024-12-24 06:12:25.278 GMT [6252][client backend] [015_stream.pl][5/4:753] LOG: statement: UPDATE test_tab SET b = sha256(b) WHERE mod(a,2) = 0; 2024-12-24 06:12:25.362 GMT [6252][client backend] [015_stream.pl][5/4:753] LOG: statement: DELETE FROM test_tab WHERE mod(a,3) = 0; 2024-12-24 06:12:25.369 GMT [6252][client backend] [015_stream.pl][5/4:753] LOG: statement: COMMIT; 2024-12-24 06:12:25.371 GMT [6252][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.168 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:25.507 GMT [632][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:25.508 GMT [632][client backend] [[unknown]][6/3:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:25.508 GMT [632][client backend] [[unknown]][6/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:25.520 GMT [632][client backend] [015_stream.pl][6/4:0] LOG: statement: SELECT pg_is_in_recovery() 2024-12-24 06:12:25.523 GMT [632][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.022 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:25.586 GMT [6228][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:25.587 GMT [6228][client backend] [[unknown]][8/3:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:25.587 GMT [6228][client backend] [[unknown]][8/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:25.590 GMT [6228][client backend] [015_stream.pl][8/4:0] LOG: statement: SELECT pg_current_wal_lsn() 2024-12-24 06:12:25.591 GMT [6228][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.009 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:25.682 GMT [3704][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:25.683 GMT [3704][client backend] [[unknown]][7/3:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:25.683 GMT [3704][client backend] [[unknown]][7/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:25.686 GMT [3704][client backend] [015_stream.pl][7/4:0] LOG: statement: SELECT '0/1BE79B8' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-12-24 06:12:25.695 GMT [3704][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.016 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:25.925 GMT [6304][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:25.927 GMT [6304][client backend] [[unknown]][9/3:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:25.927 GMT [6304][client backend] [[unknown]][9/3:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:25.930 GMT [6304][client backend] [015_stream.pl][9/4:0] LOG: statement: SELECT '0/1BE79B8' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-12-24 06:12:25.938 GMT [6304][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.015 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:26.362 GMT [3500][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:26.363 GMT [3500][client backend] [[unknown]][0/5:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:26.363 GMT [3500][client backend] [[unknown]][0/5:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:26.366 GMT [3500][client backend] [015_stream.pl][0/6:0] LOG: statement: UPDATE test_tab SET b = sha256(a::text::bytea) 2024-12-24 06:12:26.445 GMT [3500][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.087 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:26.574 GMT [4392][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:26.575 GMT [4392][client backend] [[unknown]][1/5:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:26.575 GMT [4392][client backend] [[unknown]][1/5:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:26.581 GMT [4392][client backend] [015_stream.pl][1/6:0] LOG: statement: SELECT pg_is_in_recovery() 2024-12-24 06:12:26.584 GMT [4392][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.012 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:26.693 GMT [268][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:26.695 GMT [268][client backend] [[unknown]][2/5:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:26.695 GMT [268][client backend] [[unknown]][2/5:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:26.698 GMT [268][client backend] [015_stream.pl][2/6:0] LOG: statement: SELECT pg_current_wal_lsn() 2024-12-24 06:12:26.701 GMT [268][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.011 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:26.773 GMT [1720][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:26.775 GMT [1720][client backend] [[unknown]][3/5:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:26.775 GMT [1720][client backend] [[unknown]][3/5:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:26.778 GMT [1720][client backend] [015_stream.pl][3/6:0] LOG: statement: SELECT '0/1CCCC70' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-12-24 06:12:26.788 GMT [1720][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.017 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:26.994 GMT [6936][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:26.995 GMT [6936][client backend] [[unknown]][4/5:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:26.995 GMT [6936][client backend] [[unknown]][4/5:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:26.998 GMT [6936][client backend] [015_stream.pl][4/6:0] LOG: statement: DELETE FROM test_tab WHERE (a > 2) 2024-12-24 06:12:27.023 GMT [6936][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.032 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:27.163 GMT [5428][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:27.164 GMT [5428][client backend] [[unknown]][5/5:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:27.164 GMT [5428][client backend] [[unknown]][5/5:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:27.170 GMT [5428][client backend] [015_stream.pl][5/6:0] LOG: statement: SELECT pg_is_in_recovery() 2024-12-24 06:12:27.173 GMT [5428][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.014 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:27.273 GMT [5308][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:27.274 GMT [5308][client backend] [[unknown]][6/5:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:27.274 GMT [5308][client backend] [[unknown]][6/5:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:27.277 GMT [5308][client backend] [015_stream.pl][6/6:0] LOG: statement: SELECT pg_current_wal_lsn() 2024-12-24 06:12:27.280 GMT [5308][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.010 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:27.339 GMT [3768][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:27.340 GMT [3768][client backend] [[unknown]][8/5:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:27.340 GMT [3768][client backend] [[unknown]][8/5:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:27.343 GMT [3768][client backend] [015_stream.pl][8/6:0] LOG: statement: SELECT '0/1D37618' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-12-24 06:12:27.355 GMT [3768][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.018 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:27.420 GMT [2408][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:27.421 GMT [2408][client backend] [[unknown]][7/5:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:27.421 GMT [2408][client backend] [[unknown]][7/5:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:27.424 GMT [2408][client backend] [015_stream.pl][7/6:0] LOG: statement: SELECT pid FROM pg_stat_replication WHERE application_name = 'tap_sub' AND state = 'streaming'; 2024-12-24 06:12:27.432 GMT [2408][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.015 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:27.509 GMT [2576][walsender] [tap_sub][26/0:0] LOG: released logical replication slot "tap_sub" 2024-12-24 06:12:27.509 GMT [2576][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:02.346 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:27.548 GMT [2608][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:27.549 GMT [2608][walsender] [[unknown]][27/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:27.549 GMT [2608][walsender] [[unknown]][27/1:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-12-24 06:12:27.552 GMT [2608][walsender] [tap_sub][27/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-12-24 06:12:27.553 GMT [2608][walsender] [tap_sub][27/0:0] LOG: received replication command: IDENTIFY_SYSTEM 2024-12-24 06:12:27.553 GMT [2608][walsender] [tap_sub][27/0:0] STATEMENT: IDENTIFY_SYSTEM 2024-12-24 06:12:27.553 GMT [2608][walsender] [tap_sub][27/0:0] LOG: received replication command: START_REPLICATION SLOT "tap_sub" LOGICAL 0/1D37618 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-12-24 06:12:27.553 GMT [2608][walsender] [tap_sub][27/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/1D37618 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-12-24 06:12:27.553 GMT [2608][walsender] [tap_sub][27/0:0] LOG: acquired logical replication slot "tap_sub" 2024-12-24 06:12:27.553 GMT [2608][walsender] [tap_sub][27/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/1D37618 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-12-24 06:12:27.554 GMT [2608][walsender] [tap_sub][27/0:0] LOG: starting logical decoding for slot "tap_sub" 2024-12-24 06:12:27.554 GMT [2608][walsender] [tap_sub][27/0:0] DETAIL: Streaming transactions committing after 0/1D37618, reading WAL from 0/17929F0. 2024-12-24 06:12:27.554 GMT [2608][walsender] [tap_sub][27/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/1D37618 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-12-24 06:12:27.554 GMT [2608][walsender] [tap_sub][27/0:0] LOG: logical decoding found consistent point at 0/17929F0 2024-12-24 06:12:27.554 GMT [2608][walsender] [tap_sub][27/0:0] DETAIL: There are no running transactions. 2024-12-24 06:12:27.554 GMT [2608][walsender] [tap_sub][27/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/1D37618 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"') 2024-12-24 06:12:27.574 GMT [6848][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:27.576 GMT [6848][client backend] [[unknown]][9/5:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:27.576 GMT [6848][client backend] [[unknown]][9/5:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:27.579 GMT [6848][client backend] [015_stream.pl][9/6:0] LOG: statement: SELECT pid != 2576 FROM pg_stat_replication WHERE application_name = 'tap_sub' AND state = 'streaming'; 2024-12-24 06:12:27.584 GMT [6848][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.012 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:27.736 GMT [4420][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:27.737 GMT [4420][client backend] [[unknown]][0/7:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:27.737 GMT [4420][client backend] [[unknown]][0/7:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:27.740 GMT [4420][client backend] [015_stream.pl][0/8:0] LOG: statement: SELECT pid != 2576 FROM pg_stat_replication WHERE application_name = 'tap_sub' AND state = 'streaming'; 2024-12-24 06:12:27.744 GMT [4420][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.011 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:27.912 GMT [6912][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:27.914 GMT [6912][client backend] [[unknown]][1/7:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:27.914 GMT [6912][client backend] [[unknown]][1/7:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:27.916 GMT [6912][client backend] [015_stream.pl][1/8:0] LOG: statement: SELECT pid != 2576 FROM pg_stat_replication WHERE application_name = 'tap_sub' AND state = 'streaming'; 2024-12-24 06:12:27.923 GMT [6912][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.013 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:28.202 GMT [2108][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:28.204 GMT [2108][client backend] [[unknown]][2/7:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:28.204 GMT [2108][client backend] [[unknown]][2/7:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:28.328 GMT [2108][client backend] [015_stream.pl][2/8:0] LOG: statement: BEGIN; 2024-12-24 06:12:28.328 GMT [2108][client backend] [015_stream.pl][2/8:0] LOG: statement: INSERT INTO test_tab SELECT i, sha256(i::text::bytea) FROM generate_series(3, 5000) s(i); 2024-12-24 06:12:28.419 GMT [2108][client backend] [015_stream.pl][2/8:756] LOG: statement: UPDATE test_tab SET b = sha256(b) WHERE mod(a,2) = 0; 2024-12-24 06:12:28.470 GMT [2108][client backend] [015_stream.pl][2/8:756] LOG: statement: DELETE FROM test_tab WHERE mod(a,3) = 0; 2024-12-24 06:12:28.478 GMT [2108][client backend] [015_stream.pl][2/8:756] LOG: statement: ; 2024-12-24 06:12:28.574 GMT [728][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:28.576 GMT [728][client backend] [[unknown]][3/7:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:28.576 GMT [728][client backend] [[unknown]][3/7:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:28.581 GMT [728][client backend] [015_stream.pl][3/8:0] LOG: statement: BEGIN; 2024-12-24 06:12:28.582 GMT [728][client backend] [015_stream.pl][3/8:0] LOG: statement: INSERT INTO test_tab SELECT i, sha256(i::text::bytea) FROM generate_series(5001, 9999) s(i); 2024-12-24 06:12:28.654 GMT [728][client backend] [015_stream.pl][3/8:757] LOG: statement: DELETE FROM test_tab WHERE a > 5000; 2024-12-24 06:12:28.669 GMT [728][client backend] [015_stream.pl][3/8:757] LOG: statement: COMMIT; 2024-12-24 06:12:28.670 GMT [728][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.099 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:28.847 GMT [2108][client backend] [015_stream.pl][2/8:756] LOG: statement: COMMIT ; 2024-12-24 06:12:28.848 GMT [2108][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.651 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:28.934 GMT [4716][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:28.936 GMT [4716][client backend] [[unknown]][4/7:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:28.936 GMT [4716][client backend] [[unknown]][4/7:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:28.940 GMT [4716][client backend] [015_stream.pl][4/8:0] LOG: statement: SELECT pg_is_in_recovery() 2024-12-24 06:12:28.942 GMT [4716][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.010 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:29.017 GMT [5672][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:29.019 GMT [5672][client backend] [[unknown]][5/7:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:29.019 GMT [5672][client backend] [[unknown]][5/7:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:29.021 GMT [5672][client backend] [015_stream.pl][5/8:0] LOG: statement: SELECT pg_current_wal_lsn() 2024-12-24 06:12:29.023 GMT [5672][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.009 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:29.071 GMT [5656][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:29.072 GMT [5656][client backend] [[unknown]][6/7:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:29.072 GMT [5656][client backend] [[unknown]][6/7:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:29.075 GMT [5656][client backend] [015_stream.pl][6/8:0] LOG: statement: SELECT '0/1FBDB50' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-12-24 06:12:29.084 GMT [5656][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.016 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:29.276 GMT [2608][walsender] [tap_sub][27/0:0] LOG: released logical replication slot "tap_sub" 2024-12-24 06:12:29.276 GMT [2608][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:01.731 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:29.325 GMT [6688][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:29.326 GMT [6688][walsender] [[unknown]][28/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:29.326 GMT [6688][walsender] [[unknown]][28/1:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-12-24 06:12:29.329 GMT [6688][walsender] [tap_sub][28/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-12-24 06:12:29.330 GMT [6688][walsender] [tap_sub][28/0:0] LOG: received replication command: IDENTIFY_SYSTEM 2024-12-24 06:12:29.330 GMT [6688][walsender] [tap_sub][28/0:0] STATEMENT: IDENTIFY_SYSTEM 2024-12-24 06:12:29.330 GMT [6688][walsender] [tap_sub][28/0:0] LOG: received replication command: START_REPLICATION SLOT "tap_sub" LOGICAL 0/1FBDB50 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true') 2024-12-24 06:12:29.330 GMT [6688][walsender] [tap_sub][28/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/1FBDB50 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true') 2024-12-24 06:12:29.330 GMT [6688][walsender] [tap_sub][28/0:0] LOG: acquired logical replication slot "tap_sub" 2024-12-24 06:12:29.330 GMT [6688][walsender] [tap_sub][28/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/1FBDB50 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true') 2024-12-24 06:12:29.331 GMT [6688][walsender] [tap_sub][28/0:0] LOG: starting logical decoding for slot "tap_sub" 2024-12-24 06:12:29.331 GMT [6688][walsender] [tap_sub][28/0:0] DETAIL: Streaming transactions committing after 0/1FBDB50, reading WAL from 0/17929F0. 2024-12-24 06:12:29.331 GMT [6688][walsender] [tap_sub][28/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/1FBDB50 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true') 2024-12-24 06:12:29.331 GMT [6688][walsender] [tap_sub][28/0:0] LOG: logical decoding found consistent point at 0/17929F0 2024-12-24 06:12:29.331 GMT [6688][walsender] [tap_sub][28/0:0] DETAIL: There are no running transactions. 2024-12-24 06:12:29.331 GMT [6688][walsender] [tap_sub][28/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/1FBDB50 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true') 2024-12-24 06:12:29.347 GMT [4592][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:29.349 GMT [4592][client backend] [[unknown]][8/7:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:29.349 GMT [4592][client backend] [[unknown]][8/7:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:29.351 GMT [4592][client backend] [015_stream.pl][8/8:0] LOG: statement: BEGIN; 2024-12-24 06:12:29.352 GMT [4592][client backend] [015_stream.pl][8/8:0] LOG: statement: INSERT INTO test_tab SELECT i, sha256(i::text::bytea) FROM generate_series(5001, 10000) s(i); 2024-12-24 06:12:29.437 GMT [4592][client backend] [015_stream.pl][8/8:758] LOG: statement: UPDATE test_tab SET b = sha256(b) WHERE mod(a,2) = 0; 2024-12-24 06:12:29.515 GMT [4592][client backend] [015_stream.pl][8/8:758] LOG: statement: DELETE FROM test_tab WHERE mod(a,3) = 0; 2024-12-24 06:12:29.524 GMT [4592][client backend] [015_stream.pl][8/8:758] LOG: statement: COMMIT; 2024-12-24 06:12:29.525 GMT [4592][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.181 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:29.750 GMT [4404][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:29.754 GMT [4404][client backend] [[unknown]][7/7:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:29.754 GMT [4404][client backend] [[unknown]][7/7:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:29.761 GMT [4404][client backend] [015_stream.pl][7/8:0] LOG: statement: SELECT pg_is_in_recovery() 2024-12-24 06:12:29.764 GMT [4404][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.021 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:29.857 GMT [4508][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:29.858 GMT [4508][client backend] [[unknown]][9/7:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:29.858 GMT [4508][client backend] [[unknown]][9/7:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:29.861 GMT [4508][client backend] [015_stream.pl][9/8:0] LOG: statement: SELECT pg_current_wal_lsn() 2024-12-24 06:12:29.863 GMT [4508][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.009 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:29.999 GMT [5848][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:30.000 GMT [5848][client backend] [[unknown]][0/9:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:30.000 GMT [5848][client backend] [[unknown]][0/9:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:30.008 GMT [5848][client backend] [015_stream.pl][0/10:0] LOG: statement: SELECT '0/21774A0' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-12-24 06:12:30.027 GMT [5848][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.031 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:30.216 GMT [5152][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:30.217 GMT [5152][client backend] [[unknown]][1/9:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:30.217 GMT [5152][client backend] [[unknown]][1/9:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:30.221 GMT [5152][client backend] [015_stream.pl][1/10:0] LOG: statement: SELECT '0/21774A0' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-12-24 06:12:30.228 GMT [5152][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.015 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:30.406 GMT [3916][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:30.408 GMT [3916][client backend] [[unknown]][3/9:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:30.408 GMT [3916][client backend] [[unknown]][3/9:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:30.410 GMT [3916][client backend] [015_stream.pl][3/10:0] LOG: statement: SELECT '0/21774A0' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-12-24 06:12:30.417 GMT [3916][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.014 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:30.581 GMT [3660][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:30.582 GMT [3660][client backend] [[unknown]][2/9:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:30.582 GMT [3660][client backend] [[unknown]][2/9:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:30.585 GMT [3660][client backend] [015_stream.pl][2/10:0] LOG: statement: SELECT '0/21774A0' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-12-24 06:12:30.594 GMT [3660][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.016 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:30.887 GMT [3016][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:30.889 GMT [3016][client backend] [[unknown]][4/9:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:30.889 GMT [3016][client backend] [[unknown]][4/9:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:30.894 GMT [3016][client backend] [015_stream.pl][4/10:0] LOG: statement: UPDATE test_tab SET b = sha256(a::text::bytea) 2024-12-24 06:12:31.126 GMT [3016][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.244 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:31.278 GMT [1564][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:31.280 GMT [1564][client backend] [[unknown]][5/9:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:31.280 GMT [1564][client backend] [[unknown]][5/9:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:31.284 GMT [1564][client backend] [015_stream.pl][5/10:0] LOG: statement: SELECT pg_is_in_recovery() 2024-12-24 06:12:31.287 GMT [1564][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.012 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:31.343 GMT [5220][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:31.344 GMT [5220][client backend] [[unknown]][6/9:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:31.344 GMT [5220][client backend] [[unknown]][6/9:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:31.347 GMT [5220][client backend] [015_stream.pl][6/10:0] LOG: statement: SELECT pg_current_wal_lsn() 2024-12-24 06:12:31.351 GMT [5220][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.011 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:31.398 GMT [6516][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:31.400 GMT [6516][client backend] [[unknown]][8/9:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:31.400 GMT [6516][client backend] [[unknown]][8/9:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:31.403 GMT [6516][client backend] [015_stream.pl][8/10:0] LOG: statement: SELECT '0/225D5D8' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-12-24 06:12:31.413 GMT [6516][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.017 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:31.586 GMT [1164][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:31.588 GMT [1164][client backend] [[unknown]][7/9:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:31.588 GMT [1164][client backend] [[unknown]][7/9:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:31.597 GMT [1164][client backend] [015_stream.pl][7/10:0] LOG: statement: DELETE FROM test_tab WHERE (a > 2) 2024-12-24 06:12:31.660 GMT [1164][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.080 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:31.813 GMT [6964][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:31.815 GMT [6964][client backend] [[unknown]][9/9:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:31.815 GMT [6964][client backend] [[unknown]][9/9:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:31.818 GMT [6964][client backend] [015_stream.pl][9/10:0] LOG: statement: SELECT pg_is_in_recovery() 2024-12-24 06:12:31.821 GMT [6964][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.010 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:31.880 GMT [5104][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:31.881 GMT [5104][client backend] [[unknown]][0/11:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:31.881 GMT [5104][client backend] [[unknown]][0/11:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:31.884 GMT [5104][client backend] [015_stream.pl][0/12:0] LOG: statement: SELECT pg_current_wal_lsn() 2024-12-24 06:12:31.887 GMT [5104][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.010 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:31.949 GMT [6480][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:31.950 GMT [6480][client backend] [[unknown]][1/11:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:31.950 GMT [6480][client backend] [[unknown]][1/11:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:31.953 GMT [6480][client backend] [015_stream.pl][1/12:0] LOG: statement: SELECT '0/22C80E0' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-12-24 06:12:31.963 GMT [6480][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.017 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:32.296 GMT [4700][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:32.297 GMT [4700][client backend] [[unknown]][3/11:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:32.297 GMT [4700][client backend] [[unknown]][3/11:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:32.468 GMT [4700][client backend] [015_stream.pl][3/12:0] LOG: statement: BEGIN; 2024-12-24 06:12:32.468 GMT [4700][client backend] [015_stream.pl][3/12:0] LOG: statement: INSERT INTO test_tab_2 SELECT i FROM generate_series(1, 5000) s(i); 2024-12-24 06:12:32.482 GMT [4700][client backend] [015_stream.pl][3/12:761] LOG: statement: ; 2024-12-24 06:12:32.763 GMT [1224][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:32.766 GMT [1224][client backend] [[unknown]][2/11:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:32.766 GMT [1224][client backend] [[unknown]][2/11:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:32.769 GMT [1224][client backend] [015_stream.pl][2/12:0] LOG: statement: INSERT INTO test_tab_2 values(1) 2024-12-24 06:12:32.776 GMT [1224][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.020 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:32.793 GMT [6688][walsender] [tap_sub][28/0:0] LOG: could not receive data from client: An existing connection was forcibly closed by the remote host. 2024-12-24 06:12:32.793 GMT [6688][walsender] [tap_sub][28/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/1FBDB50 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true') 2024-12-24 06:12:32.793 GMT [6688][walsender] [tap_sub][28/0:0] LOG: unexpected EOF on standby connection 2024-12-24 06:12:32.793 GMT [6688][walsender] [tap_sub][28/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/1FBDB50 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true') 2024-12-24 06:12:32.793 GMT [6688][walsender] [tap_sub][28/0:0] LOG: released logical replication slot "tap_sub" 2024-12-24 06:12:32.794 GMT [6688][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:03.473 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:32.803 GMT [4700][client backend] [015_stream.pl][3/12:761] LOG: statement: COMMIT ; 2024-12-24 06:12:32.804 GMT [4700][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.511 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:32.865 GMT [4952][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:32.866 GMT [4952][walsender] [[unknown]][29/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:32.866 GMT [4952][walsender] [[unknown]][29/1:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-12-24 06:12:32.869 GMT [4952][walsender] [tap_sub][29/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-12-24 06:12:32.870 GMT [4952][walsender] [tap_sub][29/0:0] LOG: received replication command: IDENTIFY_SYSTEM 2024-12-24 06:12:32.870 GMT [4952][walsender] [tap_sub][29/0:0] STATEMENT: IDENTIFY_SYSTEM 2024-12-24 06:12:32.870 GMT [4952][walsender] [tap_sub][29/0:0] LOG: received replication command: START_REPLICATION SLOT "tap_sub" LOGICAL 0/22C80E0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true') 2024-12-24 06:12:32.870 GMT [4952][walsender] [tap_sub][29/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/22C80E0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true') 2024-12-24 06:12:32.870 GMT [4952][walsender] [tap_sub][29/0:0] LOG: acquired logical replication slot "tap_sub" 2024-12-24 06:12:32.870 GMT [4952][walsender] [tap_sub][29/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/22C80E0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true') 2024-12-24 06:12:32.870 GMT [4952][walsender] [tap_sub][29/0:0] LOG: 0/22C80E0 has been already streamed, forwarding to 0/2315EB0 2024-12-24 06:12:32.870 GMT [4952][walsender] [tap_sub][29/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/22C80E0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true') 2024-12-24 06:12:32.870 GMT [4952][walsender] [tap_sub][29/0:0] LOG: starting logical decoding for slot "tap_sub" 2024-12-24 06:12:32.870 GMT [4952][walsender] [tap_sub][29/0:0] DETAIL: Streaming transactions committing after 0/2315EB0, reading WAL from 0/17929F0. 2024-12-24 06:12:32.870 GMT [4952][walsender] [tap_sub][29/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/22C80E0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true') 2024-12-24 06:12:32.871 GMT [4952][walsender] [tap_sub][29/0:0] LOG: logical decoding found consistent point at 0/17929F0 2024-12-24 06:12:32.871 GMT [4952][walsender] [tap_sub][29/0:0] DETAIL: There are no running transactions. 2024-12-24 06:12:32.871 GMT [4952][walsender] [tap_sub][29/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/22C80E0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true') 2024-12-24 06:12:32.992 GMT [6088][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:32.994 GMT [6088][client backend] [[unknown]][4/11:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:32.994 GMT [6088][client backend] [[unknown]][4/11:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:32.997 GMT [6088][client backend] [015_stream.pl][4/12:0] LOG: statement: SELECT pg_is_in_recovery() 2024-12-24 06:12:33.000 GMT [6088][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.010 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:33.092 GMT [1708][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:33.093 GMT [1708][client backend] [[unknown]][5/11:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:33.093 GMT [1708][client backend] [[unknown]][5/11:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:33.096 GMT [1708][client backend] [015_stream.pl][5/12:0] LOG: statement: SELECT pg_current_wal_lsn() 2024-12-24 06:12:33.099 GMT [1708][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.010 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:33.196 GMT [6360][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:33.197 GMT [6360][client backend] [[unknown]][6/11:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:33.197 GMT [6360][client backend] [[unknown]][6/11:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:33.200 GMT [6360][client backend] [015_stream.pl][6/12:0] LOG: statement: SELECT '0/2316728' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-12-24 06:12:33.210 GMT [6360][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.016 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:33.415 GMT [6752][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:33.417 GMT [6752][client backend] [[unknown]][8/11:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:33.417 GMT [6752][client backend] [[unknown]][8/11:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:33.422 GMT [6752][client backend] [015_stream.pl][8/12:0] LOG: statement: SELECT '0/2316728' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-12-24 06:12:33.432 GMT [6752][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.031 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:33.709 GMT [6412][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:33.710 GMT [6412][client backend] [[unknown]][7/11:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:33.710 GMT [6412][client backend] [[unknown]][7/11:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:33.713 GMT [6412][client backend] [015_stream.pl][7/12:0] LOG: statement: SELECT '0/2316728' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-12-24 06:12:33.727 GMT [6412][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.021 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:33.884 GMT [3704][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:33.885 GMT [3704][client backend] [[unknown]][9/11:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:33.885 GMT [3704][client backend] [[unknown]][9/11:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:33.888 GMT [3704][client backend] [015_stream.pl][9/12:0] LOG: statement: TRUNCATE TABLE test_tab_2 2024-12-24 06:12:33.891 GMT [3704][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.010 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:33.955 GMT [6224][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:33.957 GMT [6224][client backend] [[unknown]][0/13:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:33.957 GMT [6224][client backend] [[unknown]][0/13:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:33.961 GMT [6224][client backend] [015_stream.pl][0/14:0] LOG: statement: SELECT pg_is_in_recovery() 2024-12-24 06:12:33.964 GMT [6224][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.011 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:34.099 GMT [4072][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:34.100 GMT [4072][client backend] [[unknown]][1/13:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:34.100 GMT [4072][client backend] [[unknown]][1/13:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:34.103 GMT [4072][client backend] [015_stream.pl][1/14:0] LOG: statement: SELECT pg_current_wal_lsn() 2024-12-24 06:12:34.106 GMT [4072][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.009 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:34.200 GMT [4332][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:34.202 GMT [4332][client backend] [[unknown]][2/13:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:34.202 GMT [4332][client backend] [[unknown]][2/13:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:34.205 GMT [4332][client backend] [015_stream.pl][2/14:0] LOG: statement: SELECT '0/2316A48' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-12-24 06:12:34.213 GMT [4332][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.016 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:34.353 GMT [1564][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:34.354 GMT [1564][client backend] [[unknown]][3/13:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:34.354 GMT [1564][client backend] [[unknown]][3/13:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:34.497 GMT [1564][client backend] [015_stream.pl][3/14:0] LOG: statement: BEGIN; 2024-12-24 06:12:34.497 GMT [1564][client backend] [015_stream.pl][3/14:0] LOG: statement: INSERT INTO test_tab_2 SELECT i FROM generate_series(1, 5000) s(i); 2024-12-24 06:12:34.511 GMT [1564][client backend] [015_stream.pl][3/14:764] LOG: statement: ; 2024-12-24 06:12:34.667 GMT [4848][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:34.669 GMT [4848][client backend] [[unknown]][4/13:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:34.669 GMT [4848][client backend] [[unknown]][4/13:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:34.672 GMT [4848][client backend] [015_stream.pl][4/14:0] LOG: statement: INSERT INTO test_tab_2 SELECT i FROM generate_series(1, 5000) s(i) 2024-12-24 06:12:34.709 GMT [4848][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.045 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:34.734 GMT [1564][client backend] [015_stream.pl][3/14:764] LOG: statement: COMMIT ; 2024-12-24 06:12:34.735 GMT [1564][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.385 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:34.764 GMT [4952][walsender] [tap_sub][29/0:0] LOG: released logical replication slot "tap_sub" 2024-12-24 06:12:34.764 GMT [4952][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:01.902 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:34.904 GMT [736][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:34.905 GMT [736][walsender] [[unknown]][30/1:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:34.905 GMT [736][walsender] [[unknown]][30/1:0] LOG: replication connection authorized: user=SYSTEM application_name=tap_sub 2024-12-24 06:12:34.909 GMT [736][walsender] [tap_sub][30/2:0] LOG: statement: SELECT pg_catalog.set_config('search_path', '', false); 2024-12-24 06:12:34.910 GMT [736][walsender] [tap_sub][30/0:0] LOG: received replication command: IDENTIFY_SYSTEM 2024-12-24 06:12:34.910 GMT [736][walsender] [tap_sub][30/0:0] STATEMENT: IDENTIFY_SYSTEM 2024-12-24 06:12:34.910 GMT [736][walsender] [tap_sub][30/0:0] LOG: received replication command: START_REPLICATION SLOT "tap_sub" LOGICAL 0/2316A48 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true') 2024-12-24 06:12:34.910 GMT [736][walsender] [tap_sub][30/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/2316A48 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true') 2024-12-24 06:12:34.910 GMT [736][walsender] [tap_sub][30/0:0] LOG: acquired logical replication slot "tap_sub" 2024-12-24 06:12:34.910 GMT [736][walsender] [tap_sub][30/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/2316A48 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true') 2024-12-24 06:12:34.910 GMT [736][walsender] [tap_sub][30/0:0] LOG: 0/2316A48 has been already streamed, forwarding to 0/23B3558 2024-12-24 06:12:34.910 GMT [736][walsender] [tap_sub][30/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/2316A48 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true') 2024-12-24 06:12:34.911 GMT [736][walsender] [tap_sub][30/0:0] LOG: starting logical decoding for slot "tap_sub" 2024-12-24 06:12:34.911 GMT [736][walsender] [tap_sub][30/0:0] DETAIL: Streaming transactions committing after 0/23B3558, reading WAL from 0/17929F0. 2024-12-24 06:12:34.911 GMT [736][walsender] [tap_sub][30/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/2316A48 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true') 2024-12-24 06:12:34.911 GMT [736][walsender] [tap_sub][30/0:0] LOG: logical decoding found consistent point at 0/17929F0 2024-12-24 06:12:34.911 GMT [736][walsender] [tap_sub][30/0:0] DETAIL: There are no running transactions. 2024-12-24 06:12:34.911 GMT [736][walsender] [tap_sub][30/0:0] STATEMENT: START_REPLICATION SLOT "tap_sub" LOGICAL 0/2316A48 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true') 2024-12-24 06:12:34.929 GMT [1232][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:34.931 GMT [1232][client backend] [[unknown]][5/13:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:34.931 GMT [1232][client backend] [[unknown]][5/13:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:34.934 GMT [1232][client backend] [015_stream.pl][5/14:0] LOG: statement: SELECT pg_is_in_recovery() 2024-12-24 06:12:34.937 GMT [1232][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.010 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:35.029 GMT [5772][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:35.030 GMT [5772][client backend] [[unknown]][6/13:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:35.030 GMT [5772][client backend] [[unknown]][6/13:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:35.033 GMT [5772][client backend] [015_stream.pl][6/14:0] LOG: statement: SELECT pg_current_wal_lsn() 2024-12-24 06:12:35.039 GMT [5772][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.013 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:35.120 GMT [4948][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:35.121 GMT [4948][client backend] [[unknown]][8/13:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:35.121 GMT [4948][client backend] [[unknown]][8/13:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:35.124 GMT [4948][client backend] [015_stream.pl][8/14:0] LOG: statement: SELECT '0/23B35F8' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-12-24 06:12:35.134 GMT [4948][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.016 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:35.364 GMT [4592][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:35.365 GMT [4592][client backend] [[unknown]][7/13:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:35.365 GMT [4592][client backend] [[unknown]][7/13:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:35.377 GMT [4592][client backend] [015_stream.pl][7/14:0] LOG: statement: SELECT '0/23B35F8' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-12-24 06:12:35.387 GMT [4592][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.025 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:35.612 GMT [4212][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:35.613 GMT [4212][client backend] [[unknown]][9/13:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:35.613 GMT [4212][client backend] [[unknown]][9/13:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:35.616 GMT [4212][client backend] [015_stream.pl][9/14:0] LOG: statement: SELECT '0/23B35F8' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-12-24 06:12:35.624 GMT [4212][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.015 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:35.792 GMT [3656][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:35.793 GMT [3656][client backend] [[unknown]][0/15:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:35.793 GMT [3656][client backend] [[unknown]][0/15:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:35.796 GMT [3656][client backend] [015_stream.pl][0/16:0] LOG: statement: SELECT '0/23B35F8' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-12-24 06:12:35.804 GMT [3656][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.015 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:36.007 GMT [4196][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:36.008 GMT [4196][client backend] [[unknown]][1/15:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:36.008 GMT [4196][client backend] [[unknown]][1/15:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:36.011 GMT [4196][client backend] [015_stream.pl][1/16:0] LOG: statement: INSERT INTO test_tab_2 SELECT i FROM generate_series(1, 5000) s(i) 2024-12-24 06:12:36.024 GMT [4196][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.019 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:36.074 GMT [4560][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:36.075 GMT [4560][client backend] [[unknown]][2/15:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:36.075 GMT [4560][client backend] [[unknown]][2/15:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:36.078 GMT [4560][client backend] [015_stream.pl][2/16:0] LOG: statement: SELECT pg_is_in_recovery() 2024-12-24 06:12:36.080 GMT [4560][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.009 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:36.136 GMT [1748][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:36.137 GMT [1748][client backend] [[unknown]][4/15:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:36.137 GMT [1748][client backend] [[unknown]][4/15:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:36.140 GMT [1748][client backend] [015_stream.pl][4/16:0] LOG: statement: SELECT pg_current_wal_lsn() 2024-12-24 06:12:36.143 GMT [1748][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.010 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:36.197 GMT [5000][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:36.198 GMT [5000][client backend] [[unknown]][3/15:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:36.198 GMT [5000][client backend] [[unknown]][3/15:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:36.201 GMT [5000][client backend] [015_stream.pl][3/16:0] LOG: statement: SELECT '0/2401C08' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-12-24 06:12:36.210 GMT [5000][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.016 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:36.373 GMT [680][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:36.376 GMT [680][client backend] [[unknown]][5/15:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:36.376 GMT [680][client backend] [[unknown]][5/15:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:36.388 GMT [680][client backend] [015_stream.pl][5/16:0] LOG: statement: SELECT '0/2401C08' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-12-24 06:12:36.408 GMT [680][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.040 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:36.578 GMT [3000][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:36.579 GMT [3000][client backend] [[unknown]][6/15:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:36.579 GMT [3000][client backend] [[unknown]][6/15:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:36.587 GMT [3000][client backend] [015_stream.pl][6/16:0] LOG: statement: SELECT '0/2401C08' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-12-24 06:12:36.595 GMT [3000][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.020 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:36.748 GMT [6636][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:36.749 GMT [6636][client backend] [[unknown]][8/15:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:36.749 GMT [6636][client backend] [[unknown]][8/15:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:36.752 GMT [6636][client backend] [015_stream.pl][8/16:0] LOG: statement: SELECT '0/2401C08' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-12-24 06:12:36.759 GMT [6636][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.014 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:36.924 GMT [1136][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:36.926 GMT [1136][client backend] [[unknown]][7/15:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:36.926 GMT [1136][client backend] [[unknown]][7/15:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:36.928 GMT [1136][client backend] [015_stream.pl][7/16:0] LOG: statement: SELECT '0/2401C08' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-12-24 06:12:36.936 GMT [1136][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.014 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:37.107 GMT [5404][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-12-24 06:12:37.108 GMT [5404][client backend] [[unknown]][9/15:0] LOG: connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_publisher_data/pgdata/pg_hba.conf:117) 2024-12-24 06:12:37.108 GMT [5404][client backend] [[unknown]][9/15:0] LOG: connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl 2024-12-24 06:12:37.111 GMT [5404][client backend] [015_stream.pl][9/16:0] LOG: statement: SELECT '0/2401C08' <= replay_lsn AND state = 'streaming' FROM pg_catalog.pg_stat_replication WHERE application_name IN ('tap_sub', 'walreceiver') 2024-12-24 06:12:37.119 GMT [5404][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.015 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:38.271 GMT [736][walsender] [tap_sub][30/0:0] LOG: released logical replication slot "tap_sub" 2024-12-24 06:12:38.272 GMT [736][walsender] [tap_sub][:0] LOG: disconnection: session time: 0:00:03.373 user=SYSTEM database=postgres host=[local] 2024-12-24 06:12:38.387 GMT [1692][postmaster] LOG: received immediate shutdown request TRAP: failed Assert("(remainMask.mask | targetMask.mask) == BTYPE_MASK_ALL.mask"), File: "../src/backend/postmaster/postmaster.c", Line: 2896, PID: 1692 abort() has been called