2024-12-11 13:39:19.541 GMT [1968][postmaster] LOG:  starting PostgreSQL 18devel on x86_64-windows, compiled by msvc-19.29.30157, 64-bit
2024-12-11 13:39:19.544 GMT [1968][postmaster] LOG:  listening on Unix socket "C:/Windows/TEMP/TY7Rev6di5/.s.PGSQL.27580"
2024-12-11 13:39:19.658 GMT [6308][startup] LOG:  database system was shut down at 2024-12-11 13:29:36 GMT
2024-12-11 13:39:19.694 GMT [1968][postmaster] LOG:  database system is ready to accept connections
2024-12-11 13:39:20.634 GMT [3604][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-12-11 13:39:20.638 GMT [3604][client backend] [[unknown]][0/1:0] LOG:  connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117)
2024-12-11 13:39:20.638 GMT [3604][client backend] [[unknown]][0/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-12-11 13:39:20.675 GMT [3604][client backend] [015_stream.pl][0/2:0] LOG:  statement: CREATE TABLE test_tab (a int primary key, b bytea, c timestamptz DEFAULT now(), d bigint DEFAULT 999)
2024-12-11 13:39:20.700 GMT [3604][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.070 user=SYSTEM database=postgres host=[local]
2024-12-11 13:39:20.924 GMT [5128][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-12-11 13:39:20.926 GMT [5128][client backend] [[unknown]][1/1:0] LOG:  connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117)
2024-12-11 13:39:20.926 GMT [5128][client backend] [[unknown]][1/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-12-11 13:39:20.930 GMT [5128][client backend] [015_stream.pl][1/2:0] LOG:  statement: CREATE TABLE test_tab_2 (a int)
2024-12-11 13:39:20.936 GMT [5128][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.017 user=SYSTEM database=postgres host=[local]
2024-12-11 13:39:21.060 GMT [3968][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-12-11 13:39:21.062 GMT [3968][client backend] [[unknown]][2/1:0] LOG:  connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117)
2024-12-11 13:39:21.062 GMT [3968][client backend] [[unknown]][2/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-12-11 13:39:21.066 GMT [3968][client backend] [015_stream.pl][2/2:0] LOG:  statement: CREATE UNIQUE INDEX idx_tab on test_tab_2(a)
2024-12-11 13:39:21.070 GMT [3968][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.018 user=SYSTEM database=postgres host=[local]
2024-12-11 13:39:21.442 GMT [6796][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-12-11 13:39:21.444 GMT [6796][client backend] [[unknown]][3/1:0] LOG:  connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117)
2024-12-11 13:39:21.444 GMT [6796][client backend] [[unknown]][3/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-12-11 13:39:21.447 GMT [6796][client backend] [015_stream.pl][3/2:0] LOG:  statement: CREATE SUBSCRIPTION tap_sub CONNECTION 'port=27579 host=C:/Windows/TEMP/TY7Rev6di5 dbname=postgres application_name=tap_sub' PUBLICATION tap_pub WITH (streaming = on)
2024-12-11 13:39:21.541 GMT [6796][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.102 user=SYSTEM database=postgres host=[local]
2024-12-11 13:39:21.587 GMT [3960][logical replication apply worker] LOG:  logical replication apply worker for subscription "tap_sub" has started
2024-12-11 13:39:21.767 GMT [3968][logical replication tablesync worker] LOG:  logical replication table synchronization worker for subscription "tap_sub", table "test_tab_2" has started
2024-12-11 13:39:21.782 GMT [1036][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-12-11 13:39:21.784 GMT [1036][client backend] [[unknown]][4/1:0] LOG:  connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117)
2024-12-11 13:39:21.784 GMT [1036][client backend] [[unknown]][4/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-12-11 13:39:21.789 GMT [1036][client backend] [015_stream.pl][4/2:0] LOG:  statement: SELECT count(1) = 0 FROM pg_subscription_rel WHERE srsubstate NOT IN ('r', 's');
2024-12-11 13:39:21.800 GMT [1036][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.023 user=SYSTEM database=postgres host=[local]
2024-12-11 13:39:21.828 GMT [6776][logical replication tablesync worker] LOG:  logical replication table synchronization worker for subscription "tap_sub", table "test_tab" has started
2024-12-11 13:39:21.909 GMT [3968][logical replication tablesync worker] LOG:  logical replication table synchronization worker for subscription "tap_sub", table "test_tab_2" has finished
2024-12-11 13:39:21.952 GMT [6776][logical replication tablesync worker] LOG:  logical replication table synchronization worker for subscription "tap_sub", table "test_tab" has finished
2024-12-11 13:39:22.082 GMT [708][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-12-11 13:39:22.085 GMT [708][client backend] [[unknown]][5/1:0] LOG:  connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117)
2024-12-11 13:39:22.085 GMT [708][client backend] [[unknown]][5/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-12-11 13:39:22.092 GMT [708][client backend] [015_stream.pl][5/2:0] LOG:  statement: SELECT count(1) = 0 FROM pg_subscription_rel WHERE srsubstate NOT IN ('r', 's');
2024-12-11 13:39:22.100 GMT [708][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.023 user=SYSTEM database=postgres host=[local]
2024-12-11 13:39:22.849 GMT [4652][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-12-11 13:39:22.851 GMT [4652][client backend] [[unknown]][6/1:0] LOG:  connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117)
2024-12-11 13:39:22.851 GMT [4652][client backend] [[unknown]][6/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-12-11 13:39:22.872 GMT [4652][client backend] [015_stream.pl][6/2:0] LOG:  statement: SELECT count(*), count(c), count(d = 999) FROM test_tab
2024-12-11 13:39:22.883 GMT [4652][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.038 user=SYSTEM database=postgres host=[local]
2024-12-11 13:39:24.744 GMT [6380][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-12-11 13:39:24.746 GMT [6380][client backend] [[unknown]][7/1:0] LOG:  connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117)
2024-12-11 13:39:24.746 GMT [6380][client backend] [[unknown]][7/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-12-11 13:39:24.749 GMT [6380][client backend] [015_stream.pl][7/2:0] LOG:  statement: SELECT count(*), count(c), count(d = 999) FROM test_tab
2024-12-11 13:39:24.761 GMT [6380][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.020 user=SYSTEM database=postgres host=[local]
2024-12-11 13:39:24.932 GMT [2776][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-12-11 13:39:24.934 GMT [2776][client backend] [[unknown]][8/1:0] LOG:  connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117)
2024-12-11 13:39:24.934 GMT [2776][client backend] [[unknown]][8/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-12-11 13:39:24.947 GMT [2776][client backend] [015_stream.pl][8/2:0] LOG:  statement: ALTER SUBSCRIPTION tap_sub SET (binary = on)
2024-12-11 13:39:24.949 GMT [2776][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.020 user=SYSTEM database=postgres host=[local]
2024-12-11 13:39:24.949 GMT [3960][logical replication apply worker] LOG:  logical replication worker for subscription "tap_sub" will restart because of a parameter change
2024-12-11 13:39:25.087 GMT [6700][logical replication apply worker] LOG:  logical replication apply worker for subscription "tap_sub" has started
2024-12-11 13:39:26.369 GMT [7064][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-12-11 13:39:26.372 GMT [7064][client backend] [[unknown]][9/1:0] LOG:  connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117)
2024-12-11 13:39:26.372 GMT [7064][client backend] [[unknown]][9/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-12-11 13:39:26.381 GMT [7064][client backend] [015_stream.pl][9/2:0] LOG:  statement: SELECT count(*), count(c), count(d = 999) FROM test_tab
2024-12-11 13:39:26.393 GMT [7064][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.028 user=SYSTEM database=postgres host=[local]
2024-12-11 13:39:26.567 GMT [5956][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-12-11 13:39:26.571 GMT [5956][client backend] [[unknown]][10/1:0] LOG:  connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117)
2024-12-11 13:39:26.571 GMT [5956][client backend] [[unknown]][10/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-12-11 13:39:26.585 GMT [5956][client backend] [015_stream.pl][10/2:0] LOG:  statement: UPDATE test_tab SET c = 'epoch'::timestamptz + 987654321 * interval '1s'
2024-12-11 13:39:26.642 GMT [5956][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.095 user=SYSTEM database=postgres host=[local]
2024-12-11 13:39:27.824 GMT [792][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-12-11 13:39:27.826 GMT [792][client backend] [[unknown]][11/1:0] LOG:  connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117)
2024-12-11 13:39:27.826 GMT [792][client backend] [[unknown]][11/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-12-11 13:39:27.830 GMT [792][client backend] [015_stream.pl][11/2:0] LOG:  statement: SELECT count(*), count(extract(epoch from c) = 987654321), count(d = 999) FROM test_tab
2024-12-11 13:39:27.846 GMT [792][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.026 user=SYSTEM database=postgres host=[local]
2024-12-11 13:39:28.908 GMT [1768][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-12-11 13:39:28.910 GMT [1768][client backend] [[unknown]][12/1:0] LOG:  connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117)
2024-12-11 13:39:28.910 GMT [1768][client backend] [[unknown]][12/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-12-11 13:39:28.916 GMT [1768][client backend] [015_stream.pl][12/2:0] LOG:  statement: ALTER SUBSCRIPTION tap_sub SET(streaming = parallel, binary = off)
2024-12-11 13:39:28.917 GMT [6700][logical replication apply worker] LOG:  logical replication worker for subscription "tap_sub" will restart because of a parameter change
2024-12-11 13:39:28.917 GMT [1768][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.014 user=SYSTEM database=postgres host=[local]
2024-12-11 13:39:28.962 GMT [3160][logical replication apply worker] LOG:  logical replication apply worker for subscription "tap_sub" has started
2024-12-11 13:39:29.642 GMT [1968][postmaster] LOG:  received SIGHUP, reloading configuration files
2024-12-11 13:39:29.644 GMT [1968][postmaster] LOG:  parameter "log_min_messages" changed to "debug1"
2024-12-11 13:39:29.768 GMT [4868][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-12-11 13:39:29.770 GMT [4868][client backend] [[unknown]][13/1:0] LOG:  connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117)
2024-12-11 13:39:29.770 GMT [4868][client backend] [[unknown]][13/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-12-11 13:39:29.873 GMT [4868][client backend] [015_stream.pl][13/2:0] LOG:  statement: SELECT 1
2024-12-11 13:39:29.877 GMT [4868][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.112 user=SYSTEM database=postgres host=[local]
2024-12-11 13:39:30.480 GMT [3160][logical replication apply worker] DEBUG:  starting logical replication worker for subscription "tap_sub"
2024-12-11 13:39:30.480 GMT [3160][logical replication apply worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM START" in transaction 755
2024-12-11 13:39:30.482 GMT [1968][postmaster] DEBUG:  registering background worker "logical replication parallel apply worker for subscription 16398"
2024-12-11 13:39:30.482 GMT [1968][postmaster] DEBUG:  starting background worker process "logical replication parallel apply worker for subscription 16398"
2024-12-11 13:39:30.566 GMT [5404][logical replication parallel worker] LOG:  logical replication apply worker for subscription "tap_sub" has started
2024-12-11 13:39:30.585 GMT [5404][logical replication parallel worker] DEBUG:  applied 399 changes in the streaming chunk
2024-12-11 13:39:30.585 GMT [5404][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 755
2024-12-11 13:39:30.597 GMT [5404][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:30.597 GMT [5404][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 755
2024-12-11 13:39:30.608 GMT [5404][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:30.608 GMT [5404][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 755
2024-12-11 13:39:30.620 GMT [5404][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:30.620 GMT [5404][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 755
2024-12-11 13:39:30.636 GMT [5404][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:30.636 GMT [5404][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 755
2024-12-11 13:39:30.651 GMT [5404][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:30.651 GMT [5404][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 755
2024-12-11 13:39:30.664 GMT [5404][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:30.664 GMT [5404][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 755
2024-12-11 13:39:30.677 GMT [5404][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:30.677 GMT [5404][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 755
2024-12-11 13:39:30.690 GMT [5404][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:30.690 GMT [5404][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 755
2024-12-11 13:39:30.705 GMT [5404][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:30.705 GMT [5404][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 755
2024-12-11 13:39:30.721 GMT [5404][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:30.721 GMT [5404][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 755
2024-12-11 13:39:30.739 GMT [5404][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:30.739 GMT [5404][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 755
2024-12-11 13:39:30.759 GMT [5404][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:30.759 GMT [5404][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 755
2024-12-11 13:39:30.782 GMT [5404][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:30.782 GMT [5404][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 755
2024-12-11 13:39:30.827 GMT [3160][logical replication apply worker] DEBUG:  starting logical replication worker for subscription "tap_sub"
2024-12-11 13:39:30.827 GMT [3160][logical replication apply worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM START" in transaction 756
2024-12-11 13:39:30.827 GMT [1968][postmaster] DEBUG:  registering background worker "logical replication parallel apply worker for subscription 16398"
2024-12-11 13:39:30.827 GMT [1968][postmaster] DEBUG:  starting background worker process "logical replication parallel apply worker for subscription 16398"
2024-12-11 13:39:30.885 GMT [5404][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:30.885 GMT [5404][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 755
2024-12-11 13:39:30.930 GMT [5404][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:30.930 GMT [5404][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 755
2024-12-11 13:39:30.951 GMT [5404][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:30.951 GMT [5404][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 755
2024-12-11 13:39:30.970 GMT [5404][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:30.970 GMT [5404][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 755
2024-12-11 13:39:30.977 GMT [3980][logical replication parallel worker] LOG:  logical replication apply worker for subscription "tap_sub" has started
2024-12-11 13:39:30.989 GMT [3980][logical replication parallel worker] DEBUG:  applied 322 changes in the streaming chunk
2024-12-11 13:39:30.989 GMT [3980][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 756
2024-12-11 13:39:30.992 GMT [5404][logical replication parallel worker] DEBUG:  applied 413 changes in the streaming chunk
2024-12-11 13:39:30.992 GMT [5404][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 755
2024-12-11 13:39:31.000 GMT [3980][logical replication parallel worker] DEBUG:  applied 321 changes in the streaming chunk
2024-12-11 13:39:31.000 GMT [3980][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 756
2024-12-11 13:39:31.005 GMT [5404][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:31.005 GMT [5404][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 755
2024-12-11 13:39:31.015 GMT [3980][logical replication parallel worker] DEBUG:  applied 321 changes in the streaming chunk
2024-12-11 13:39:31.015 GMT [3980][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 756
2024-12-11 13:39:31.024 GMT [5404][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:31.024 GMT [5404][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 755
2024-12-11 13:39:31.025 GMT [3980][logical replication parallel worker] DEBUG:  applied 321 changes in the streaming chunk
2024-12-11 13:39:31.025 GMT [3980][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 756
2024-12-11 13:39:31.038 GMT [5404][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:31.038 GMT [5404][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 755
2024-12-11 13:39:31.038 GMT [3980][logical replication parallel worker] DEBUG:  applied 321 changes in the streaming chunk
2024-12-11 13:39:31.038 GMT [3980][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 756
2024-12-11 13:39:31.049 GMT [3980][logical replication parallel worker] DEBUG:  applied 321 changes in the streaming chunk
2024-12-11 13:39:31.049 GMT [3980][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 756
2024-12-11 13:39:31.065 GMT [3980][logical replication parallel worker] DEBUG:  applied 321 changes in the streaming chunk
2024-12-11 13:39:31.065 GMT [3980][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 756
2024-12-11 13:39:31.077 GMT [3980][logical replication parallel worker] DEBUG:  applied 321 changes in the streaming chunk
2024-12-11 13:39:31.077 GMT [3980][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 756
2024-12-11 13:39:31.093 GMT [3980][logical replication parallel worker] DEBUG:  applied 321 changes in the streaming chunk
2024-12-11 13:39:31.093 GMT [3980][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 756
2024-12-11 13:39:31.110 GMT [3980][logical replication parallel worker] DEBUG:  applied 321 changes in the streaming chunk
2024-12-11 13:39:31.110 GMT [3980][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 756
2024-12-11 13:39:31.126 GMT [3980][logical replication parallel worker] DEBUG:  applied 321 changes in the streaming chunk
2024-12-11 13:39:31.126 GMT [3980][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 756
2024-12-11 13:39:31.141 GMT [3980][logical replication parallel worker] DEBUG:  applied 321 changes in the streaming chunk
2024-12-11 13:39:31.141 GMT [3980][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 756
2024-12-11 13:39:31.151 GMT [3980][logical replication parallel worker] DEBUG:  applied 321 changes in the streaming chunk
2024-12-11 13:39:31.151 GMT [3980][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 756
2024-12-11 13:39:31.160 GMT [3980][logical replication parallel worker] DEBUG:  applied 321 changes in the streaming chunk
2024-12-11 13:39:31.160 GMT [3980][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 756
2024-12-11 13:39:31.169 GMT [3980][logical replication parallel worker] DEBUG:  applied 321 changes in the streaming chunk
2024-12-11 13:39:31.169 GMT [3980][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 756
2024-12-11 13:39:31.179 GMT [3980][logical replication parallel worker] DEBUG:  applied 355 changes in the streaming chunk
2024-12-11 13:39:31.179 GMT [3980][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 756
2024-12-11 13:39:31.203 GMT [3980][logical replication parallel worker] DEBUG:  applied 401 changes in the streaming chunk
2024-12-11 13:39:31.203 GMT [3980][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 756
2024-12-11 13:39:31.231 GMT [3980][logical replication parallel worker] DEBUG:  applied 401 changes in the streaming chunk
2024-12-11 13:39:31.231 GMT [3980][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 756
2024-12-11 13:39:31.255 GMT [3980][logical replication parallel worker] DEBUG:  applied 401 changes in the streaming chunk
2024-12-11 13:39:31.255 GMT [3980][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 756
2024-12-11 13:39:31.277 GMT [3980][logical replication parallel worker] DEBUG:  applied 401 changes in the streaming chunk
2024-12-11 13:39:31.277 GMT [3980][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 756
2024-12-11 13:39:31.298 GMT [3980][logical replication parallel worker] DEBUG:  applied 401 changes in the streaming chunk
2024-12-11 13:39:31.298 GMT [3980][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 756
2024-12-11 13:39:31.317 GMT [3980][logical replication parallel worker] DEBUG:  applied 401 changes in the streaming chunk
2024-12-11 13:39:31.317 GMT [3980][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 756
2024-12-11 13:39:31.342 GMT [3980][logical replication parallel worker] DEBUG:  applied 401 changes in the streaming chunk
2024-12-11 13:39:31.342 GMT [3980][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 756
2024-12-11 13:39:31.386 GMT [3980][logical replication parallel worker] DEBUG:  applied 401 changes in the streaming chunk
2024-12-11 13:39:31.386 GMT [3980][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 756
2024-12-11 13:39:31.399 GMT [3980][logical replication parallel worker] DEBUG:  applied 401 changes in the streaming chunk
2024-12-11 13:39:31.399 GMT [3980][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 756
2024-12-11 13:39:31.429 GMT [3980][logical replication parallel worker] DEBUG:  applied 401 changes in the streaming chunk
2024-12-11 13:39:31.429 GMT [3980][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 756
2024-12-11 13:39:31.440 GMT [3980][logical replication parallel worker] DEBUG:  applied 401 changes in the streaming chunk
2024-12-11 13:39:31.440 GMT [3980][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 756
2024-12-11 13:39:31.481 GMT [3980][logical replication parallel worker] DEBUG:  applied 401 changes in the streaming chunk
2024-12-11 13:39:31.481 GMT [3980][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 756
2024-12-11 13:39:31.482 GMT [3980][logical replication parallel worker] DEBUG:  applied 16 changes in the streaming chunk
2024-12-11 13:39:31.482 GMT [3980][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 756
2024-12-11 13:39:31.483 GMT [3980][logical replication parallel worker] DEBUG:  finished processing the STREAM COMMIT command
2024-12-11 13:39:31.483 GMT [3980][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM COMMIT" in transaction 756, finished at 0/1FBE3D0
2024-12-11 13:39:31.483 GMT [3980][logical replication parallel worker] LOG:  logical replication parallel apply worker for subscription "tap_sub" has finished
2024-12-11 13:39:31.489 GMT [5404][logical replication parallel worker] DEBUG:  applied 96 changes in the streaming chunk
2024-12-11 13:39:31.489 GMT [5404][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 755
2024-12-11 13:39:31.489 GMT [5404][logical replication parallel worker] DEBUG:  finished processing the STREAM COMMIT command
2024-12-11 13:39:31.489 GMT [5404][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM COMMIT" in transaction 755, finished at 0/1FBE400
2024-12-11 13:39:31.520 GMT [1968][postmaster] DEBUG:  unregistering background worker "logical replication parallel apply worker for subscription 16398"
2024-12-11 13:39:31.520 GMT [1968][postmaster] DEBUG:  background worker "logical replication parallel worker" (PID 3980) exited with exit code 0
2024-12-11 13:39:31.766 GMT [3888][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-12-11 13:39:31.767 GMT [3888][client backend] [[unknown]][14/1:0] LOG:  connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117)
2024-12-11 13:39:31.767 GMT [3888][client backend] [[unknown]][14/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-12-11 13:39:31.787 GMT [3888][client backend] [015_stream.pl][14/2:0] LOG:  statement: SELECT count(*), count(c), count(d = 999) FROM test_tab
2024-12-11 13:39:31.800 GMT [3888][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.037 user=SYSTEM database=postgres host=[local]
2024-12-11 13:39:31.897 GMT [7136][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-12-11 13:39:31.899 GMT [7136][client backend] [[unknown]][15/1:0] LOG:  connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117)
2024-12-11 13:39:31.899 GMT [7136][client backend] [[unknown]][15/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-12-11 13:39:31.904 GMT [7136][client backend] [015_stream.pl][15/2:0] LOG:  statement: ALTER SUBSCRIPTION tap_sub SET (binary = on)
2024-12-11 13:39:31.905 GMT [7136][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.013 user=SYSTEM database=postgres host=[local]
2024-12-11 13:39:31.906 GMT [3160][logical replication apply worker] LOG:  logical replication worker for subscription "tap_sub" will restart because of a parameter change
2024-12-11 13:39:31.907 GMT [5404][logical replication parallel worker] FATAL:  terminating logical replication worker due to administrator command
2024-12-11 13:39:31.908 GMT [5412][logical replication launcher] DEBUG:  starting logical replication worker for subscription "tap_sub"
2024-12-11 13:39:31.909 GMT [1968][postmaster] DEBUG:  registering background worker "logical replication apply worker for subscription 16398"
2024-12-11 13:39:31.909 GMT [1968][postmaster] DEBUG:  starting background worker process "logical replication apply worker for subscription 16398"
2024-12-11 13:39:31.961 GMT [1968][postmaster] DEBUG:  unregistering background worker "logical replication apply worker for subscription 16398"
2024-12-11 13:39:31.961 GMT [1968][postmaster] DEBUG:  background worker "logical replication apply worker" (PID 3160) exited with exit code 0
2024-12-11 13:39:31.961 GMT [1968][postmaster] DEBUG:  unregistering background worker "logical replication parallel apply worker for subscription 16398"
2024-12-11 13:39:31.961 GMT [1968][postmaster] LOG:  background worker "logical replication parallel worker" (PID 5404) exited with exit code 1
2024-12-11 13:39:31.965 GMT [4176][logical replication apply worker] LOG:  logical replication apply worker for subscription "tap_sub" has started
2024-12-11 13:39:31.965 GMT [4176][logical replication apply worker] DEBUG:  connecting to publisher using connection string "port=27579 host=C:/Windows/TEMP/TY7Rev6di5 dbname=postgres application_name=tap_sub"
2024-12-11 13:39:32.067 GMT [4176][logical replication apply worker] DEBUG:  logical replication apply worker for subscription "tap_sub" two_phase is DISABLED
2024-12-11 13:39:32.172 GMT [4176][logical replication apply worker] DEBUG:  starting logical replication worker for subscription "tap_sub"
2024-12-11 13:39:32.172 GMT [4176][logical replication apply worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM START" in transaction 757
2024-12-11 13:39:32.174 GMT [1968][postmaster] DEBUG:  registering background worker "logical replication parallel apply worker for subscription 16398"
2024-12-11 13:39:32.174 GMT [1968][postmaster] DEBUG:  starting background worker process "logical replication parallel apply worker for subscription 16398"
2024-12-11 13:39:32.227 GMT [1820][logical replication parallel worker] LOG:  logical replication apply worker for subscription "tap_sub" has started
2024-12-11 13:39:32.259 GMT [1820][logical replication parallel worker] DEBUG:  applied 399 changes in the streaming chunk
2024-12-11 13:39:32.259 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 757
2024-12-11 13:39:32.293 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:32.293 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 757
2024-12-11 13:39:32.313 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:32.313 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 757
2024-12-11 13:39:32.336 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:32.336 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 757
2024-12-11 13:39:32.354 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:32.354 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 757
2024-12-11 13:39:32.372 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:32.372 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 757
2024-12-11 13:39:32.387 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:32.387 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 757
2024-12-11 13:39:32.400 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:32.400 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 757
2024-12-11 13:39:32.412 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:32.412 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 757
2024-12-11 13:39:32.424 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:32.424 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 757
2024-12-11 13:39:32.440 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:32.440 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 757
2024-12-11 13:39:32.452 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:32.452 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 757
2024-12-11 13:39:32.491 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:32.491 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 757
2024-12-11 13:39:32.568 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:32.568 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 757
2024-12-11 13:39:32.588 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:32.588 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 757
2024-12-11 13:39:32.636 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:32.636 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 757
2024-12-11 13:39:32.679 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:32.679 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 757
2024-12-11 13:39:32.706 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:32.706 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 757
2024-12-11 13:39:32.732 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:32.732 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 757
2024-12-11 13:39:32.752 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:32.752 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 757
2024-12-11 13:39:32.772 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:32.772 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 757
2024-12-11 13:39:32.793 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:32.793 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 757
2024-12-11 13:39:32.809 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:32.809 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 757
2024-12-11 13:39:32.822 GMT [1820][logical replication parallel worker] DEBUG:  applied 494 changes in the streaming chunk
2024-12-11 13:39:32.822 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 757
2024-12-11 13:39:32.864 GMT [1820][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:32.864 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 757
2024-12-11 13:39:32.903 GMT [1820][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:32.903 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 757
2024-12-11 13:39:32.908 GMT [1820][logical replication parallel worker] DEBUG:  applied 192 changes in the streaming chunk
2024-12-11 13:39:32.908 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 757
2024-12-11 13:39:32.909 GMT [1820][logical replication parallel worker] DEBUG:  finished processing the STREAM COMMIT command
2024-12-11 13:39:32.909 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM COMMIT" in transaction 757, finished at 0/2177D70
2024-12-11 13:39:33.329 GMT [1844][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-12-11 13:39:33.331 GMT [1844][client backend] [[unknown]][16/1:0] LOG:  connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117)
2024-12-11 13:39:33.331 GMT [1844][client backend] [[unknown]][16/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-12-11 13:39:33.334 GMT [1844][client backend] [015_stream.pl][16/2:0] LOG:  statement: SELECT count(*), count(c), count(d = 999) FROM test_tab
2024-12-11 13:39:33.348 GMT [1844][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.025 user=SYSTEM database=postgres host=[local]
2024-12-11 13:39:33.509 GMT [5816][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-12-11 13:39:33.511 GMT [5816][client backend] [[unknown]][17/1:0] LOG:  connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117)
2024-12-11 13:39:33.511 GMT [5816][client backend] [[unknown]][17/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-12-11 13:39:33.514 GMT [5816][client backend] [015_stream.pl][17/2:0] LOG:  statement: UPDATE test_tab SET c = 'epoch'::timestamptz + 987654321 * interval '1s'
2024-12-11 13:39:33.567 GMT [5816][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.061 user=SYSTEM database=postgres host=[local]
2024-12-11 13:39:34.063 GMT [1820][logical replication parallel worker] DEBUG:  applied 399 changes in the streaming chunk
2024-12-11 13:39:34.063 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 758
2024-12-11 13:39:34.078 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:34.078 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 758
2024-12-11 13:39:34.091 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:34.091 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 758
2024-12-11 13:39:34.103 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:34.103 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 758
2024-12-11 13:39:34.118 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:34.118 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 758
2024-12-11 13:39:34.138 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:34.138 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 758
2024-12-11 13:39:34.151 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:34.151 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 758
2024-12-11 13:39:34.169 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:34.169 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 758
2024-12-11 13:39:34.185 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:34.185 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 758
2024-12-11 13:39:34.199 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:34.199 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 758
2024-12-11 13:39:34.213 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:34.213 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 758
2024-12-11 13:39:34.233 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:34.233 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 758
2024-12-11 13:39:34.249 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:34.249 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 758
2024-12-11 13:39:34.300 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:34.300 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 758
2024-12-11 13:39:34.320 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:34.320 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 758
2024-12-11 13:39:34.369 GMT [1820][logical replication parallel worker] DEBUG:  applied 398 changes in the streaming chunk
2024-12-11 13:39:34.369 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 758
2024-12-11 13:39:34.425 GMT [1820][logical replication parallel worker] DEBUG:  applied 299 changes in the streaming chunk
2024-12-11 13:39:34.425 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 758
2024-12-11 13:39:34.426 GMT [1820][logical replication parallel worker] DEBUG:  finished processing the STREAM COMMIT command
2024-12-11 13:39:34.426 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM COMMIT" in transaction 758, finished at 0/225DEA8
2024-12-11 13:39:34.953 GMT [4092][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-12-11 13:39:34.955 GMT [4092][client backend] [[unknown]][18/1:0] LOG:  connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117)
2024-12-11 13:39:34.955 GMT [4092][client backend] [[unknown]][18/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-12-11 13:39:34.960 GMT [4092][client backend] [015_stream.pl][18/2:0] LOG:  statement: SELECT count(*), count(extract(epoch from c) = 987654321), count(d = 999) FROM test_tab
2024-12-11 13:39:35.034 GMT [4092][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.088 user=SYSTEM database=postgres host=[local]
2024-12-11 13:39:35.216 GMT [1820][logical replication parallel worker] DEBUG:  applied 498 changes in the streaming chunk
2024-12-11 13:39:35.216 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 759
2024-12-11 13:39:35.225 GMT [1820][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:35.225 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 759
2024-12-11 13:39:35.236 GMT [1820][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:35.236 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 759
2024-12-11 13:39:35.251 GMT [1820][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:35.251 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 759
2024-12-11 13:39:35.264 GMT [1820][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:35.264 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 759
2024-12-11 13:39:35.276 GMT [1820][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:35.276 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 759
2024-12-11 13:39:35.288 GMT [1820][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:35.288 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 759
2024-12-11 13:39:35.298 GMT [1820][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:35.298 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 759
2024-12-11 13:39:35.316 GMT [1820][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:35.316 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 759
2024-12-11 13:39:35.330 GMT [1820][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:35.330 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 759
2024-12-11 13:39:35.341 GMT [1820][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:35.341 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 759
2024-12-11 13:39:35.355 GMT [1820][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:35.355 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 759
2024-12-11 13:39:35.369 GMT [1820][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:35.369 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 759
2024-12-11 13:39:35.374 GMT [1820][logical replication parallel worker] DEBUG:  applied 204 changes in the streaming chunk
2024-12-11 13:39:35.374 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 759
2024-12-11 13:39:35.374 GMT [1820][logical replication parallel worker] DEBUG:  finished processing the STREAM COMMIT command
2024-12-11 13:39:35.374 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM COMMIT" in transaction 759, finished at 0/22C89B0
2024-12-11 13:39:35.896 GMT [1968][postmaster] LOG:  received SIGHUP, reloading configuration files
2024-12-11 13:39:35.898 GMT [1968][postmaster] LOG:  parameter "deadlock_timeout" changed to "10ms"
2024-12-11 13:39:36.076 GMT [4008][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-12-11 13:39:36.078 GMT [4008][client backend] [[unknown]][19/1:0] LOG:  connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117)
2024-12-11 13:39:36.078 GMT [4008][client backend] [[unknown]][19/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-12-11 13:39:36.111 GMT [4008][client backend] [015_stream.pl][19/2:0] LOG:  statement: SELECT 1
2024-12-11 13:39:36.115 GMT [4008][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.050 user=SYSTEM database=postgres host=[local]
2024-12-11 13:39:37.087 GMT [1820][logical replication parallel worker] DEBUG:  applied 498 changes in the streaming chunk
2024-12-11 13:39:37.087 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 760
2024-12-11 13:39:37.094 GMT [1820][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:37.094 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 760
2024-12-11 13:39:37.100 GMT [1820][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:37.100 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 760
2024-12-11 13:39:37.106 GMT [1820][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:37.106 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 760
2024-12-11 13:39:37.112 GMT [1820][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:37.112 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 760
2024-12-11 13:39:37.119 GMT [1820][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:37.119 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 760
2024-12-11 13:39:37.125 GMT [1820][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:37.125 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 760
2024-12-11 13:39:37.131 GMT [1820][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:37.131 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 760
2024-12-11 13:39:37.138 GMT [1820][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:37.138 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 760
2024-12-11 13:39:37.156 GMT [1820][logical replication parallel worker] LOG:  process 1820 still waiting for AccessShareLock on remote transaction 760 of subscription 16398 of database 5 after 17.568 ms
2024-12-11 13:39:37.156 GMT [1820][logical replication parallel worker] DETAIL:  Process holding the lock: 4176. Wait queue: 1820.
2024-12-11 13:39:37.156 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 760
2024-12-11 13:39:37.274 GMT [1820][logical replication parallel worker] LOG:  process 1820 acquired AccessShareLock on remote transaction 760 of subscription 16398 of database 5 after 135.179 ms
2024-12-11 13:39:37.274 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 760
2024-12-11 13:39:37.282 GMT [1820][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:37.282 GMT [1820][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 760
2024-12-11 13:39:37.292 GMT [4176][logical replication apply worker] LOG:  process 4176 detected deadlock while waiting for ShareLock on transaction 775 after 15.216 ms
2024-12-11 13:39:37.292 GMT [4176][logical replication apply worker] DETAIL:  Process holding the lock: 1820. Wait queue: .
2024-12-11 13:39:37.292 GMT [4176][logical replication apply worker] CONTEXT:  while inserting index tuple (0,1) in relation "test_tab_2"
	processing remote data for replication origin "pg_16398" during message type "INSERT" for replication target relation "public.test_tab_2" in transaction 761, finished at 0/2316FC8
2024-12-11 13:39:37.292 GMT [4176][logical replication apply worker] ERROR:  deadlock detected
2024-12-11 13:39:37.292 GMT [4176][logical replication apply worker] DETAIL:  Process 4176 waits for ShareLock on transaction 775; blocked by process 1820.
	Process 1820 waits for AccessShareLock on remote transaction 760 of subscription 16398 of database 5; blocked by process 4176.
	Process 4176: <command string not enabled>
	Process 1820: <command string not enabled>
2024-12-11 13:39:37.292 GMT [4176][logical replication apply worker] HINT:  See server log for query details.
2024-12-11 13:39:37.292 GMT [4176][logical replication apply worker] CONTEXT:  while inserting index tuple (0,1) in relation "test_tab_2"
	processing remote data for replication origin "pg_16398" during message type "INSERT" for replication target relation "public.test_tab_2" in transaction 761, finished at 0/2316FC8
2024-12-11 13:39:37.292 GMT [1820][logical replication parallel worker] FATAL:  terminating logical replication worker due to administrator command
2024-12-11 13:39:37.307 GMT [5412][logical replication launcher] DEBUG:  starting logical replication worker for subscription "tap_sub"
2024-12-11 13:39:37.308 GMT [1968][postmaster] DEBUG:  registering background worker "logical replication apply worker for subscription 16398"
2024-12-11 13:39:37.308 GMT [1968][postmaster] DEBUG:  starting background worker process "logical replication apply worker for subscription 16398"
2024-12-11 13:39:37.311 GMT [1968][postmaster] DEBUG:  unregistering background worker "logical replication parallel apply worker for subscription 16398"
2024-12-11 13:39:37.311 GMT [1968][postmaster] LOG:  background worker "logical replication parallel worker" (PID 1820) exited with exit code 1
2024-12-11 13:39:37.332 GMT [2112][logical replication apply worker] LOG:  logical replication apply worker for subscription "tap_sub" has started
2024-12-11 13:39:37.332 GMT [2112][logical replication apply worker] DEBUG:  connecting to publisher using connection string "port=27579 host=C:/Windows/TEMP/TY7Rev6di5 dbname=postgres application_name=tap_sub"
2024-12-11 13:39:37.387 GMT [1968][postmaster] DEBUG:  unregistering background worker "logical replication apply worker for subscription 16398"
2024-12-11 13:39:37.387 GMT [1968][postmaster] LOG:  background worker "logical replication apply worker" (PID 4176) exited with exit code 1
2024-12-11 13:39:37.398 GMT [2112][logical replication apply worker] DEBUG:  logical replication apply worker for subscription "tap_sub" two_phase is DISABLED
2024-12-11 13:39:37.469 GMT [6260][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-12-11 13:39:37.476 GMT [6260][client backend] [[unknown]][20/1:0] LOG:  connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117)
2024-12-11 13:39:37.476 GMT [6260][client backend] [[unknown]][20/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-12-11 13:39:37.494 GMT [6260][client backend] [015_stream.pl][20/2:0] LOG:  statement: DROP INDEX idx_tab
2024-12-11 13:39:37.509 GMT [6260][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.043 user=SYSTEM database=postgres host=[local]
2024-12-11 13:39:37.660 GMT [2112][logical replication apply worker] DEBUG:  starting logical replication worker for subscription "tap_sub"
2024-12-11 13:39:37.660 GMT [2112][logical replication apply worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM START" in transaction 760
2024-12-11 13:39:37.660 GMT [1968][postmaster] DEBUG:  registering background worker "logical replication parallel apply worker for subscription 16398"
2024-12-11 13:39:37.660 GMT [1968][postmaster] DEBUG:  starting background worker process "logical replication parallel apply worker for subscription 16398"
2024-12-11 13:39:37.717 GMT [6624][logical replication parallel worker] LOG:  logical replication apply worker for subscription "tap_sub" has started
2024-12-11 13:39:37.746 GMT [6624][logical replication parallel worker] DEBUG:  applied 4971 changes in the streaming chunk
2024-12-11 13:39:37.746 GMT [6624][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 760
2024-12-11 13:39:37.746 GMT [6624][logical replication parallel worker] DEBUG:  applied 30 changes in the streaming chunk
2024-12-11 13:39:37.746 GMT [6624][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 760
2024-12-11 13:39:37.746 GMT [6624][logical replication parallel worker] DEBUG:  finished processing the STREAM COMMIT command
2024-12-11 13:39:37.746 GMT [6624][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM COMMIT" in transaction 760, finished at 0/2316FF8
2024-12-11 13:39:38.273 GMT [1444][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-12-11 13:39:38.281 GMT [1444][client backend] [[unknown]][21/1:0] LOG:  connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117)
2024-12-11 13:39:38.281 GMT [1444][client backend] [[unknown]][21/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-12-11 13:39:38.292 GMT [1444][client backend] [015_stream.pl][21/2:0] LOG:  statement: SELECT count(*) FROM test_tab_2
2024-12-11 13:39:38.299 GMT [1444][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.032 user=SYSTEM database=postgres host=[local]
2024-12-11 13:39:39.197 GMT [5596][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-12-11 13:39:39.199 GMT [5596][client backend] [[unknown]][22/1:0] LOG:  connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117)
2024-12-11 13:39:39.199 GMT [5596][client backend] [[unknown]][22/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-12-11 13:39:39.202 GMT [5596][client backend] [015_stream.pl][22/2:0] LOG:  statement: CREATE UNIQUE INDEX idx_tab on test_tab_2(a)
2024-12-11 13:39:39.206 GMT [5596][client backend] [015_stream.pl][22/2:781] DEBUG:  building index "idx_tab" on table "test_tab_2" serially
2024-12-11 13:39:39.206 GMT [5596][client backend] [015_stream.pl][22/2:781] DEBUG:  index "idx_tab" can safely use deduplication
2024-12-11 13:39:39.208 GMT [5596][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.016 user=SYSTEM database=postgres host=[local]
2024-12-11 13:39:39.616 GMT [6624][logical replication parallel worker] DEBUG:  applied 498 changes in the streaming chunk
2024-12-11 13:39:39.616 GMT [6624][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 763
2024-12-11 13:39:39.622 GMT [6624][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:39.622 GMT [6624][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 763
2024-12-11 13:39:39.628 GMT [6624][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:39.628 GMT [6624][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 763
2024-12-11 13:39:39.635 GMT [6624][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:39.635 GMT [6624][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 763
2024-12-11 13:39:39.641 GMT [6624][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:39.641 GMT [6624][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 763
2024-12-11 13:39:39.647 GMT [6624][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:39.647 GMT [6624][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 763
2024-12-11 13:39:39.653 GMT [6624][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:39.653 GMT [6624][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 763
2024-12-11 13:39:39.659 GMT [6624][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:39.659 GMT [6624][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 763
2024-12-11 13:39:39.665 GMT [6624][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:39.665 GMT [6624][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 763
2024-12-11 13:39:39.717 GMT [6624][logical replication parallel worker] LOG:  process 6624 still waiting for AccessShareLock on remote transaction 763 of subscription 16398 of database 5 after 51.222 ms
2024-12-11 13:39:39.717 GMT [6624][logical replication parallel worker] DETAIL:  Process holding the lock: 2112. Wait queue: 6624.
2024-12-11 13:39:39.717 GMT [6624][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 763
2024-12-11 13:39:39.820 GMT [6624][logical replication parallel worker] LOG:  process 6624 acquired AccessShareLock on remote transaction 763 of subscription 16398 of database 5 after 154.457 ms
2024-12-11 13:39:39.820 GMT [6624][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 763
2024-12-11 13:39:39.825 GMT [2112][logical replication apply worker] DEBUG:  starting logical replication worker for subscription "tap_sub"
2024-12-11 13:39:39.825 GMT [2112][logical replication apply worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM START" in transaction 764
2024-12-11 13:39:39.826 GMT [1968][postmaster] DEBUG:  registering background worker "logical replication parallel apply worker for subscription 16398"
2024-12-11 13:39:39.826 GMT [1968][postmaster] DEBUG:  starting background worker process "logical replication parallel apply worker for subscription 16398"
2024-12-11 13:39:39.828 GMT [6624][logical replication parallel worker] DEBUG:  applied 497 changes in the streaming chunk
2024-12-11 13:39:39.828 GMT [6624][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 763
2024-12-11 13:39:39.844 GMT [6624][logical replication parallel worker] LOG:  process 6624 still waiting for AccessShareLock on remote transaction 763 of subscription 16398 of database 5 after 15.802 ms
2024-12-11 13:39:39.844 GMT [6624][logical replication parallel worker] DETAIL:  Process holding the lock: 2112. Wait queue: 6624.
2024-12-11 13:39:39.844 GMT [6624][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 763
2024-12-11 13:39:39.864 GMT [3852][logical replication parallel worker] LOG:  logical replication apply worker for subscription "tap_sub" has started
2024-12-11 13:39:39.891 GMT [2112][logical replication apply worker] LOG:  process 2112 detected deadlock while waiting for AccessShareLock on remote transaction 764 of subscription 16398 of database 5 after 18.370 ms
2024-12-11 13:39:39.891 GMT [2112][logical replication apply worker] DETAIL:  Process holding the lock: 3852. Wait queue: .
2024-12-11 13:39:39.891 GMT [2112][logical replication apply worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM COMMIT" in transaction 764, finished at 0/23B3E98
2024-12-11 13:39:39.891 GMT [2112][logical replication apply worker] ERROR:  deadlock detected
2024-12-11 13:39:39.891 GMT [2112][logical replication apply worker] DETAIL:  Process 2112 waits for AccessShareLock on remote transaction 764 of subscription 16398 of database 5; blocked by process 3852.
	Process 3852 waits for ShareLock on transaction 782; blocked by process 6624.
	Process 6624 waits for AccessShareLock on remote transaction 763 of subscription 16398 of database 5; blocked by process 2112.
	Process 2112: <command string not enabled>
	Process 3852: <command string not enabled>
	Process 6624: <command string not enabled>
2024-12-11 13:39:39.891 GMT [2112][logical replication apply worker] HINT:  See server log for query details.
2024-12-11 13:39:39.891 GMT [2112][logical replication apply worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM COMMIT" in transaction 764, finished at 0/23B3E98
2024-12-11 13:39:39.892 GMT [6624][logical replication parallel worker] FATAL:  terminating logical replication worker due to administrator command
2024-12-11 13:39:39.892 GMT [6624][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 763
2024-12-11 13:39:39.899 GMT [3852][logical replication parallel worker] DEBUG:  applied 468 changes in the streaming chunk
2024-12-11 13:39:39.899 GMT [3852][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 764
2024-12-11 13:39:39.905 GMT [3852][logical replication parallel worker] DEBUG:  applied 467 changes in the streaming chunk
2024-12-11 13:39:39.905 GMT [3852][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 764
2024-12-11 13:39:39.911 GMT [3852][logical replication parallel worker] FATAL:  terminating logical replication worker due to administrator command
2024-12-11 13:39:39.925 GMT [5412][logical replication launcher] DEBUG:  starting logical replication worker for subscription "tap_sub"
2024-12-11 13:39:39.925 GMT [1968][postmaster] DEBUG:  registering background worker "logical replication apply worker for subscription 16398"
2024-12-11 13:39:39.925 GMT [1968][postmaster] DEBUG:  starting background worker process "logical replication apply worker for subscription 16398"
2024-12-11 13:39:39.971 GMT [1968][postmaster] DEBUG:  unregistering background worker "logical replication apply worker for subscription 16398"
2024-12-11 13:39:39.971 GMT [1968][postmaster] LOG:  background worker "logical replication apply worker" (PID 2112) exited with exit code 1
2024-12-11 13:39:39.971 GMT [1968][postmaster] DEBUG:  unregistering background worker "logical replication parallel apply worker for subscription 16398"
2024-12-11 13:39:39.971 GMT [1968][postmaster] LOG:  background worker "logical replication parallel worker" (PID 6624) exited with exit code 1
2024-12-11 13:39:39.972 GMT [6888][logical replication apply worker] LOG:  logical replication apply worker for subscription "tap_sub" has started
2024-12-11 13:39:39.972 GMT [6888][logical replication apply worker] DEBUG:  connecting to publisher using connection string "port=27579 host=C:/Windows/TEMP/TY7Rev6di5 dbname=postgres application_name=tap_sub"
2024-12-11 13:39:39.986 GMT [1968][postmaster] DEBUG:  unregistering background worker "logical replication parallel apply worker for subscription 16398"
2024-12-11 13:39:39.986 GMT [1968][postmaster] LOG:  background worker "logical replication parallel worker" (PID 3852) exited with exit code 1
2024-12-11 13:39:40.057 GMT [6888][logical replication apply worker] DEBUG:  logical replication apply worker for subscription "tap_sub" two_phase is DISABLED
2024-12-11 13:39:40.162 GMT [6152][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-12-11 13:39:40.164 GMT [6152][client backend] [[unknown]][23/1:0] LOG:  connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117)
2024-12-11 13:39:40.164 GMT [6152][client backend] [[unknown]][23/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-12-11 13:39:40.172 GMT [6152][client backend] [015_stream.pl][23/2:0] LOG:  statement: DROP INDEX idx_tab
2024-12-11 13:39:40.175 GMT [6152][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.019 user=SYSTEM database=postgres host=[local]
2024-12-11 13:39:40.376 GMT [6888][logical replication apply worker] DEBUG:  starting logical replication worker for subscription "tap_sub"
2024-12-11 13:39:40.376 GMT [6888][logical replication apply worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM START" in transaction 764
2024-12-11 13:39:40.377 GMT [1968][postmaster] DEBUG:  registering background worker "logical replication parallel apply worker for subscription 16398"
2024-12-11 13:39:40.377 GMT [1968][postmaster] DEBUG:  starting background worker process "logical replication parallel apply worker for subscription 16398"
2024-12-11 13:39:40.433 GMT [4648][logical replication parallel worker] LOG:  logical replication apply worker for subscription "tap_sub" has started
2024-12-11 13:39:40.463 GMT [4648][logical replication parallel worker] DEBUG:  applied 5001 changes in the streaming chunk
2024-12-11 13:39:40.463 GMT [4648][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM STOP" in transaction 764
2024-12-11 13:39:40.463 GMT [4648][logical replication parallel worker] DEBUG:  finished processing the STREAM COMMIT command
2024-12-11 13:39:40.463 GMT [4648][logical replication parallel worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM COMMIT" in transaction 764, finished at 0/23B3E98
2024-12-11 13:39:40.938 GMT [5980][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-12-11 13:39:40.940 GMT [5980][client backend] [[unknown]][24/1:0] LOG:  connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117)
2024-12-11 13:39:40.940 GMT [5980][client backend] [[unknown]][24/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-12-11 13:39:40.954 GMT [5980][client backend] [015_stream.pl][24/2:0] LOG:  statement: SELECT count(*) FROM test_tab_2
2024-12-11 13:39:40.962 GMT [5980][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.027 user=SYSTEM database=postgres host=[local]
2024-12-11 13:39:41.048 GMT [1968][postmaster] LOG:  received SIGHUP, reloading configuration files
2024-12-11 13:39:41.050 GMT [1968][postmaster] LOG:  parameter "debug_logical_replication_streaming" changed to "immediate"
2024-12-11 13:39:41.050 GMT [1968][postmaster] LOG:  parameter "log_min_messages" changed to "warning"
2024-12-11 13:39:41.220 GMT [3164][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-12-11 13:39:41.222 GMT [3164][client backend] [[unknown]][25/1:0] LOG:  connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117)
2024-12-11 13:39:41.222 GMT [3164][client backend] [[unknown]][25/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-12-11 13:39:41.226 GMT [3164][client backend] [015_stream.pl][25/2:0] LOG:  statement: SELECT 1
2024-12-11 13:39:41.230 GMT [3164][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.013 user=SYSTEM database=postgres host=[local]
2024-12-11 13:39:41.422 GMT [6888][logical replication apply worker] LOG:  logical replication apply worker will serialize the remaining changes of remote transaction 765 to a file
2024-12-11 13:39:41.422 GMT [6888][logical replication apply worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM START" in transaction 765
2024-12-11 13:39:42.074 GMT [6888][logical replication apply worker] LOG:  process 6888 still waiting for AccessShareLock on remote transaction 765 of subscription 16398 of database 5 after 19.038 ms
2024-12-11 13:39:42.074 GMT [6888][logical replication apply worker] DETAIL:  Process holding the lock: 4648. Wait queue: 6888.
2024-12-11 13:39:42.074 GMT [6888][logical replication apply worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM COMMIT" in transaction 765, finished at 0/24024B8
2024-12-11 13:39:42.119 GMT [6888][logical replication apply worker] LOG:  process 6888 acquired AccessShareLock on remote transaction 765 of subscription 16398 of database 5 after 63.928 ms
2024-12-11 13:39:42.119 GMT [6888][logical replication apply worker] CONTEXT:  processing remote data for replication origin "pg_16398" during message type "STREAM COMMIT" in transaction 765, finished at 0/24024B8
2024-12-11 13:39:42.119 GMT [4648][logical replication parallel worker] LOG:  logical replication parallel apply worker for subscription "tap_sub" has finished
2024-12-11 13:39:42.519 GMT [6780][not initialized] [[unknown]][:0] LOG:  connection received: host=[local]
2024-12-11 13:39:42.520 GMT [6780][client backend] [[unknown]][26/1:0] LOG:  connection authenticated: user="SYSTEM" method=trust (C:/cirrus/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117)
2024-12-11 13:39:42.520 GMT [6780][client backend] [[unknown]][26/1:0] LOG:  connection authorized: user=SYSTEM database=postgres application_name=015_stream.pl
2024-12-11 13:39:42.524 GMT [6780][client backend] [015_stream.pl][26/2:0] LOG:  statement: SELECT count(*) FROM test_tab_2
2024-12-11 13:39:42.531 GMT [6780][client backend] [015_stream.pl][:0] LOG:  disconnection: session time: 0:00:00.017 user=SYSTEM database=postgres host=[local]
2024-12-11 13:39:42.588 GMT [1968][postmaster] LOG:  received fast shutdown request
2024-12-11 13:39:42.589 GMT [1968][postmaster] LOG:  aborting any active transactions
TRAP: failed Assert("(remainMask.mask | targetMask.mask) == BTYPE_MASK_ALL.mask"), File: "../src/backend/postmaster/postmaster.c", Line: 2899, PID: 1968
abort() has been called