2024-11-24 06:04:02.264 GMT [5652][postmaster] LOG:  starting PostgreSQL 18devel on x86_64-windows, compiled by msvc-19.29.30157, 64-bit
2024-11-24 06:04:02.265 GMT [5652][postmaster] LOG:  listening on Unix socket "C:/Windows/TEMP/hmvFrNn6Nt/.s.PGSQL.26304"
2024-11-24 06:04:02.299 GMT [6092][startup] LOG:  database system was shut down at 2024-11-24 05:56:53 GMT
2024-11-24 06:04:02.317 GMT [5652][postmaster] LOG:  database system is ready to accept connections
2024-11-24 06:04:04.051 GMT [6240][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:04.053 GMT [6240][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-11-24 06:04:04.053 GMT [6240][client backend] [[unknown]][0/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:04.076 GMT [6240][client backend] [015_stream.pl][0/2:0] LOG:  statement: CREATE TABLE test_tab (a int primary key, b bytea)
2024-11-24 06:04:04.093 GMT [6240][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.047 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:04.224 GMT [6736][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:04.226 GMT [6736][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-11-24 06:04:04.226 GMT [6736][client backend] [[unknown]][1/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:04.234 GMT [6736][client backend] [015_stream.pl][1/2:0] LOG:  statement: INSERT INTO test_tab VALUES (1, 'foo'), (2, 'bar')
2024-11-24 06:04:04.236 GMT [6736][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.015 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:04.326 GMT [2764][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:04.327 GMT [2764][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-11-24 06:04:04.327 GMT [2764][client backend] [[unknown]][2/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:04.332 GMT [2764][client backend] [015_stream.pl][2/2:0] LOG:  statement: CREATE TABLE test_tab_2 (a int)
2024-11-24 06:04:04.336 GMT [2764][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.013 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:04.672 GMT [4424][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:04.673 GMT [4424][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-11-24 06:04:04.673 GMT [4424][client backend] [[unknown]][3/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:04.676 GMT [4424][client backend] [015_stream.pl][3/2:0] LOG:  statement: CREATE PUBLICATION tap_pub FOR TABLE test_tab, test_tab_2
2024-11-24 06:04:04.681 GMT [4424][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.012 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:04.766 GMT [5668][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:04.767 GMT [5668][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-11-24 06:04:04.767 GMT [5668][walsender] [[unknown]][22/1:0] LOG:  replication connection authorized: user=SYSTEM application_name=tap_sub
2024-11-24 06:04:04.772 GMT [5668][walsender] [tap_sub][22/2:0] LOG:  statement: SELECT pg_catalog.set_config('search_path', '', false);
2024-11-24 06:04:04.773 GMT [5668][walsender] [tap_sub][22/3:0] LOG:  statement: SELECT t.pubname FROM
	 pg_catalog.pg_publication t WHERE
	 t.pubname IN ('tap_pub')
2024-11-24 06:04:04.775 GMT [5668][walsender] [tap_sub][22/4:0] LOG:  statement: SELECT DISTINCT n.nspname, c.relname, gpt.attrs
	       FROM pg_class c
	         JOIN pg_namespace n ON n.oid = c.relnamespace
	         JOIN ( SELECT (pg_get_publication_tables(VARIADIC array_agg(pubname::text))).*
	                FROM pg_publication
	                WHERE pubname IN ( 'tap_pub' )) AS gpt
	             ON gpt.relid = c.oid
	
2024-11-24 06:04:04.783 GMT [5668][walsender] [tap_sub][22/0:0] LOG:  received replication command: CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing')
2024-11-24 06:04:04.783 GMT [5668][walsender] [tap_sub][22/0:0] STATEMENT:  CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing')
2024-11-24 06:04:04.790 GMT [5668][walsender] [tap_sub][22/0:0] LOG:  logical decoding found consistent point at 0/1792E70
2024-11-24 06:04:04.790 GMT [5668][walsender] [tap_sub][22/0:0] DETAIL:  There are no running transactions.
2024-11-24 06:04:04.790 GMT [5668][walsender] [tap_sub][22/0:0] STATEMENT:  CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing')
2024-11-24 06:04:04.791 GMT [5668][walsender] [tap_sub][22/0:0] LOG:  released logical replication slot "tap_sub"
2024-11-24 06:04:04.791 GMT [5668][walsender] [tap_sub][22/0:0] STATEMENT:  CREATE_REPLICATION_SLOT "tap_sub" LOGICAL pgoutput (SNAPSHOT 'nothing')
2024-11-24 06:04:04.791 GMT [5668][walsender] [tap_sub][:0] LOG:  disconnection: session time: 0:00:00.028 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:04.831 GMT [2104][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:04.832 GMT [2104][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-11-24 06:04:04.832 GMT [2104][walsender] [[unknown]][23/1:0] LOG:  replication connection authorized: user=SYSTEM application_name=tap_sub
2024-11-24 06:04:04.851 GMT [2104][walsender] [tap_sub][23/2:0] LOG:  statement: SELECT pg_catalog.set_config('search_path', '', false);
2024-11-24 06:04:04.851 GMT [2104][walsender] [tap_sub][23/0:0] LOG:  received replication command: IDENTIFY_SYSTEM
2024-11-24 06:04:04.851 GMT [2104][walsender] [tap_sub][23/0:0] STATEMENT:  IDENTIFY_SYSTEM
2024-11-24 06:04:04.851 GMT [2104][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-11-24 06:04:04.851 GMT [2104][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-11-24 06:04:04.852 GMT [2104][walsender] [tap_sub][23/0:0] LOG:  acquired logical replication slot "tap_sub"
2024-11-24 06:04:04.852 GMT [2104][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-11-24 06:04:04.852 GMT [2104][walsender] [tap_sub][23/0:0] LOG:  starting logical decoding for slot "tap_sub"
2024-11-24 06:04:04.852 GMT [2104][walsender] [tap_sub][23/0:0] DETAIL:  Streaming transactions committing after 0/1792EA8, reading WAL from 0/1792E70.
2024-11-24 06:04:04.852 GMT [2104][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-11-24 06:04:04.852 GMT [2104][walsender] [tap_sub][23/0:0] LOG:  logical decoding found consistent point at 0/1792E70
2024-11-24 06:04:04.852 GMT [2104][walsender] [tap_sub][23/0:0] DETAIL:  There are no running transactions.
2024-11-24 06:04:04.852 GMT [2104][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-11-24 06:04:04.924 GMT [836][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:04.924 GMT [2668][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:04.925 GMT [836][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-11-24 06:04:04.925 GMT [836][walsender] [[unknown]][24/1:0] LOG:  replication connection authorized: user=SYSTEM application_name=tap_sub
2024-11-24 06:04:04.930 GMT [2668][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-11-24 06:04:04.930 GMT [2668][walsender] [[unknown]][25/1:0] LOG:  replication connection authorized: user=SYSTEM application_name=tap_sub
2024-11-24 06:04:04.933 GMT [836][walsender] [tap_sub][24/2:0] LOG:  statement: SELECT pg_catalog.set_config('search_path', '', false);
2024-11-24 06:04:04.934 GMT [836][walsender] [tap_sub][24/3:0] LOG:  statement: BEGIN READ ONLY ISOLATION LEVEL REPEATABLE READ
2024-11-24 06:04:04.934 GMT [836][walsender] [tap_sub][24/3:0] LOG:  received replication command: CREATE_REPLICATION_SLOT "pg_16398_sync_16394_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use')
2024-11-24 06:04:04.934 GMT [836][walsender] [tap_sub][24/3:0] STATEMENT:  CREATE_REPLICATION_SLOT "pg_16398_sync_16394_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use')
2024-11-24 06:04:04.936 GMT [2668][walsender] [tap_sub][25/2:0] LOG:  statement: SELECT pg_catalog.set_config('search_path', '', false);
2024-11-24 06:04:04.937 GMT [2668][walsender] [tap_sub][25/3:0] LOG:  statement: BEGIN READ ONLY ISOLATION LEVEL REPEATABLE READ
2024-11-24 06:04:04.937 GMT [2668][walsender] [tap_sub][25/3:0] LOG:  received replication command: CREATE_REPLICATION_SLOT "pg_16398_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use')
2024-11-24 06:04:04.937 GMT [2668][walsender] [tap_sub][25/3:0] STATEMENT:  CREATE_REPLICATION_SLOT "pg_16398_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use')
2024-11-24 06:04:04.942 GMT [2668][walsender] [tap_sub][25/3:0] LOG:  logical decoding found consistent point at 0/1792EE0
2024-11-24 06:04:04.942 GMT [2668][walsender] [tap_sub][25/3:0] DETAIL:  There are no running transactions.
2024-11-24 06:04:04.942 GMT [2668][walsender] [tap_sub][25/3:0] STATEMENT:  CREATE_REPLICATION_SLOT "pg_16398_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use')
2024-11-24 06:04:04.943 GMT [2668][walsender] [tap_sub][25/3:0] LOG:  released logical replication slot "pg_16398_sync_16384_7440720796304225096"
2024-11-24 06:04:04.943 GMT [2668][walsender] [tap_sub][25/3:0] STATEMENT:  CREATE_REPLICATION_SLOT "pg_16398_sync_16384_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use')
2024-11-24 06:04:04.943 GMT [2668][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-11-24 06:04:04.944 GMT [836][walsender] [tap_sub][24/3:0] LOG:  logical decoding found consistent point at 0/1792EA8
2024-11-24 06:04:04.944 GMT [836][walsender] [tap_sub][24/3:0] DETAIL:  There are no running transactions.
2024-11-24 06:04:04.944 GMT [836][walsender] [tap_sub][24/3:0] STATEMENT:  CREATE_REPLICATION_SLOT "pg_16398_sync_16394_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use')
2024-11-24 06:04:04.945 GMT [836][walsender] [tap_sub][24/3:0] LOG:  released logical replication slot "pg_16398_sync_16394_7440720796304225096"
2024-11-24 06:04:04.945 GMT [836][walsender] [tap_sub][24/3:0] STATEMENT:  CREATE_REPLICATION_SLOT "pg_16398_sync_16394_7440720796304225096" LOGICAL pgoutput (SNAPSHOT 'use')
2024-11-24 06:04:04.946 GMT [836][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-11-24 06:04:04.948 GMT [2668][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-11-24 06:04:04.952 GMT [836][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-11-24 06:04:04.952 GMT [2668][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-11-24 06:04:04.957 GMT [836][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-11-24 06:04:04.959 GMT [836][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-11-24 06:04:04.959 GMT [2668][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-11-24 06:04:04.961 GMT [2668][walsender] [tap_sub][25/3:0] LOG:  statement: COPY public.test_tab (a, b) TO STDOUT
2024-11-24 06:04:04.961 GMT [836][walsender] [tap_sub][24/3:0] LOG:  statement: COPY public.test_tab_2 (a) TO STDOUT
2024-11-24 06:04:04.961 GMT [836][walsender] [tap_sub][24/3:0] LOG:  statement: COMMIT
2024-11-24 06:04:04.962 GMT [836][walsender] [tap_sub][24/0:0] LOG:  received replication command: START_REPLICATION SLOT "pg_16398_sync_16394_7440720796304225096" LOGICAL 0/1792EE0 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"')
2024-11-24 06:04:04.962 GMT [836][walsender] [tap_sub][24/0:0] STATEMENT:  START_REPLICATION SLOT "pg_16398_sync_16394_7440720796304225096" LOGICAL 0/1792EE0 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"')
2024-11-24 06:04:04.962 GMT [836][walsender] [tap_sub][24/0:0] LOG:  acquired logical replication slot "pg_16398_sync_16394_7440720796304225096"
2024-11-24 06:04:04.962 GMT [836][walsender] [tap_sub][24/0:0] STATEMENT:  START_REPLICATION SLOT "pg_16398_sync_16394_7440720796304225096" LOGICAL 0/1792EE0 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"')
2024-11-24 06:04:04.962 GMT [2668][walsender] [tap_sub][25/3:0] LOG:  statement: COMMIT
2024-11-24 06:04:04.962 GMT [836][walsender] [tap_sub][24/0:0] LOG:  starting logical decoding for slot "pg_16398_sync_16394_7440720796304225096"
2024-11-24 06:04:04.962 GMT [836][walsender] [tap_sub][24/0:0] DETAIL:  Streaming transactions committing after 0/1792EE0, reading WAL from 0/1792EA8.
2024-11-24 06:04:04.962 GMT [836][walsender] [tap_sub][24/0:0] STATEMENT:  START_REPLICATION SLOT "pg_16398_sync_16394_7440720796304225096" LOGICAL 0/1792EE0 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"')
2024-11-24 06:04:04.962 GMT [836][walsender] [tap_sub][24/0:0] LOG:  logical decoding found consistent point at 0/1792EA8
2024-11-24 06:04:04.962 GMT [836][walsender] [tap_sub][24/0:0] DETAIL:  There are no running transactions.
2024-11-24 06:04:04.962 GMT [836][walsender] [tap_sub][24/0:0] STATEMENT:  START_REPLICATION SLOT "pg_16398_sync_16394_7440720796304225096" LOGICAL 0/1792EE0 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"')
2024-11-24 06:04:04.963 GMT [836][walsender] [tap_sub][24/0:0] LOG:  released logical replication slot "pg_16398_sync_16394_7440720796304225096"
2024-11-24 06:04:04.963 GMT [836][walsender] [tap_sub][24/0:0] STATEMENT:  START_REPLICATION SLOT "pg_16398_sync_16394_7440720796304225096" LOGICAL 0/1792EE0 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"')
2024-11-24 06:04:04.963 GMT [836][walsender] [tap_sub][24/0:0] LOG:  received replication command: DROP_REPLICATION_SLOT pg_16398_sync_16394_7440720796304225096 WAIT
2024-11-24 06:04:04.963 GMT [836][walsender] [tap_sub][24/0:0] STATEMENT:  DROP_REPLICATION_SLOT pg_16398_sync_16394_7440720796304225096 WAIT
2024-11-24 06:04:04.963 GMT [836][walsender] [tap_sub][24/0:0] LOG:  acquired logical replication slot "pg_16398_sync_16394_7440720796304225096"
2024-11-24 06:04:04.963 GMT [836][walsender] [tap_sub][24/0:0] STATEMENT:  DROP_REPLICATION_SLOT pg_16398_sync_16394_7440720796304225096 WAIT
2024-11-24 06:04:04.964 GMT [836][walsender] [tap_sub][:0] LOG:  disconnection: session time: 0:00:00.046 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:04.970 GMT [2668][walsender] [tap_sub][25/0:0] LOG:  received replication command: START_REPLICATION SLOT "pg_16398_sync_16384_7440720796304225096" LOGICAL 0/1792F18 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"')
2024-11-24 06:04:04.970 GMT [2668][walsender] [tap_sub][25/0:0] STATEMENT:  START_REPLICATION SLOT "pg_16398_sync_16384_7440720796304225096" LOGICAL 0/1792F18 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"')
2024-11-24 06:04:04.970 GMT [2668][walsender] [tap_sub][25/0:0] LOG:  acquired logical replication slot "pg_16398_sync_16384_7440720796304225096"
2024-11-24 06:04:04.970 GMT [2668][walsender] [tap_sub][25/0:0] STATEMENT:  START_REPLICATION SLOT "pg_16398_sync_16384_7440720796304225096" LOGICAL 0/1792F18 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"')
2024-11-24 06:04:04.971 GMT [2668][walsender] [tap_sub][25/0:0] LOG:  starting logical decoding for slot "pg_16398_sync_16384_7440720796304225096"
2024-11-24 06:04:04.971 GMT [2668][walsender] [tap_sub][25/0:0] DETAIL:  Streaming transactions committing after 0/1792F18, reading WAL from 0/1792EE0.
2024-11-24 06:04:04.971 GMT [2668][walsender] [tap_sub][25/0:0] STATEMENT:  START_REPLICATION SLOT "pg_16398_sync_16384_7440720796304225096" LOGICAL 0/1792F18 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"')
2024-11-24 06:04:04.971 GMT [2668][walsender] [tap_sub][25/0:0] LOG:  logical decoding found consistent point at 0/1792EE0
2024-11-24 06:04:04.971 GMT [2668][walsender] [tap_sub][25/0:0] DETAIL:  There are no running transactions.
2024-11-24 06:04:04.971 GMT [2668][walsender] [tap_sub][25/0:0] STATEMENT:  START_REPLICATION SLOT "pg_16398_sync_16384_7440720796304225096" LOGICAL 0/1792F18 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"')
2024-11-24 06:04:04.971 GMT [2668][walsender] [tap_sub][25/0:0] LOG:  released logical replication slot "pg_16398_sync_16384_7440720796304225096"
2024-11-24 06:04:04.971 GMT [2668][walsender] [tap_sub][25/0:0] STATEMENT:  START_REPLICATION SLOT "pg_16398_sync_16384_7440720796304225096" LOGICAL 0/1792F18 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"')
2024-11-24 06:04:04.971 GMT [2668][walsender] [tap_sub][25/0:0] LOG:  received replication command: DROP_REPLICATION_SLOT pg_16398_sync_16384_7440720796304225096 WAIT
2024-11-24 06:04:04.971 GMT [2668][walsender] [tap_sub][25/0:0] STATEMENT:  DROP_REPLICATION_SLOT pg_16398_sync_16384_7440720796304225096 WAIT
2024-11-24 06:04:04.971 GMT [2668][walsender] [tap_sub][25/0:0] LOG:  acquired logical replication slot "pg_16398_sync_16384_7440720796304225096"
2024-11-24 06:04:04.971 GMT [2668][walsender] [tap_sub][25/0:0] STATEMENT:  DROP_REPLICATION_SLOT pg_16398_sync_16384_7440720796304225096 WAIT
2024-11-24 06:04:04.972 GMT [2668][walsender] [tap_sub][:0] LOG:  disconnection: session time: 0:00:00.053 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:05.169 GMT [4232][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:05.170 GMT [4232][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-11-24 06:04:05.170 GMT [4232][client backend] [[unknown]][4/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:05.174 GMT [4232][client backend] [015_stream.pl][4/2:0] LOG:  statement: SELECT pg_is_in_recovery()
2024-11-24 06:04:05.184 GMT [4232][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.018 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:05.256 GMT [4144][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:05.257 GMT [4144][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-11-24 06:04:05.257 GMT [4144][client backend] [[unknown]][5/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:05.260 GMT [4144][client backend] [015_stream.pl][5/2:0] LOG:  statement: SELECT pg_current_wal_lsn()
2024-11-24 06:04:05.312 GMT [4144][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.059 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:05.356 GMT [1796][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:05.357 GMT [1796][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-11-24 06:04:05.357 GMT [1796][client backend] [[unknown]][6/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:05.360 GMT [1796][client backend] [015_stream.pl][6/2:0] LOG:  statement: SELECT '0/1792F18' <= replay_lsn AND state = 'streaming'
	         FROM pg_catalog.pg_stat_replication
	         WHERE application_name IN ('tap_sub', 'walreceiver')
2024-11-24 06:04:05.368 GMT [1796][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.015 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:05.548 GMT [4796][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:05.549 GMT [4796][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-11-24 06:04:05.549 GMT [4796][client backend] [[unknown]][7/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:05.673 GMT [4796][client backend] [015_stream.pl][7/2:0] LOG:  statement: BEGIN;
2024-11-24 06:04:05.673 GMT [4796][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-11-24 06:04:05.719 GMT [4796][client backend] [015_stream.pl][7/2:750] LOG:  statement: UPDATE test_tab SET b = sha256(b) WHERE mod(a,2) = 0;
2024-11-24 06:04:05.766 GMT [4796][client backend] [015_stream.pl][7/2:750] LOG:  statement: DELETE FROM test_tab WHERE mod(a,3) = 0;
2024-11-24 06:04:05.771 GMT [4796][client backend] [015_stream.pl][7/2:750] LOG:  statement: ;
2024-11-24 06:04:05.820 GMT [5500][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:05.821 GMT [5500][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-11-24 06:04:05.821 GMT [5500][client backend] [[unknown]][8/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:05.834 GMT [5500][client backend] [015_stream.pl][8/2:0] LOG:  statement: BEGIN;
2024-11-24 06:04:05.835 GMT [5500][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-11-24 06:04:05.881 GMT [5500][client backend] [015_stream.pl][8/2:751] LOG:  statement: DELETE FROM test_tab WHERE a > 5000;
2024-11-24 06:04:05.894 GMT [5500][client backend] [015_stream.pl][8/2:751] LOG:  statement: COMMIT;
2024-11-24 06:04:05.895 GMT [5500][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.080 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:05.936 GMT [4796][client backend] [015_stream.pl][7/2:750] LOG:  statement: COMMIT
	;
2024-11-24 06:04:05.937 GMT [4796][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.392 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:06.009 GMT [3920][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:06.010 GMT [3920][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-11-24 06:04:06.010 GMT [3920][client backend] [[unknown]][9/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:06.015 GMT [3920][client backend] [015_stream.pl][9/2:0] LOG:  statement: SELECT pg_is_in_recovery()
2024-11-24 06:04:06.017 GMT [3920][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.013 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:06.097 GMT [3748][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:06.099 GMT [3748][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-11-24 06:04:06.099 GMT [3748][client backend] [[unknown]][0/3:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:06.102 GMT [3748][client backend] [015_stream.pl][0/4:0] LOG:  statement: SELECT pg_current_wal_lsn()
2024-11-24 06:04:06.103 GMT [3748][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.009 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:06.154 GMT [4144][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:06.155 GMT [4144][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-11-24 06:04:06.156 GMT [4144][client backend] [[unknown]][1/3:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:06.158 GMT [4144][client backend] [015_stream.pl][1/4:0] LOG:  statement: SELECT '0/1A22050' <= replay_lsn AND state = 'streaming'
	         FROM pg_catalog.pg_stat_replication
	         WHERE application_name IN ('tap_sub', 'walreceiver')
2024-11-24 06:04:06.167 GMT [4144][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.015 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:06.355 GMT [2880][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:06.356 GMT [2880][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-11-24 06:04:06.356 GMT [2880][client backend] [[unknown]][2/3:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:06.359 GMT [2880][client backend] [015_stream.pl][2/4:0] LOG:  statement: SELECT '0/1A22050' <= replay_lsn AND state = 'streaming'
	         FROM pg_catalog.pg_stat_replication
	         WHERE application_name IN ('tap_sub', 'walreceiver')
2024-11-24 06:04:06.365 GMT [2880][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.014 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:06.566 GMT [3240][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:06.567 GMT [3240][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-11-24 06:04:06.567 GMT [3240][client backend] [[unknown]][3/3:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:06.570 GMT [3240][client backend] [015_stream.pl][3/4:0] LOG:  statement: SELECT '0/1A22050' <= replay_lsn AND state = 'streaming'
	         FROM pg_catalog.pg_stat_replication
	         WHERE application_name IN ('tap_sub', 'walreceiver')
2024-11-24 06:04:06.688 GMT [3240][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.125 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:06.867 GMT [2104][walsender] [tap_sub][23/0:0] LOG:  released logical replication slot "tap_sub"
2024-11-24 06:04:06.867 GMT [2104][walsender] [tap_sub][:0] LOG:  disconnection: session time: 0:00:02.039 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:06.923 GMT [3920][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:06.925 GMT [3920][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-11-24 06:04:06.925 GMT [3920][walsender] [[unknown]][26/1:0] LOG:  replication connection authorized: user=SYSTEM application_name=tap_sub
2024-11-24 06:04:06.930 GMT [3920][walsender] [tap_sub][26/2:0] LOG:  statement: SELECT pg_catalog.set_config('search_path', '', false);
2024-11-24 06:04:06.930 GMT [3920][walsender] [tap_sub][26/0:0] LOG:  received replication command: IDENTIFY_SYSTEM
2024-11-24 06:04:06.930 GMT [3920][walsender] [tap_sub][26/0:0] STATEMENT:  IDENTIFY_SYSTEM
2024-11-24 06:04:06.930 GMT [3920][walsender] [tap_sub][26/0:0] LOG:  received replication command: START_REPLICATION SLOT "tap_sub" LOGICAL 0/1A22050 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"', binary 'true')
2024-11-24 06:04:06.930 GMT [3920][walsender] [tap_sub][26/0:0] STATEMENT:  START_REPLICATION SLOT "tap_sub" LOGICAL 0/1A22050 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"', binary 'true')
2024-11-24 06:04:06.930 GMT [3920][walsender] [tap_sub][26/0:0] LOG:  acquired logical replication slot "tap_sub"
2024-11-24 06:04:06.930 GMT [3920][walsender] [tap_sub][26/0:0] STATEMENT:  START_REPLICATION SLOT "tap_sub" LOGICAL 0/1A22050 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"', binary 'true')
2024-11-24 06:04:06.931 GMT [3920][walsender] [tap_sub][26/0:0] LOG:  starting logical decoding for slot "tap_sub"
2024-11-24 06:04:06.931 GMT [3920][walsender] [tap_sub][26/0:0] DETAIL:  Streaming transactions committing after 0/1A22050, reading WAL from 0/1792EE0.
2024-11-24 06:04:06.931 GMT [3920][walsender] [tap_sub][26/0:0] STATEMENT:  START_REPLICATION SLOT "tap_sub" LOGICAL 0/1A22050 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"', binary 'true')
2024-11-24 06:04:06.931 GMT [3920][walsender] [tap_sub][26/0:0] LOG:  logical decoding found consistent point at 0/1792EE0
2024-11-24 06:04:06.931 GMT [3920][walsender] [tap_sub][26/0:0] DETAIL:  There are no running transactions.
2024-11-24 06:04:06.931 GMT [3920][walsender] [tap_sub][26/0:0] STATEMENT:  START_REPLICATION SLOT "tap_sub" LOGICAL 0/1A22050 (proto_version '4', streaming 'on', origin 'any', publication_names '"tap_pub"', binary 'true')
2024-11-24 06:04:06.962 GMT [2088][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:06.963 GMT [2088][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-11-24 06:04:06.963 GMT [2088][client backend] [[unknown]][4/3:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:06.966 GMT [2088][client backend] [015_stream.pl][4/4:0] LOG:  statement: BEGIN;
2024-11-24 06:04:06.966 GMT [2088][client backend] [015_stream.pl][4/4:0] LOG:  statement: INSERT INTO test_tab SELECT i, sha256(i::text::bytea) FROM generate_series(5001, 10000) s(i);
2024-11-24 06:04:07.023 GMT [2088][client backend] [015_stream.pl][4/4:752] LOG:  statement: UPDATE test_tab SET b = sha256(b) WHERE mod(a,2) = 0;
2024-11-24 06:04:07.093 GMT [2088][client backend] [015_stream.pl][4/4:752] LOG:  statement: DELETE FROM test_tab WHERE mod(a,3) = 0;
2024-11-24 06:04:07.099 GMT [2088][client backend] [015_stream.pl][4/4:752] LOG:  statement: COMMIT;
2024-11-24 06:04:07.099 GMT [2088][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.140 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:07.253 GMT [5936][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:07.254 GMT [5936][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-11-24 06:04:07.254 GMT [5936][client backend] [[unknown]][5/3:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:07.258 GMT [5936][client backend] [015_stream.pl][5/4:0] LOG:  statement: SELECT pg_is_in_recovery()
2024-11-24 06:04:07.261 GMT [5936][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.011 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:07.351 GMT [3168][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:07.359 GMT [3168][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-11-24 06:04:07.359 GMT [3168][client backend] [[unknown]][6/3:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:07.368 GMT [3168][client backend] [015_stream.pl][6/4:0] LOG:  statement: SELECT pg_current_wal_lsn()
2024-11-24 06:04:07.370 GMT [3168][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.022 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:07.458 GMT [872][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:07.459 GMT [872][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-11-24 06:04:07.459 GMT [872][client backend] [[unknown]][8/3:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:07.462 GMT [872][client backend] [015_stream.pl][8/4:0] LOG:  statement: SELECT '0/1BE7EA8' <= replay_lsn AND state = 'streaming'
	         FROM pg_catalog.pg_stat_replication
	         WHERE application_name IN ('tap_sub', 'walreceiver')
2024-11-24 06:04:07.470 GMT [872][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.014 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:07.741 GMT [5140][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:07.742 GMT [5140][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-11-24 06:04:07.742 GMT [5140][client backend] [[unknown]][7/3:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:07.745 GMT [5140][client backend] [015_stream.pl][7/4:0] LOG:  statement: UPDATE test_tab SET b = sha256(a::text::bytea)
2024-11-24 06:04:07.809 GMT [5140][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.071 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:07.978 GMT [5256][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:07.981 GMT [5256][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-11-24 06:04:07.981 GMT [5256][client backend] [[unknown]][9/3:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:07.985 GMT [5256][client backend] [015_stream.pl][9/4:0] LOG:  statement: SELECT pg_is_in_recovery()
2024-11-24 06:04:07.998 GMT [5256][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.023 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:08.104 GMT [1192][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:08.107 GMT [1192][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-11-24 06:04:08.107 GMT [1192][client backend] [[unknown]][0/5:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:08.110 GMT [1192][client backend] [015_stream.pl][0/6:0] LOG:  statement: SELECT pg_current_wal_lsn()
2024-11-24 06:04:08.113 GMT [1192][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.011 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:08.210 GMT [4652][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:08.211 GMT [4652][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-11-24 06:04:08.211 GMT [4652][client backend] [[unknown]][1/5:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:08.214 GMT [4652][client backend] [015_stream.pl][1/6:0] LOG:  statement: SELECT '0/1CCD160' <= replay_lsn AND state = 'streaming'
	         FROM pg_catalog.pg_stat_replication
	         WHERE application_name IN ('tap_sub', 'walreceiver')
2024-11-24 06:04:08.223 GMT [4652][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.015 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:08.349 GMT [5524][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:08.351 GMT [5524][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-11-24 06:04:08.351 GMT [5524][client backend] [[unknown]][2/5:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:08.353 GMT [5524][client backend] [015_stream.pl][2/6:0] LOG:  statement: DELETE FROM test_tab WHERE (a > 2)
2024-11-24 06:04:08.375 GMT [5524][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.029 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:08.432 GMT [6044][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:08.434 GMT [6044][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-11-24 06:04:08.434 GMT [6044][client backend] [[unknown]][3/5:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:08.438 GMT [6044][client backend] [015_stream.pl][3/6:0] LOG:  statement: SELECT pg_is_in_recovery()
2024-11-24 06:04:08.441 GMT [6044][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.011 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:08.543 GMT [5004][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:08.544 GMT [5004][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-11-24 06:04:08.544 GMT [5004][client backend] [[unknown]][4/5:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:08.547 GMT [5004][client backend] [015_stream.pl][4/6:0] LOG:  statement: SELECT pg_current_wal_lsn()
2024-11-24 06:04:08.549 GMT [5004][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.010 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:08.595 GMT [5468][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:08.597 GMT [5468][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-11-24 06:04:08.597 GMT [5468][client backend] [[unknown]][5/5:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:08.600 GMT [5468][client backend] [015_stream.pl][5/6:0] LOG:  statement: SELECT '0/1D37B08' <= replay_lsn AND state = 'streaming'
	         FROM pg_catalog.pg_stat_replication
	         WHERE application_name IN ('tap_sub', 'walreceiver')
2024-11-24 06:04:08.610 GMT [5468][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.017 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:08.663 GMT [4424][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:08.664 GMT [4424][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-11-24 06:04:08.664 GMT [4424][client backend] [[unknown]][6/5:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:08.667 GMT [4424][client backend] [015_stream.pl][6/6:0] LOG:  statement: SELECT pid FROM pg_stat_replication WHERE application_name = 'tap_sub' AND state = 'streaming';
2024-11-24 06:04:08.673 GMT [4424][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.013 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:08.752 GMT [3920][walsender] [tap_sub][26/0:0] LOG:  released logical replication slot "tap_sub"
2024-11-24 06:04:08.752 GMT [3920][walsender] [tap_sub][:0] LOG:  disconnection: session time: 0:00:01.837 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:08.797 GMT [5544][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:08.798 GMT [5544][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-11-24 06:04:08.798 GMT [5544][walsender] [[unknown]][27/1:0] LOG:  replication connection authorized: user=SYSTEM application_name=tap_sub
2024-11-24 06:04:08.802 GMT [5544][walsender] [tap_sub][27/2:0] LOG:  statement: SELECT pg_catalog.set_config('search_path', '', false);
2024-11-24 06:04:08.802 GMT [5544][walsender] [tap_sub][27/0:0] LOG:  received replication command: IDENTIFY_SYSTEM
2024-11-24 06:04:08.802 GMT [5544][walsender] [tap_sub][27/0:0] STATEMENT:  IDENTIFY_SYSTEM
2024-11-24 06:04:08.802 GMT [5544][walsender] [tap_sub][27/0:0] LOG:  received replication command: START_REPLICATION SLOT "tap_sub" LOGICAL 0/1D37B08 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"')
2024-11-24 06:04:08.802 GMT [5544][walsender] [tap_sub][27/0:0] STATEMENT:  START_REPLICATION SLOT "tap_sub" LOGICAL 0/1D37B08 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"')
2024-11-24 06:04:08.802 GMT [5544][walsender] [tap_sub][27/0:0] LOG:  acquired logical replication slot "tap_sub"
2024-11-24 06:04:08.802 GMT [5544][walsender] [tap_sub][27/0:0] STATEMENT:  START_REPLICATION SLOT "tap_sub" LOGICAL 0/1D37B08 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"')
2024-11-24 06:04:08.803 GMT [5544][walsender] [tap_sub][27/0:0] LOG:  starting logical decoding for slot "tap_sub"
2024-11-24 06:04:08.803 GMT [5544][walsender] [tap_sub][27/0:0] DETAIL:  Streaming transactions committing after 0/1D37B08, reading WAL from 0/1792EE0.
2024-11-24 06:04:08.803 GMT [5544][walsender] [tap_sub][27/0:0] STATEMENT:  START_REPLICATION SLOT "tap_sub" LOGICAL 0/1D37B08 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"')
2024-11-24 06:04:08.803 GMT [5544][walsender] [tap_sub][27/0:0] LOG:  logical decoding found consistent point at 0/1792EE0
2024-11-24 06:04:08.803 GMT [5544][walsender] [tap_sub][27/0:0] DETAIL:  There are no running transactions.
2024-11-24 06:04:08.803 GMT [5544][walsender] [tap_sub][27/0:0] STATEMENT:  START_REPLICATION SLOT "tap_sub" LOGICAL 0/1D37B08 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"')
2024-11-24 06:04:08.810 GMT [7012][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:08.812 GMT [7012][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-11-24 06:04:08.812 GMT [7012][client backend] [[unknown]][8/5:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:08.819 GMT [7012][client backend] [015_stream.pl][8/6:0] LOG:  statement: SELECT pid != 3920 FROM pg_stat_replication WHERE application_name = 'tap_sub' AND state = 'streaming';
2024-11-24 06:04:08.824 GMT [7012][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.016 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:09.037 GMT [5040][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:09.039 GMT [5040][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-11-24 06:04:09.039 GMT [5040][client backend] [[unknown]][7/5:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:09.041 GMT [5040][client backend] [015_stream.pl][7/6:0] LOG:  statement: SELECT pid != 3920 FROM pg_stat_replication WHERE application_name = 'tap_sub' AND state = 'streaming';
2024-11-24 06:04:09.045 GMT [5040][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.011 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:09.218 GMT [4748][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:09.219 GMT [4748][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-11-24 06:04:09.219 GMT [4748][client backend] [[unknown]][9/5:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:09.221 GMT [4748][client backend] [015_stream.pl][9/6:0] LOG:  statement: SELECT pid != 3920 FROM pg_stat_replication WHERE application_name = 'tap_sub' AND state = 'streaming';
2024-11-24 06:04:09.228 GMT [4748][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.014 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:09.430 GMT [3476][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:09.432 GMT [3476][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-11-24 06:04:09.432 GMT [3476][client backend] [[unknown]][0/7:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:09.516 GMT [3476][client backend] [015_stream.pl][0/8:0] LOG:  statement: BEGIN;
2024-11-24 06:04:09.516 GMT [3476][client backend] [015_stream.pl][0/8:0] LOG:  statement: INSERT INTO test_tab SELECT i, sha256(i::text::bytea) FROM generate_series(3, 5000) s(i);
2024-11-24 06:04:09.581 GMT [3476][client backend] [015_stream.pl][0/8:755] LOG:  statement: UPDATE test_tab SET b = sha256(b) WHERE mod(a,2) = 0;
2024-11-24 06:04:09.621 GMT [3476][client backend] [015_stream.pl][0/8:755] LOG:  statement: DELETE FROM test_tab WHERE mod(a,3) = 0;
2024-11-24 06:04:09.628 GMT [3476][client backend] [015_stream.pl][0/8:755] LOG:  statement: ;
2024-11-24 06:04:09.689 GMT [1756][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:09.690 GMT [1756][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-11-24 06:04:09.690 GMT [1756][client backend] [[unknown]][1/7:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:09.701 GMT [1756][client backend] [015_stream.pl][1/8:0] LOG:  statement: BEGIN;
2024-11-24 06:04:09.701 GMT [1756][client backend] [015_stream.pl][1/8:0] LOG:  statement: INSERT INTO test_tab SELECT i, sha256(i::text::bytea) FROM generate_series(5001, 9999) s(i);
2024-11-24 06:04:09.766 GMT [1756][client backend] [015_stream.pl][1/8:756] LOG:  statement: DELETE FROM test_tab WHERE a > 5000;
2024-11-24 06:04:09.778 GMT [1756][client backend] [015_stream.pl][1/8:756] LOG:  statement: COMMIT;
2024-11-24 06:04:09.779 GMT [1756][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.093 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:09.807 GMT [3476][client backend] [015_stream.pl][0/8:755] LOG:  statement: COMMIT
	;
2024-11-24 06:04:09.808 GMT [3476][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.380 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:09.917 GMT [1212][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:09.919 GMT [1212][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-11-24 06:04:09.919 GMT [1212][client backend] [[unknown]][2/7:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:09.923 GMT [1212][client backend] [015_stream.pl][2/8:0] LOG:  statement: SELECT pg_is_in_recovery()
2024-11-24 06:04:09.925 GMT [1212][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.010 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:10.012 GMT [4256][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:10.013 GMT [4256][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-11-24 06:04:10.013 GMT [4256][client backend] [[unknown]][3/7:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:10.016 GMT [4256][client backend] [015_stream.pl][3/8:0] LOG:  statement: SELECT pg_current_wal_lsn()
2024-11-24 06:04:10.018 GMT [4256][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.009 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:10.079 GMT [2716][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:10.080 GMT [2716][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-11-24 06:04:10.080 GMT [2716][client backend] [[unknown]][4/7:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:10.083 GMT [2716][client backend] [015_stream.pl][4/8:0] LOG:  statement: SELECT '0/1FBE058' <= replay_lsn AND state = 'streaming'
	         FROM pg_catalog.pg_stat_replication
	         WHERE application_name IN ('tap_sub', 'walreceiver')
2024-11-24 06:04:10.091 GMT [2716][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.014 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:10.259 GMT [5852][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:10.261 GMT [5852][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-11-24 06:04:10.261 GMT [5852][client backend] [[unknown]][5/7:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:10.263 GMT [5852][client backend] [015_stream.pl][5/8:0] LOG:  statement: SELECT '0/1FBE058' <= replay_lsn AND state = 'streaming'
	         FROM pg_catalog.pg_stat_replication
	         WHERE application_name IN ('tap_sub', 'walreceiver')
2024-11-24 06:04:10.270 GMT [5852][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.013 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:10.387 GMT [5544][walsender] [tap_sub][27/0:0] LOG:  released logical replication slot "tap_sub"
2024-11-24 06:04:10.387 GMT [5544][walsender] [tap_sub][:0] LOG:  disconnection: session time: 0:00:01.593 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:10.426 GMT [1784][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:10.427 GMT [1784][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-11-24 06:04:10.427 GMT [1784][walsender] [[unknown]][28/1:0] LOG:  replication connection authorized: user=SYSTEM application_name=tap_sub
2024-11-24 06:04:10.429 GMT [1784][walsender] [tap_sub][28/2:0] LOG:  statement: SELECT pg_catalog.set_config('search_path', '', false);
2024-11-24 06:04:10.430 GMT [1784][walsender] [tap_sub][28/0:0] LOG:  received replication command: IDENTIFY_SYSTEM
2024-11-24 06:04:10.430 GMT [1784][walsender] [tap_sub][28/0:0] STATEMENT:  IDENTIFY_SYSTEM
2024-11-24 06:04:10.430 GMT [1784][walsender] [tap_sub][28/0:0] LOG:  received replication command: START_REPLICATION SLOT "tap_sub" LOGICAL 0/1FBE058 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true')
2024-11-24 06:04:10.430 GMT [1784][walsender] [tap_sub][28/0:0] STATEMENT:  START_REPLICATION SLOT "tap_sub" LOGICAL 0/1FBE058 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true')
2024-11-24 06:04:10.430 GMT [1784][walsender] [tap_sub][28/0:0] LOG:  acquired logical replication slot "tap_sub"
2024-11-24 06:04:10.430 GMT [1784][walsender] [tap_sub][28/0:0] STATEMENT:  START_REPLICATION SLOT "tap_sub" LOGICAL 0/1FBE058 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true')
2024-11-24 06:04:10.430 GMT [1784][walsender] [tap_sub][28/0:0] LOG:  starting logical decoding for slot "tap_sub"
2024-11-24 06:04:10.430 GMT [1784][walsender] [tap_sub][28/0:0] DETAIL:  Streaming transactions committing after 0/1FBE058, reading WAL from 0/1792EE0.
2024-11-24 06:04:10.430 GMT [1784][walsender] [tap_sub][28/0:0] STATEMENT:  START_REPLICATION SLOT "tap_sub" LOGICAL 0/1FBE058 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true')
2024-11-24 06:04:10.431 GMT [1784][walsender] [tap_sub][28/0:0] LOG:  logical decoding found consistent point at 0/1792EE0
2024-11-24 06:04:10.431 GMT [1784][walsender] [tap_sub][28/0:0] DETAIL:  There are no running transactions.
2024-11-24 06:04:10.431 GMT [1784][walsender] [tap_sub][28/0:0] STATEMENT:  START_REPLICATION SLOT "tap_sub" LOGICAL 0/1FBE058 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true')
2024-11-24 06:04:10.446 GMT [5680][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:10.447 GMT [5680][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-11-24 06:04:10.447 GMT [5680][client backend] [[unknown]][6/7:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:10.449 GMT [5680][client backend] [015_stream.pl][6/8:0] LOG:  statement: BEGIN;
2024-11-24 06:04:10.450 GMT [5680][client backend] [015_stream.pl][6/8:0] LOG:  statement: INSERT INTO test_tab SELECT i, sha256(i::text::bytea) FROM generate_series(5001, 10000) s(i);
2024-11-24 06:04:10.521 GMT [5680][client backend] [015_stream.pl][6/8:757] LOG:  statement: UPDATE test_tab SET b = sha256(b) WHERE mod(a,2) = 0;
2024-11-24 06:04:10.583 GMT [5680][client backend] [015_stream.pl][6/8:757] LOG:  statement: DELETE FROM test_tab WHERE mod(a,3) = 0;
2024-11-24 06:04:10.592 GMT [5680][client backend] [015_stream.pl][6/8:757] LOG:  statement: COMMIT;
2024-11-24 06:04:10.593 GMT [5680][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.150 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:10.785 GMT [1052][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:10.787 GMT [1052][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-11-24 06:04:10.787 GMT [1052][client backend] [[unknown]][8/7:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:10.798 GMT [1052][client backend] [015_stream.pl][8/8:0] LOG:  statement: SELECT pg_is_in_recovery()
2024-11-24 06:04:10.801 GMT [1052][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.021 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:11.008 GMT [5996][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:11.009 GMT [5996][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-11-24 06:04:11.009 GMT [5996][client backend] [[unknown]][7/7:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:11.011 GMT [5996][client backend] [015_stream.pl][7/8:0] LOG:  statement: SELECT pg_current_wal_lsn()
2024-11-24 06:04:11.014 GMT [5996][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.008 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:11.228 GMT [3504][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:11.229 GMT [3504][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-11-24 06:04:11.229 GMT [3504][client backend] [[unknown]][9/7:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:11.232 GMT [3504][client backend] [015_stream.pl][9/8:0] LOG:  statement: SELECT '0/2177990' <= replay_lsn AND state = 'streaming'
	         FROM pg_catalog.pg_stat_replication
	         WHERE application_name IN ('tap_sub', 'walreceiver')
2024-11-24 06:04:11.242 GMT [3504][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.016 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:11.473 GMT [5000][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:11.474 GMT [5000][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-11-24 06:04:11.474 GMT [5000][client backend] [[unknown]][1/9:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:11.477 GMT [5000][client backend] [015_stream.pl][1/10:0] LOG:  statement: SELECT '0/2177990' <= replay_lsn AND state = 'streaming'
	         FROM pg_catalog.pg_stat_replication
	         WHERE application_name IN ('tap_sub', 'walreceiver')
2024-11-24 06:04:11.485 GMT [5000][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.015 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:11.904 GMT [6348][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:11.905 GMT [6348][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-11-24 06:04:11.905 GMT [6348][client backend] [[unknown]][0/9:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:11.908 GMT [6348][client backend] [015_stream.pl][0/10:0] LOG:  statement: UPDATE test_tab SET b = sha256(a::text::bytea)
2024-11-24 06:04:11.973 GMT [6348][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.071 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:12.158 GMT [1740][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:12.159 GMT [1740][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-11-24 06:04:12.159 GMT [1740][client backend] [[unknown]][2/9:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:12.164 GMT [1740][client backend] [015_stream.pl][2/10:0] LOG:  statement: SELECT pg_is_in_recovery()
2024-11-24 06:04:12.170 GMT [1740][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.015 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:12.227 GMT [1840][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:12.228 GMT [1840][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-11-24 06:04:12.228 GMT [1840][client backend] [[unknown]][3/9:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:12.231 GMT [1840][client backend] [015_stream.pl][3/10:0] LOG:  statement: SELECT pg_current_wal_lsn()
2024-11-24 06:04:12.233 GMT [1840][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.009 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:12.312 GMT [6100][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:12.314 GMT [6100][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-11-24 06:04:12.314 GMT [6100][client backend] [[unknown]][4/9:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:12.327 GMT [6100][client backend] [015_stream.pl][4/10:0] LOG:  statement: SELECT '0/225DAC8' <= replay_lsn AND state = 'streaming'
	         FROM pg_catalog.pg_stat_replication
	         WHERE application_name IN ('tap_sub', 'walreceiver')
2024-11-24 06:04:12.336 GMT [6100][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.030 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:12.525 GMT [4300][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:12.526 GMT [4300][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-11-24 06:04:12.526 GMT [4300][client backend] [[unknown]][5/9:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:12.529 GMT [4300][client backend] [015_stream.pl][5/10:0] LOG:  statement: DELETE FROM test_tab WHERE (a > 2)
2024-11-24 06:04:12.550 GMT [4300][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.028 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:12.715 GMT [416][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:12.717 GMT [416][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-11-24 06:04:12.717 GMT [416][client backend] [[unknown]][6/9:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:12.721 GMT [416][client backend] [015_stream.pl][6/10:0] LOG:  statement: SELECT pg_is_in_recovery()
2024-11-24 06:04:12.725 GMT [416][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.012 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:12.839 GMT [3432][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:12.841 GMT [3432][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-11-24 06:04:12.841 GMT [3432][client backend] [[unknown]][8/9:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:12.843 GMT [3432][client backend] [015_stream.pl][8/10:0] LOG:  statement: SELECT pg_current_wal_lsn()
2024-11-24 06:04:12.847 GMT [3432][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.010 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:12.895 GMT [5636][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:12.896 GMT [5636][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-11-24 06:04:12.896 GMT [5636][client backend] [[unknown]][7/9:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:12.899 GMT [5636][client backend] [015_stream.pl][7/10:0] LOG:  statement: SELECT '0/22C85D0' <= replay_lsn AND state = 'streaming'
	         FROM pg_catalog.pg_stat_replication
	         WHERE application_name IN ('tap_sub', 'walreceiver')
2024-11-24 06:04:12.917 GMT [5636][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.025 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:13.284 GMT [6552][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:13.285 GMT [6552][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-11-24 06:04:13.285 GMT [6552][client backend] [[unknown]][9/9:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:13.344 GMT [6552][client backend] [015_stream.pl][9/10:0] LOG:  statement: BEGIN;
2024-11-24 06:04:13.344 GMT [6552][client backend] [015_stream.pl][9/10:0] LOG:  statement: INSERT INTO test_tab_2 SELECT i FROM generate_series(1, 5000) s(i);
2024-11-24 06:04:13.358 GMT [6552][client backend] [015_stream.pl][9/10:760] LOG:  statement: ;
2024-11-24 06:04:13.519 GMT [7108][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:13.521 GMT [7108][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-11-24 06:04:13.521 GMT [7108][client backend] [[unknown]][1/11:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:13.525 GMT [7108][client backend] [015_stream.pl][1/12:0] LOG:  statement: INSERT INTO test_tab_2 values(1)
2024-11-24 06:04:13.526 GMT [7108][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.009 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:13.554 GMT [1784][walsender] [tap_sub][28/0:0] LOG:  could not receive data from client: An existing connection was forcibly closed by the remote host.
	
2024-11-24 06:04:13.554 GMT [1784][walsender] [tap_sub][28/0:0] STATEMENT:  START_REPLICATION SLOT "tap_sub" LOGICAL 0/1FBE058 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true')
2024-11-24 06:04:13.554 GMT [1784][walsender] [tap_sub][28/0:0] LOG:  unexpected EOF on standby connection
2024-11-24 06:04:13.554 GMT [1784][walsender] [tap_sub][28/0:0] STATEMENT:  START_REPLICATION SLOT "tap_sub" LOGICAL 0/1FBE058 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true')
2024-11-24 06:04:13.554 GMT [1784][walsender] [tap_sub][28/0:0] LOG:  released logical replication slot "tap_sub"
2024-11-24 06:04:13.554 GMT [1784][walsender] [tap_sub][:0] LOG:  disconnection: session time: 0:00:03.131 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:13.568 GMT [6552][client backend] [015_stream.pl][9/10:760] LOG:  statement: COMMIT
	;
2024-11-24 06:04:13.568 GMT [6552][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.288 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:13.687 GMT [5908][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:13.688 GMT [5908][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-11-24 06:04:13.688 GMT [5908][walsender] [[unknown]][29/1:0] LOG:  replication connection authorized: user=SYSTEM application_name=tap_sub
2024-11-24 06:04:13.709 GMT [5908][walsender] [tap_sub][29/2:0] LOG:  statement: SELECT pg_catalog.set_config('search_path', '', false);
2024-11-24 06:04:13.710 GMT [5908][walsender] [tap_sub][29/0:0] LOG:  received replication command: IDENTIFY_SYSTEM
2024-11-24 06:04:13.710 GMT [5908][walsender] [tap_sub][29/0:0] STATEMENT:  IDENTIFY_SYSTEM
2024-11-24 06:04:13.710 GMT [5908][walsender] [tap_sub][29/0:0] LOG:  received replication command: START_REPLICATION SLOT "tap_sub" LOGICAL 0/22C85D0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true')
2024-11-24 06:04:13.710 GMT [5908][walsender] [tap_sub][29/0:0] STATEMENT:  START_REPLICATION SLOT "tap_sub" LOGICAL 0/22C85D0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true')
2024-11-24 06:04:13.710 GMT [5908][walsender] [tap_sub][29/0:0] LOG:  acquired logical replication slot "tap_sub"
2024-11-24 06:04:13.710 GMT [5908][walsender] [tap_sub][29/0:0] STATEMENT:  START_REPLICATION SLOT "tap_sub" LOGICAL 0/22C85D0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true')
2024-11-24 06:04:13.710 GMT [5908][walsender] [tap_sub][29/0:0] LOG:  0/22C85D0 has been already streamed, forwarding to 0/23163B8
2024-11-24 06:04:13.710 GMT [5908][walsender] [tap_sub][29/0:0] STATEMENT:  START_REPLICATION SLOT "tap_sub" LOGICAL 0/22C85D0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true')
2024-11-24 06:04:13.717 GMT [5908][walsender] [tap_sub][29/0:0] LOG:  starting logical decoding for slot "tap_sub"
2024-11-24 06:04:13.717 GMT [5908][walsender] [tap_sub][29/0:0] DETAIL:  Streaming transactions committing after 0/23163B8, reading WAL from 0/1792EE0.
2024-11-24 06:04:13.717 GMT [5908][walsender] [tap_sub][29/0:0] STATEMENT:  START_REPLICATION SLOT "tap_sub" LOGICAL 0/22C85D0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true')
2024-11-24 06:04:13.717 GMT [5908][walsender] [tap_sub][29/0:0] LOG:  logical decoding found consistent point at 0/1792EE0
2024-11-24 06:04:13.717 GMT [5908][walsender] [tap_sub][29/0:0] DETAIL:  There are no running transactions.
2024-11-24 06:04:13.717 GMT [5908][walsender] [tap_sub][29/0:0] STATEMENT:  START_REPLICATION SLOT "tap_sub" LOGICAL 0/22C85D0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true')
2024-11-24 06:04:13.838 GMT [1840][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:13.839 GMT [1840][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-11-24 06:04:13.839 GMT [1840][client backend] [[unknown]][0/11:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:13.842 GMT [1840][client backend] [015_stream.pl][0/12:0] LOG:  statement: SELECT pg_is_in_recovery()
2024-11-24 06:04:13.845 GMT [1840][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.010 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:13.997 GMT [1004][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:13.999 GMT [1004][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-11-24 06:04:13.999 GMT [1004][client backend] [[unknown]][2/11:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:14.004 GMT [1004][client backend] [015_stream.pl][2/12:0] LOG:  statement: SELECT pg_current_wal_lsn()
2024-11-24 06:04:14.007 GMT [1004][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.013 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:14.096 GMT [7104][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:14.097 GMT [7104][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-11-24 06:04:14.097 GMT [7104][client backend] [[unknown]][3/11:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:14.119 GMT [7104][client backend] [015_stream.pl][3/12:0] LOG:  statement: SELECT '0/2316C18' <= replay_lsn AND state = 'streaming'
	         FROM pg_catalog.pg_stat_replication
	         WHERE application_name IN ('tap_sub', 'walreceiver')
2024-11-24 06:04:14.146 GMT [7104][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.056 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:14.336 GMT [6276][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:14.337 GMT [6276][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-11-24 06:04:14.337 GMT [6276][client backend] [[unknown]][4/11:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:14.342 GMT [6276][client backend] [015_stream.pl][4/12:0] LOG:  statement: SELECT '0/2316C18' <= replay_lsn AND state = 'streaming'
	         FROM pg_catalog.pg_stat_replication
	         WHERE application_name IN ('tap_sub', 'walreceiver')
2024-11-24 06:04:14.349 GMT [6276][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.016 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:14.535 GMT [3196][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:14.537 GMT [3196][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-11-24 06:04:14.537 GMT [3196][client backend] [[unknown]][5/11:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:14.539 GMT [3196][client backend] [015_stream.pl][5/12:0] LOG:  statement: SELECT '0/2316C18' <= replay_lsn AND state = 'streaming'
	         FROM pg_catalog.pg_stat_replication
	         WHERE application_name IN ('tap_sub', 'walreceiver')
2024-11-24 06:04:14.547 GMT [3196][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.015 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:14.727 GMT [5668][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:14.728 GMT [5668][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-11-24 06:04:14.728 GMT [5668][client backend] [[unknown]][6/11:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:14.730 GMT [5668][client backend] [015_stream.pl][6/12:0] LOG:  statement: SELECT '0/2316C18' <= replay_lsn AND state = 'streaming'
	         FROM pg_catalog.pg_stat_replication
	         WHERE application_name IN ('tap_sub', 'walreceiver')
2024-11-24 06:04:14.756 GMT [5668][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.033 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:14.917 GMT [6192][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:14.918 GMT [6192][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-11-24 06:04:14.918 GMT [6192][client backend] [[unknown]][8/11:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:14.921 GMT [6192][client backend] [015_stream.pl][8/12:0] LOG:  statement: TRUNCATE TABLE test_tab_2
2024-11-24 06:04:14.923 GMT [6192][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.010 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:14.999 GMT [2208][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:15.000 GMT [2208][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-11-24 06:04:15.000 GMT [2208][client backend] [[unknown]][7/11:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:15.003 GMT [2208][client backend] [015_stream.pl][7/12:0] LOG:  statement: SELECT pg_is_in_recovery()
2024-11-24 06:04:15.005 GMT [2208][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.008 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:15.082 GMT [1140][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:15.083 GMT [1140][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-11-24 06:04:15.083 GMT [1140][client backend] [[unknown]][1/13:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:15.086 GMT [1140][client backend] [015_stream.pl][1/14:0] LOG:  statement: SELECT pg_current_wal_lsn()
2024-11-24 06:04:15.088 GMT [1140][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.009 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:15.155 GMT [5128][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:15.157 GMT [5128][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-11-24 06:04:15.157 GMT [5128][client backend] [[unknown]][9/11:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:15.161 GMT [5128][client backend] [015_stream.pl][9/12:0] LOG:  statement: SELECT '0/2316F38' <= replay_lsn AND state = 'streaming'
	         FROM pg_catalog.pg_stat_replication
	         WHERE application_name IN ('tap_sub', 'walreceiver')
2024-11-24 06:04:15.167 GMT [5128][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.015 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:15.467 GMT [2188][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:15.468 GMT [2188][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-11-24 06:04:15.468 GMT [2188][client backend] [[unknown]][0/13:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:15.471 GMT [2188][client backend] [015_stream.pl][0/14:0] LOG:  statement: BEGIN;
2024-11-24 06:04:15.471 GMT [2188][client backend] [015_stream.pl][0/14:0] LOG:  statement: INSERT INTO test_tab_2 SELECT i FROM generate_series(1, 5000) s(i);
2024-11-24 06:04:15.484 GMT [2188][client backend] [015_stream.pl][0/14:763] LOG:  statement: ;
2024-11-24 06:04:15.873 GMT [2776][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:15.874 GMT [2776][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-11-24 06:04:15.874 GMT [2776][client backend] [[unknown]][2/13:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:15.876 GMT [2776][client backend] [015_stream.pl][2/14:0] LOG:  statement: INSERT INTO test_tab_2 SELECT i FROM generate_series(1, 5000) s(i)
2024-11-24 06:04:15.888 GMT [2776][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.018 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:15.935 GMT [5908][walsender] [tap_sub][29/0:0] LOG:  could not receive data from client: An existing connection was forcibly closed by the remote host.
	
2024-11-24 06:04:15.935 GMT [5908][walsender] [tap_sub][29/0:0] STATEMENT:  START_REPLICATION SLOT "tap_sub" LOGICAL 0/22C85D0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true')
2024-11-24 06:04:15.936 GMT [5908][walsender] [tap_sub][29/0:0] LOG:  unexpected EOF on standby connection
2024-11-24 06:04:15.936 GMT [5908][walsender] [tap_sub][29/0:0] STATEMENT:  START_REPLICATION SLOT "tap_sub" LOGICAL 0/22C85D0 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true')
2024-11-24 06:04:15.936 GMT [5908][walsender] [tap_sub][29/0:0] LOG:  released logical replication slot "tap_sub"
2024-11-24 06:04:15.936 GMT [5908][walsender] [tap_sub][:0] LOG:  disconnection: session time: 0:00:02.251 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:15.961 GMT [2188][client backend] [015_stream.pl][0/14:763] LOG:  statement: COMMIT
	;
2024-11-24 06:04:15.961 GMT [2188][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.497 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:16.022 GMT [6408][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:16.023 GMT [6408][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-11-24 06:04:16.023 GMT [6408][walsender] [[unknown]][30/1:0] LOG:  replication connection authorized: user=SYSTEM application_name=tap_sub
2024-11-24 06:04:16.025 GMT [6408][walsender] [tap_sub][30/2:0] LOG:  statement: SELECT pg_catalog.set_config('search_path', '', false);
2024-11-24 06:04:16.026 GMT [6408][walsender] [tap_sub][30/0:0] LOG:  received replication command: IDENTIFY_SYSTEM
2024-11-24 06:04:16.026 GMT [6408][walsender] [tap_sub][30/0:0] STATEMENT:  IDENTIFY_SYSTEM
2024-11-24 06:04:16.026 GMT [6408][walsender] [tap_sub][30/0:0] LOG:  received replication command: START_REPLICATION SLOT "tap_sub" LOGICAL 0/2316F38 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true')
2024-11-24 06:04:16.026 GMT [6408][walsender] [tap_sub][30/0:0] STATEMENT:  START_REPLICATION SLOT "tap_sub" LOGICAL 0/2316F38 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true')
2024-11-24 06:04:16.026 GMT [6408][walsender] [tap_sub][30/0:0] LOG:  acquired logical replication slot "tap_sub"
2024-11-24 06:04:16.026 GMT [6408][walsender] [tap_sub][30/0:0] STATEMENT:  START_REPLICATION SLOT "tap_sub" LOGICAL 0/2316F38 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true')
2024-11-24 06:04:16.026 GMT [6408][walsender] [tap_sub][30/0:0] LOG:  0/2316F38 has been already streamed, forwarding to 0/23B3A48
2024-11-24 06:04:16.026 GMT [6408][walsender] [tap_sub][30/0:0] STATEMENT:  START_REPLICATION SLOT "tap_sub" LOGICAL 0/2316F38 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true')
2024-11-24 06:04:16.027 GMT [6408][walsender] [tap_sub][30/0:0] LOG:  starting logical decoding for slot "tap_sub"
2024-11-24 06:04:16.027 GMT [6408][walsender] [tap_sub][30/0:0] DETAIL:  Streaming transactions committing after 0/23B3A48, reading WAL from 0/1792EE0.
2024-11-24 06:04:16.027 GMT [6408][walsender] [tap_sub][30/0:0] STATEMENT:  START_REPLICATION SLOT "tap_sub" LOGICAL 0/2316F38 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true')
2024-11-24 06:04:16.027 GMT [6408][walsender] [tap_sub][30/0:0] LOG:  logical decoding found consistent point at 0/1792EE0
2024-11-24 06:04:16.027 GMT [6408][walsender] [tap_sub][30/0:0] DETAIL:  There are no running transactions.
2024-11-24 06:04:16.027 GMT [6408][walsender] [tap_sub][30/0:0] STATEMENT:  START_REPLICATION SLOT "tap_sub" LOGICAL 0/2316F38 (proto_version '4', streaming 'parallel', origin 'any', publication_names '"tap_pub"', binary 'true')
2024-11-24 06:04:16.372 GMT [5012][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:16.374 GMT [5012][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-11-24 06:04:16.374 GMT [5012][client backend] [[unknown]][3/13:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:16.378 GMT [5012][client backend] [015_stream.pl][3/14:0] LOG:  statement: SELECT pg_is_in_recovery()
2024-11-24 06:04:16.381 GMT [5012][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.012 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:16.473 GMT [6380][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:16.475 GMT [6380][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-11-24 06:04:16.475 GMT [6380][client backend] [[unknown]][4/13:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:16.479 GMT [6380][client backend] [015_stream.pl][4/14:0] LOG:  statement: SELECT pg_current_wal_lsn()
2024-11-24 06:04:16.482 GMT [6380][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.022 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:16.605 GMT [6096][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:16.612 GMT [6096][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-11-24 06:04:16.612 GMT [6096][client backend] [[unknown]][5/13:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:16.619 GMT [6096][client backend] [015_stream.pl][5/14:0] LOG:  statement: SELECT '0/23B3AE8' <= replay_lsn AND state = 'streaming'
	         FROM pg_catalog.pg_stat_replication
	         WHERE application_name IN ('tap_sub', 'walreceiver')
2024-11-24 06:04:16.632 GMT [6096][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.032 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:16.877 GMT [6304][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:16.880 GMT [6304][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-11-24 06:04:16.880 GMT [6304][client backend] [[unknown]][6/13:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:16.883 GMT [6304][client backend] [015_stream.pl][6/14:0] LOG:  statement: SELECT '0/23B3AE8' <= replay_lsn AND state = 'streaming'
	         FROM pg_catalog.pg_stat_replication
	         WHERE application_name IN ('tap_sub', 'walreceiver')
2024-11-24 06:04:16.892 GMT [6304][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.038 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:17.101 GMT [6428][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:17.102 GMT [6428][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-11-24 06:04:17.102 GMT [6428][client backend] [[unknown]][8/13:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:17.105 GMT [6428][client backend] [015_stream.pl][8/14:0] LOG:  statement: SELECT '0/23B3AE8' <= replay_lsn AND state = 'streaming'
	         FROM pg_catalog.pg_stat_replication
	         WHERE application_name IN ('tap_sub', 'walreceiver')
2024-11-24 06:04:17.113 GMT [6428][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.015 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:17.389 GMT [5040][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:17.390 GMT [5040][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-11-24 06:04:17.390 GMT [5040][client backend] [[unknown]][7/13:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:17.392 GMT [5040][client backend] [015_stream.pl][7/14:0] LOG:  statement: INSERT INTO test_tab_2 SELECT i FROM generate_series(1, 5000) s(i)
2024-11-24 06:04:17.404 GMT [5040][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.018 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:17.446 GMT [2776][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:17.447 GMT [2776][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-11-24 06:04:17.447 GMT [2776][client backend] [[unknown]][1/15:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:17.449 GMT [2776][client backend] [015_stream.pl][1/16:0] LOG:  statement: SELECT pg_is_in_recovery()
2024-11-24 06:04:17.451 GMT [2776][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.009 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:17.543 GMT [3480][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:17.544 GMT [3480][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-11-24 06:04:17.544 GMT [3480][client backend] [[unknown]][9/13:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:17.547 GMT [3480][client backend] [015_stream.pl][9/14:0] LOG:  statement: SELECT pg_current_wal_lsn()
2024-11-24 06:04:17.550 GMT [3480][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.009 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:17.631 GMT [6624][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:17.633 GMT [6624][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-11-24 06:04:17.633 GMT [6624][client backend] [[unknown]][2/15:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:17.655 GMT [6624][client backend] [015_stream.pl][2/16:0] LOG:  statement: SELECT '0/24020D8' <= replay_lsn AND state = 'streaming'
	         FROM pg_catalog.pg_stat_replication
	         WHERE application_name IN ('tap_sub', 'walreceiver')
2024-11-24 06:04:17.663 GMT [6624][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.036 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:17.904 GMT [5548][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:17.906 GMT [5548][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-11-24 06:04:17.906 GMT [5548][client backend] [[unknown]][0/15:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:17.935 GMT [5548][client backend] [015_stream.pl][0/16:0] LOG:  statement: SELECT '0/24020D8' <= replay_lsn AND state = 'streaming'
	         FROM pg_catalog.pg_stat_replication
	         WHERE application_name IN ('tap_sub', 'walreceiver')
2024-11-24 06:04:17.945 GMT [5548][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.047 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:18.108 GMT [6352][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:18.110 GMT [6352][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-11-24 06:04:18.110 GMT [6352][client backend] [[unknown]][3/15:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:18.114 GMT [6352][client backend] [015_stream.pl][3/16:0] LOG:  statement: SELECT '0/24020D8' <= replay_lsn AND state = 'streaming'
	         FROM pg_catalog.pg_stat_replication
	         WHERE application_name IN ('tap_sub', 'walreceiver')
2024-11-24 06:04:18.119 GMT [6352][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.014 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:18.310 GMT [5756][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-11-24 06:04:18.311 GMT [5756][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-11-24 06:04:18.311 GMT [5756][client backend] [[unknown]][4/15:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-11-24 06:04:18.314 GMT [5756][client backend] [015_stream.pl][4/16:0] LOG:  statement: SELECT '0/24020D8' <= replay_lsn AND state = 'streaming'
	         FROM pg_catalog.pg_stat_replication
	         WHERE application_name IN ('tap_sub', 'walreceiver')
2024-11-24 06:04:18.321 GMT [5756][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.013 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:19.536 GMT [6408][walsender] [tap_sub][30/0:0] LOG:  released logical replication slot "tap_sub"
2024-11-24 06:04:19.536 GMT [6408][walsender] [tap_sub][:0] LOG:  disconnection: session time: 0:00:03.517 user=SYSTEM database=postgres host=[local]
2024-11-24 06:04:19.662 GMT [5652][postmaster] LOG:  received immediate shutdown request
TRAP: failed Assert("(remainMask.mask | targetMask.mask) == BTYPE_MASK_ALL.mask"), File: "../src/backend/postmaster/postmaster.c", Line: 2887, PID: 5652
abort() has been called