2024-03-12 11:40:38.391 UTC [48804][postmaster] LOG: starting PostgreSQL 17devel on x86_64-linux, compiled by gcc-10.2.1, 64-bit 2024-03-12 11:40:38.391 UTC [48804][postmaster] LOG: listening on Unix socket "/tmp/3olC9SZ3Vm/.s.PGSQL.54315" 2024-03-12 11:40:38.400 UTC [48813][startup] LOG: database system was shut down at 2024-03-12 11:38:30 UTC 2024-03-12 11:40:38.405 UTC [48804][postmaster] LOG: database system is ready to accept connections 2024-03-12 11:40:38.585 UTC [48877][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-03-12 11:40:38.586 UTC [48877][client backend] [[unknown]][0/1:0] LOG: connection authenticated: user="postgres" method=trust (/tmp/cirrus-ci-build/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117) 2024-03-12 11:40:38.586 UTC [48877][client backend] [[unknown]][0/1:0] LOG: connection authorized: user=postgres database=postgres application_name=015_stream.pl 2024-03-12 11:40:38.590 UTC [48877][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-03-12 11:40:38.596 UTC [48877][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.010 user=postgres database=postgres host=[local] 2024-03-12 11:40:38.614 UTC [48889][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-03-12 11:40:38.614 UTC [48889][client backend] [[unknown]][1/1:0] LOG: connection authenticated: user="postgres" method=trust (/tmp/cirrus-ci-build/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117) 2024-03-12 11:40:38.614 UTC [48889][client backend] [[unknown]][1/1:0] LOG: connection authorized: user=postgres database=postgres application_name=015_stream.pl 2024-03-12 11:40:38.615 UTC [48889][client backend] [015_stream.pl][1/2:0] LOG: statement: CREATE TABLE test_tab_2 (a int) 2024-03-12 11:40:38.617 UTC [48889][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.003 user=postgres database=postgres host=[local] 2024-03-12 11:40:38.636 UTC [48900][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-03-12 11:40:38.636 UTC [48900][client backend] [[unknown]][2/1:0] LOG: connection authenticated: user="postgres" method=trust (/tmp/cirrus-ci-build/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117) 2024-03-12 11:40:38.636 UTC [48900][client backend] [[unknown]][2/1:0] LOG: connection authorized: user=postgres database=postgres application_name=015_stream.pl 2024-03-12 11:40:38.638 UTC [48900][client backend] [015_stream.pl][2/2:0] LOG: statement: CREATE UNIQUE INDEX idx_tab on test_tab_2(a) 2024-03-12 11:40:38.642 UTC [48900][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.006 user=postgres database=postgres host=[local] 2024-03-12 11:40:38.665 UTC [48923][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-03-12 11:40:38.666 UTC [48923][client backend] [[unknown]][3/1:0] LOG: connection authenticated: user="postgres" method=trust (/tmp/cirrus-ci-build/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117) 2024-03-12 11:40:38.666 UTC [48923][client backend] [[unknown]][3/1:0] LOG: connection authorized: user=postgres database=postgres application_name=015_stream.pl 2024-03-12 11:40:38.666 UTC [48923][client backend] [015_stream.pl][3/2:0] LOG: statement: CREATE SUBSCRIPTION tap_sub CONNECTION 'port=54314 host=/tmp/3olC9SZ3Vm dbname=postgres application_name=tap_sub' PUBLICATION tap_pub WITH (streaming = on) 2024-03-12 11:40:38.676 UTC [48923][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.011 user=postgres database=postgres host=[local] 2024-03-12 11:40:38.683 UTC [48933][logical replication apply worker] LOG: logical replication apply worker for subscription "tap_sub" has started 2024-03-12 11:40:38.688 UTC [48940][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-03-12 11:40:38.693 UTC [48941][logical replication tablesync worker] LOG: logical replication table synchronization worker for subscription "tap_sub", table "test_tab_2" has started 2024-03-12 11:40:38.693 UTC [48940][client backend] [[unknown]][4/1:0] LOG: connection authenticated: user="postgres" method=trust (/tmp/cirrus-ci-build/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117) 2024-03-12 11:40:38.693 UTC [48940][client backend] [[unknown]][4/1:0] LOG: connection authorized: user=postgres database=postgres application_name=015_stream.pl 2024-03-12 11:40:38.694 UTC [48940][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-03-12 11:40:38.695 UTC [48940][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.008 user=postgres database=postgres host=[local] 2024-03-12 11:40:38.708 UTC [48946][logical replication tablesync worker] LOG: logical replication table synchronization worker for subscription "tap_sub", table "test_tab" has started 2024-03-12 11:40:38.719 UTC [48941][logical replication tablesync worker] LOG: logical replication table synchronization worker for subscription "tap_sub", table "test_tab_2" has finished 2024-03-12 11:40:38.724 UTC [48946][logical replication tablesync worker] LOG: logical replication table synchronization worker for subscription "tap_sub", table "test_tab" has finished 2024-03-12 11:40:38.809 UTC [48991][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-03-12 11:40:38.810 UTC [48991][client backend] [[unknown]][5/1:0] LOG: connection authenticated: user="postgres" method=trust (/tmp/cirrus-ci-build/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117) 2024-03-12 11:40:38.810 UTC [48991][client backend] [[unknown]][5/1:0] LOG: connection authorized: user=postgres database=postgres application_name=015_stream.pl 2024-03-12 11:40:38.812 UTC [48991][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-03-12 11:40:38.823 UTC [48991][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.013 user=postgres database=postgres host=[local] 2024-03-12 11:40:38.906 UTC [49039][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-03-12 11:40:38.907 UTC [49039][client backend] [[unknown]][6/1:0] LOG: connection authenticated: user="postgres" method=trust (/tmp/cirrus-ci-build/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117) 2024-03-12 11:40:38.907 UTC [49039][client backend] [[unknown]][6/1:0] LOG: connection authorized: user=postgres database=postgres application_name=015_stream.pl 2024-03-12 11:40:38.908 UTC [49039][client backend] [015_stream.pl][6/2:0] LOG: statement: SELECT count(*), count(c), count(d = 999) FROM test_tab 2024-03-12 11:40:38.910 UTC [49039][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.003 user=postgres database=postgres host=[local] 2024-03-12 11:40:39.636 UTC [49303][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-03-12 11:40:39.641 UTC [49303][client backend] [[unknown]][7/1:0] LOG: connection authenticated: user="postgres" method=trust (/tmp/cirrus-ci-build/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117) 2024-03-12 11:40:39.641 UTC [49303][client backend] [[unknown]][7/1:0] LOG: connection authorized: user=postgres database=postgres application_name=015_stream.pl 2024-03-12 11:40:39.643 UTC [49303][client backend] [015_stream.pl][7/2:0] LOG: statement: SELECT count(*), count(c), count(d = 999) FROM test_tab 2024-03-12 11:40:39.646 UTC [49303][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.010 user=postgres database=postgres host=[local] 2024-03-12 11:40:39.664 UTC [49319][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-03-12 11:40:39.666 UTC [49319][client backend] [[unknown]][8/1:0] LOG: connection authenticated: user="postgres" method=trust (/tmp/cirrus-ci-build/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117) 2024-03-12 11:40:39.666 UTC [49319][client backend] [[unknown]][8/1:0] LOG: connection authorized: user=postgres database=postgres application_name=015_stream.pl 2024-03-12 11:40:39.666 UTC [49319][client backend] [015_stream.pl][8/2:0] LOG: statement: ALTER SUBSCRIPTION tap_sub SET (binary = on) 2024-03-12 11:40:39.667 UTC [48933][logical replication apply worker] LOG: logical replication worker for subscription "tap_sub" will restart because of a parameter change 2024-03-12 11:40:39.667 UTC [49319][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.006 user=postgres database=postgres host=[local] 2024-03-12 11:40:39.683 UTC [49325][logical replication apply worker] LOG: logical replication apply worker for subscription "tap_sub" has started 2024-03-12 11:40:40.107 UTC [49503][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-03-12 11:40:40.108 UTC [49503][client backend] [[unknown]][9/1:0] LOG: connection authenticated: user="postgres" method=trust (/tmp/cirrus-ci-build/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117) 2024-03-12 11:40:40.108 UTC [49503][client backend] [[unknown]][9/1:0] LOG: connection authorized: user=postgres database=postgres application_name=015_stream.pl 2024-03-12 11:40:40.109 UTC [49503][client backend] [015_stream.pl][9/2:0] LOG: statement: SELECT count(*), count(c), count(d = 999) FROM test_tab 2024-03-12 11:40:40.113 UTC [49503][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.005 user=postgres database=postgres host=[local] 2024-03-12 11:40:40.149 UTC [49521][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-03-12 11:40:40.149 UTC [49521][client backend] [[unknown]][10/1:0] LOG: connection authenticated: user="postgres" method=trust (/tmp/cirrus-ci-build/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117) 2024-03-12 11:40:40.149 UTC [49521][client backend] [[unknown]][10/1:0] LOG: connection authorized: user=postgres database=postgres application_name=015_stream.pl 2024-03-12 11:40:40.153 UTC [49521][client backend] [015_stream.pl][10/2:0] LOG: statement: UPDATE test_tab SET c = 'epoch'::timestamptz + 987654321 * interval '1s' 2024-03-12 11:40:40.177 UTC [49521][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.028 user=postgres database=postgres host=[local] 2024-03-12 11:40:40.433 UTC [49648][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-03-12 11:40:40.433 UTC [49648][client backend] [[unknown]][11/1:0] LOG: connection authenticated: user="postgres" method=trust (/tmp/cirrus-ci-build/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117) 2024-03-12 11:40:40.433 UTC [49648][client backend] [[unknown]][11/1:0] LOG: connection authorized: user=postgres database=postgres application_name=015_stream.pl 2024-03-12 11:40:40.437 UTC [49648][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-03-12 11:40:40.452 UTC [49648][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.019 user=postgres database=postgres host=[local] 2024-03-12 11:40:40.751 UTC [49757][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-03-12 11:40:40.751 UTC [49757][client backend] [[unknown]][12/1:0] LOG: connection authenticated: user="postgres" method=trust (/tmp/cirrus-ci-build/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117) 2024-03-12 11:40:40.751 UTC [49757][client backend] [[unknown]][12/1:0] LOG: connection authorized: user=postgres database=postgres application_name=015_stream.pl 2024-03-12 11:40:40.752 UTC [49757][client backend] [015_stream.pl][12/2:0] LOG: statement: ALTER SUBSCRIPTION tap_sub SET(streaming = parallel, binary = off) 2024-03-12 11:40:40.752 UTC [49325][logical replication apply worker] LOG: logical replication worker for subscription "tap_sub" will restart because of a parameter change 2024-03-12 11:40:40.758 UTC [49757][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.008 user=postgres database=postgres host=[local] 2024-03-12 11:40:40.762 UTC [49761][logical replication apply worker] LOG: logical replication apply worker for subscription "tap_sub" has started 2024-03-12 11:40:40.914 UTC [48804][postmaster] LOG: received SIGHUP, reloading configuration files 2024-03-12 11:40:40.915 UTC [48804][postmaster] LOG: parameter "log_min_messages" changed to "debug1" 2024-03-12 11:40:40.932 UTC [49821][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-03-12 11:40:40.932 UTC [49821][client backend] [[unknown]][13/1:0] LOG: connection authenticated: user="postgres" method=trust (/tmp/cirrus-ci-build/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117) 2024-03-12 11:40:40.932 UTC [49821][client backend] [[unknown]][13/1:0] LOG: connection authorized: user=postgres database=postgres application_name=015_stream.pl 2024-03-12 11:40:40.933 UTC [49821][client backend] [015_stream.pl][13/2:0] LOG: statement: SELECT 1 2024-03-12 11:40:40.936 UTC [49821][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.004 user=postgres database=postgres host=[local] 2024-03-12 11:40:40.984 UTC [49761][logical replication apply worker] DEBUG: starting logical replication worker for subscription "tap_sub" 2024-03-12 11:40:40.984 UTC [49761][logical replication apply worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM START" in transaction 747 2024-03-12 11:40:40.985 UTC [48804][postmaster] DEBUG: registering background worker "logical replication parallel apply worker for subscription 16397" 2024-03-12 11:40:40.985 UTC [48804][postmaster] DEBUG: starting background worker process "logical replication parallel apply worker for subscription 16397" 2024-03-12 11:40:40.994 UTC [49843][logical replication parallel worker] LOG: logical replication apply worker for subscription "tap_sub" has started 2024-03-12 11:40:41.004 UTC [49843][logical replication parallel worker] DEBUG: applied 399 changes in the streaming chunk 2024-03-12 11:40:41.004 UTC [49843][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 747 2024-03-12 11:40:41.014 UTC [49843][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.014 UTC [49843][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 747 2024-03-12 11:40:41.023 UTC [49843][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.023 UTC [49843][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 747 2024-03-12 11:40:41.032 UTC [49843][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.032 UTC [49843][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 747 2024-03-12 11:40:41.042 UTC [49843][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.042 UTC [49843][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 747 2024-03-12 11:40:41.051 UTC [49843][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.051 UTC [49843][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 747 2024-03-12 11:40:41.058 UTC [49843][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.058 UTC [49843][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 747 2024-03-12 11:40:41.063 UTC [49843][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.063 UTC [49843][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 747 2024-03-12 11:40:41.068 UTC [49843][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.068 UTC [49843][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 747 2024-03-12 11:40:41.073 UTC [49843][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.073 UTC [49843][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 747 2024-03-12 11:40:41.077 UTC [49843][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.077 UTC [49843][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 747 2024-03-12 11:40:41.082 UTC [49843][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.082 UTC [49843][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 747 2024-03-12 11:40:41.100 UTC [49843][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.100 UTC [49843][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 747 2024-03-12 11:40:41.112 UTC [49761][logical replication apply worker] DEBUG: starting logical replication worker for subscription "tap_sub" 2024-03-12 11:40:41.112 UTC [49761][logical replication apply worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM START" in transaction 748 2024-03-12 11:40:41.112 UTC [48804][postmaster] DEBUG: registering background worker "logical replication parallel apply worker for subscription 16397" 2024-03-12 11:40:41.112 UTC [48804][postmaster] DEBUG: starting background worker process "logical replication parallel apply worker for subscription 16397" 2024-03-12 11:40:41.123 UTC [49895][logical replication parallel worker] LOG: logical replication apply worker for subscription "tap_sub" has started 2024-03-12 11:40:41.131 UTC [49895][logical replication parallel worker] DEBUG: applied 322 changes in the streaming chunk 2024-03-12 11:40:41.131 UTC [49895][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 748 2024-03-12 11:40:41.136 UTC [49843][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.136 UTC [49843][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 747 2024-03-12 11:40:41.139 UTC [49895][logical replication parallel worker] DEBUG: applied 321 changes in the streaming chunk 2024-03-12 11:40:41.139 UTC [49895][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 748 2024-03-12 11:40:41.143 UTC [49895][logical replication parallel worker] DEBUG: applied 321 changes in the streaming chunk 2024-03-12 11:40:41.143 UTC [49895][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 748 2024-03-12 11:40:41.159 UTC [49895][logical replication parallel worker] DEBUG: applied 321 changes in the streaming chunk 2024-03-12 11:40:41.159 UTC [49895][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 748 2024-03-12 11:40:41.162 UTC [49843][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.162 UTC [49843][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 747 2024-03-12 11:40:41.169 UTC [49895][logical replication parallel worker] DEBUG: applied 321 changes in the streaming chunk 2024-03-12 11:40:41.169 UTC [49895][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 748 2024-03-12 11:40:41.182 UTC [49895][logical replication parallel worker] DEBUG: applied 321 changes in the streaming chunk 2024-03-12 11:40:41.182 UTC [49895][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 748 2024-03-12 11:40:41.185 UTC [49843][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.185 UTC [49843][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 747 2024-03-12 11:40:41.196 UTC [49895][logical replication parallel worker] DEBUG: applied 321 changes in the streaming chunk 2024-03-12 11:40:41.196 UTC [49895][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 748 2024-03-12 11:40:41.202 UTC [49843][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.202 UTC [49843][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 747 2024-03-12 11:40:41.206 UTC [49895][logical replication parallel worker] DEBUG: applied 321 changes in the streaming chunk 2024-03-12 11:40:41.206 UTC [49895][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 748 2024-03-12 11:40:41.216 UTC [49895][logical replication parallel worker] DEBUG: applied 321 changes in the streaming chunk 2024-03-12 11:40:41.216 UTC [49895][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 748 2024-03-12 11:40:41.216 UTC [49843][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.216 UTC [49843][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 747 2024-03-12 11:40:41.220 UTC [49895][logical replication parallel worker] DEBUG: applied 321 changes in the streaming chunk 2024-03-12 11:40:41.220 UTC [49895][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 748 2024-03-12 11:40:41.223 UTC [49843][logical replication parallel worker] DEBUG: applied 413 changes in the streaming chunk 2024-03-12 11:40:41.223 UTC [49843][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 747 2024-03-12 11:40:41.238 UTC [49895][logical replication parallel worker] DEBUG: applied 321 changes in the streaming chunk 2024-03-12 11:40:41.238 UTC [49895][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 748 2024-03-12 11:40:41.240 UTC [49843][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:41.240 UTC [49843][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 747 2024-03-12 11:40:41.243 UTC [49895][logical replication parallel worker] DEBUG: applied 321 changes in the streaming chunk 2024-03-12 11:40:41.243 UTC [49895][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 748 2024-03-12 11:40:41.250 UTC [49895][logical replication parallel worker] DEBUG: applied 321 changes in the streaming chunk 2024-03-12 11:40:41.250 UTC [49895][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 748 2024-03-12 11:40:41.254 UTC [49895][logical replication parallel worker] DEBUG: applied 321 changes in the streaming chunk 2024-03-12 11:40:41.254 UTC [49895][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 748 2024-03-12 11:40:41.254 UTC [49843][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:41.254 UTC [49843][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 747 2024-03-12 11:40:41.261 UTC [49843][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:41.261 UTC [49843][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 747 2024-03-12 11:40:41.264 UTC [49895][logical replication parallel worker] DEBUG: applied 321 changes in the streaming chunk 2024-03-12 11:40:41.264 UTC [49895][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 748 2024-03-12 11:40:41.271 UTC [49895][logical replication parallel worker] DEBUG: applied 355 changes in the streaming chunk 2024-03-12 11:40:41.271 UTC [49895][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 748 2024-03-12 11:40:41.275 UTC [49895][logical replication parallel worker] DEBUG: applied 401 changes in the streaming chunk 2024-03-12 11:40:41.275 UTC [49895][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 748 2024-03-12 11:40:41.282 UTC [49895][logical replication parallel worker] DEBUG: applied 401 changes in the streaming chunk 2024-03-12 11:40:41.282 UTC [49895][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 748 2024-03-12 11:40:41.289 UTC [49895][logical replication parallel worker] DEBUG: applied 401 changes in the streaming chunk 2024-03-12 11:40:41.289 UTC [49895][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 748 2024-03-12 11:40:41.301 UTC [49895][logical replication parallel worker] DEBUG: applied 401 changes in the streaming chunk 2024-03-12 11:40:41.301 UTC [49895][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 748 2024-03-12 11:40:41.306 UTC [49895][logical replication parallel worker] DEBUG: applied 401 changes in the streaming chunk 2024-03-12 11:40:41.306 UTC [49895][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 748 2024-03-12 11:40:41.317 UTC [49895][logical replication parallel worker] DEBUG: applied 401 changes in the streaming chunk 2024-03-12 11:40:41.317 UTC [49895][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 748 2024-03-12 11:40:41.323 UTC [49895][logical replication parallel worker] DEBUG: applied 401 changes in the streaming chunk 2024-03-12 11:40:41.323 UTC [49895][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 748 2024-03-12 11:40:41.329 UTC [49895][logical replication parallel worker] DEBUG: applied 401 changes in the streaming chunk 2024-03-12 11:40:41.329 UTC [49895][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 748 2024-03-12 11:40:41.333 UTC [49895][logical replication parallel worker] DEBUG: applied 401 changes in the streaming chunk 2024-03-12 11:40:41.333 UTC [49895][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 748 2024-03-12 11:40:41.350 UTC [49895][logical replication parallel worker] DEBUG: applied 401 changes in the streaming chunk 2024-03-12 11:40:41.350 UTC [49895][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 748 2024-03-12 11:40:41.363 UTC [49895][logical replication parallel worker] DEBUG: applied 401 changes in the streaming chunk 2024-03-12 11:40:41.363 UTC [49895][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 748 2024-03-12 11:40:41.375 UTC [49895][logical replication parallel worker] DEBUG: applied 401 changes in the streaming chunk 2024-03-12 11:40:41.375 UTC [49895][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 748 2024-03-12 11:40:41.375 UTC [49895][logical replication parallel worker] DEBUG: applied 16 changes in the streaming chunk 2024-03-12 11:40:41.375 UTC [49895][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 748 2024-03-12 11:40:41.375 UTC [49895][logical replication parallel worker] DEBUG: finished processing the STREAM COMMIT command 2024-03-12 11:40:41.375 UTC [49895][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM COMMIT" in transaction 748, finished at 0/1D858D0 2024-03-12 11:40:41.378 UTC [49895][logical replication parallel worker] LOG: logical replication parallel apply worker for subscription "tap_sub" has finished 2024-03-12 11:40:41.380 UTC [48804][postmaster] DEBUG: unregistering background worker "logical replication parallel apply worker for subscription 16397" 2024-03-12 11:40:41.381 UTC [48804][postmaster] DEBUG: background worker "logical replication parallel worker" (PID 49895) exited with exit code 0 2024-03-12 11:40:41.383 UTC [49843][logical replication parallel worker] DEBUG: applied 96 changes in the streaming chunk 2024-03-12 11:40:41.383 UTC [49843][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 747 2024-03-12 11:40:41.383 UTC [49843][logical replication parallel worker] DEBUG: finished processing the STREAM COMMIT command 2024-03-12 11:40:41.383 UTC [49843][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM COMMIT" in transaction 747, finished at 0/1D85900 2024-03-12 11:40:41.486 UTC [50071][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-03-12 11:40:41.487 UTC [50071][client backend] [[unknown]][14/1:0] LOG: connection authenticated: user="postgres" method=trust (/tmp/cirrus-ci-build/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117) 2024-03-12 11:40:41.487 UTC [50071][client backend] [[unknown]][14/1:0] LOG: connection authorized: user=postgres database=postgres application_name=015_stream.pl 2024-03-12 11:40:41.488 UTC [50071][client backend] [015_stream.pl][14/2:0] LOG: statement: SELECT count(*), count(c), count(d = 999) FROM test_tab 2024-03-12 11:40:41.492 UTC [50071][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.005 user=postgres database=postgres host=[local] 2024-03-12 11:40:41.508 UTC [50083][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-03-12 11:40:41.508 UTC [50083][client backend] [[unknown]][15/1:0] LOG: connection authenticated: user="postgres" method=trust (/tmp/cirrus-ci-build/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117) 2024-03-12 11:40:41.508 UTC [50083][client backend] [[unknown]][15/1:0] LOG: connection authorized: user=postgres database=postgres application_name=015_stream.pl 2024-03-12 11:40:41.509 UTC [50083][client backend] [015_stream.pl][15/2:0] LOG: statement: ALTER SUBSCRIPTION tap_sub SET (binary = on) 2024-03-12 11:40:41.510 UTC [50083][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.002 user=postgres database=postgres host=[local] 2024-03-12 11:40:41.510 UTC [49761][logical replication apply worker] LOG: logical replication worker for subscription "tap_sub" will restart because of a parameter change 2024-03-12 11:40:41.510 UTC [49843][logical replication parallel worker] FATAL: terminating logical replication worker due to administrator command 2024-03-12 11:40:41.513 UTC [48804][postmaster] DEBUG: unregistering background worker "logical replication parallel apply worker for subscription 16397" 2024-03-12 11:40:41.513 UTC [48804][postmaster] LOG: background worker "logical replication parallel worker" (PID 49843) exited with exit code 1 2024-03-12 11:40:41.516 UTC [48820][logical replication launcher] DEBUG: starting logical replication worker for subscription "tap_sub" 2024-03-12 11:40:41.516 UTC [48804][postmaster] DEBUG: unregistering background worker "logical replication apply worker for subscription 16397" 2024-03-12 11:40:41.516 UTC [48804][postmaster] DEBUG: background worker "logical replication apply worker" (PID 49761) exited with exit code 0 2024-03-12 11:40:41.516 UTC [48804][postmaster] DEBUG: registering background worker "logical replication apply worker for subscription 16397" 2024-03-12 11:40:41.516 UTC [48804][postmaster] DEBUG: starting background worker process "logical replication apply worker for subscription 16397" 2024-03-12 11:40:41.520 UTC [50090][logical replication apply worker] LOG: logical replication apply worker for subscription "tap_sub" has started 2024-03-12 11:40:41.520 UTC [50090][logical replication apply worker] DEBUG: connecting to publisher using connection string "port=54314 host=/tmp/3olC9SZ3Vm dbname=postgres application_name=tap_sub" 2024-03-12 11:40:41.536 UTC [50090][logical replication apply worker] DEBUG: logical replication apply worker for subscription "tap_sub" two_phase is DISABLED 2024-03-12 11:40:41.725 UTC [50090][logical replication apply worker] DEBUG: starting logical replication worker for subscription "tap_sub" 2024-03-12 11:40:41.725 UTC [50090][logical replication apply worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM START" in transaction 749 2024-03-12 11:40:41.725 UTC [48804][postmaster] DEBUG: registering background worker "logical replication parallel apply worker for subscription 16397" 2024-03-12 11:40:41.725 UTC [48804][postmaster] DEBUG: starting background worker process "logical replication parallel apply worker for subscription 16397" 2024-03-12 11:40:41.727 UTC [50174][logical replication parallel worker] LOG: logical replication apply worker for subscription "tap_sub" has started 2024-03-12 11:40:41.733 UTC [50174][logical replication parallel worker] DEBUG: applied 399 changes in the streaming chunk 2024-03-12 11:40:41.733 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 749 2024-03-12 11:40:41.737 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.737 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 749 2024-03-12 11:40:41.742 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.742 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 749 2024-03-12 11:40:41.749 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.749 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 749 2024-03-12 11:40:41.753 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.753 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 749 2024-03-12 11:40:41.758 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.758 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 749 2024-03-12 11:40:41.764 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.764 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 749 2024-03-12 11:40:41.770 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.770 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 749 2024-03-12 11:40:41.774 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.774 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 749 2024-03-12 11:40:41.785 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.785 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 749 2024-03-12 11:40:41.790 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.790 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 749 2024-03-12 11:40:41.794 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.794 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 749 2024-03-12 11:40:41.802 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.802 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 749 2024-03-12 11:40:41.808 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.808 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 749 2024-03-12 11:40:41.820 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.820 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 749 2024-03-12 11:40:41.840 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.840 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 749 2024-03-12 11:40:41.848 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.848 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 749 2024-03-12 11:40:41.855 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.855 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 749 2024-03-12 11:40:41.862 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.862 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 749 2024-03-12 11:40:41.871 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.871 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 749 2024-03-12 11:40:41.894 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.894 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 749 2024-03-12 11:40:41.901 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.901 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 749 2024-03-12 11:40:41.907 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:41.907 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 749 2024-03-12 11:40:41.912 UTC [50174][logical replication parallel worker] DEBUG: applied 494 changes in the streaming chunk 2024-03-12 11:40:41.912 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 749 2024-03-12 11:40:41.918 UTC [50174][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:41.918 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 749 2024-03-12 11:40:41.923 UTC [50174][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:41.923 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 749 2024-03-12 11:40:41.925 UTC [50174][logical replication parallel worker] DEBUG: applied 192 changes in the streaming chunk 2024-03-12 11:40:41.925 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 749 2024-03-12 11:40:41.925 UTC [50174][logical replication parallel worker] DEBUG: finished processing the STREAM COMMIT command 2024-03-12 11:40:41.925 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM COMMIT" in transaction 749, finished at 0/1F3F258 2024-03-12 11:40:41.977 UTC [50235][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-03-12 11:40:41.983 UTC [50235][client backend] [[unknown]][16/1:0] LOG: connection authenticated: user="postgres" method=trust (/tmp/cirrus-ci-build/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117) 2024-03-12 11:40:41.983 UTC [50235][client backend] [[unknown]][16/1:0] LOG: connection authorized: user=postgres database=postgres application_name=015_stream.pl 2024-03-12 11:40:41.985 UTC [50235][client backend] [015_stream.pl][16/2:0] LOG: statement: SELECT count(*), count(c), count(d = 999) FROM test_tab 2024-03-12 11:40:41.990 UTC [50235][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.013 user=postgres database=postgres host=[local] 2024-03-12 11:40:42.025 UTC [50244][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-03-12 11:40:42.025 UTC [50244][client backend] [[unknown]][17/1:0] LOG: connection authenticated: user="postgres" method=trust (/tmp/cirrus-ci-build/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117) 2024-03-12 11:40:42.025 UTC [50244][client backend] [[unknown]][17/1:0] LOG: connection authorized: user=postgres database=postgres application_name=015_stream.pl 2024-03-12 11:40:42.026 UTC [50244][client backend] [015_stream.pl][17/2:0] LOG: statement: UPDATE test_tab SET c = 'epoch'::timestamptz + 987654321 * interval '1s' 2024-03-12 11:40:42.080 UTC [50244][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.067 user=postgres database=postgres host=[local] 2024-03-12 11:40:42.117 UTC [50174][logical replication parallel worker] DEBUG: applied 399 changes in the streaming chunk 2024-03-12 11:40:42.117 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 750 2024-03-12 11:40:42.135 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:42.135 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 750 2024-03-12 11:40:42.157 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:42.157 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 750 2024-03-12 11:40:42.180 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:42.180 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 750 2024-03-12 11:40:42.191 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:42.191 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 750 2024-03-12 11:40:42.207 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:42.207 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 750 2024-03-12 11:40:42.218 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:42.218 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 750 2024-03-12 11:40:42.231 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:42.231 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 750 2024-03-12 11:40:42.236 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:42.236 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 750 2024-03-12 11:40:42.247 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:42.247 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 750 2024-03-12 11:40:42.252 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:42.252 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 750 2024-03-12 11:40:42.262 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:42.262 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 750 2024-03-12 11:40:42.276 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:42.276 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 750 2024-03-12 11:40:42.286 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:42.286 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 750 2024-03-12 11:40:42.310 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:42.310 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 750 2024-03-12 11:40:42.327 UTC [50174][logical replication parallel worker] DEBUG: applied 398 changes in the streaming chunk 2024-03-12 11:40:42.327 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 750 2024-03-12 11:40:42.338 UTC [50174][logical replication parallel worker] DEBUG: applied 299 changes in the streaming chunk 2024-03-12 11:40:42.338 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 750 2024-03-12 11:40:42.338 UTC [50174][logical replication parallel worker] DEBUG: finished processing the STREAM COMMIT command 2024-03-12 11:40:42.338 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM COMMIT" in transaction 750, finished at 0/20253B8 2024-03-12 11:40:42.372 UTC [50370][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-03-12 11:40:42.373 UTC [50370][client backend] [[unknown]][18/1:0] LOG: connection authenticated: user="postgres" method=trust (/tmp/cirrus-ci-build/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117) 2024-03-12 11:40:42.373 UTC [50370][client backend] [[unknown]][18/1:0] LOG: connection authorized: user=postgres database=postgres application_name=015_stream.pl 2024-03-12 11:40:42.375 UTC [50370][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-03-12 11:40:42.388 UTC [50370][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.017 user=postgres database=postgres host=[local] 2024-03-12 11:40:42.425 UTC [50174][logical replication parallel worker] DEBUG: applied 498 changes in the streaming chunk 2024-03-12 11:40:42.425 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 751 2024-03-12 11:40:42.430 UTC [50174][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:42.430 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 751 2024-03-12 11:40:42.444 UTC [50174][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:42.444 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 751 2024-03-12 11:40:42.455 UTC [50174][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:42.455 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 751 2024-03-12 11:40:42.460 UTC [50174][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:42.460 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 751 2024-03-12 11:40:42.465 UTC [50174][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:42.465 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 751 2024-03-12 11:40:42.473 UTC [50174][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:42.473 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 751 2024-03-12 11:40:42.486 UTC [50174][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:42.486 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 751 2024-03-12 11:40:42.492 UTC [50174][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:42.492 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 751 2024-03-12 11:40:42.500 UTC [50174][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:42.500 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 751 2024-03-12 11:40:42.507 UTC [50174][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:42.507 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 751 2024-03-12 11:40:42.516 UTC [50174][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:42.516 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 751 2024-03-12 11:40:42.521 UTC [50174][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:42.521 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 751 2024-03-12 11:40:42.524 UTC [50174][logical replication parallel worker] DEBUG: applied 204 changes in the streaming chunk 2024-03-12 11:40:42.524 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 751 2024-03-12 11:40:42.524 UTC [50174][logical replication parallel worker] DEBUG: finished processing the STREAM COMMIT command 2024-03-12 11:40:42.524 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM COMMIT" in transaction 751, finished at 0/208FEA8 2024-03-12 11:40:42.601 UTC [48804][postmaster] LOG: received SIGHUP, reloading configuration files 2024-03-12 11:40:42.602 UTC [48804][postmaster] LOG: parameter "deadlock_timeout" changed to "10ms" 2024-03-12 11:40:42.614 UTC [50501][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-03-12 11:40:42.615 UTC [50501][client backend] [[unknown]][19/1:0] LOG: connection authenticated: user="postgres" method=trust (/tmp/cirrus-ci-build/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117) 2024-03-12 11:40:42.615 UTC [50501][client backend] [[unknown]][19/1:0] LOG: connection authorized: user=postgres database=postgres application_name=015_stream.pl 2024-03-12 11:40:42.616 UTC [50501][client backend] [015_stream.pl][19/2:0] LOG: statement: SELECT 1 2024-03-12 11:40:42.618 UTC [50501][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.003 user=postgres database=postgres host=[local] 2024-03-12 11:40:42.809 UTC [50174][logical replication parallel worker] DEBUG: applied 498 changes in the streaming chunk 2024-03-12 11:40:42.809 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 752 2024-03-12 11:40:42.814 UTC [50174][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:42.814 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 752 2024-03-12 11:40:42.817 UTC [50174][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:42.817 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 752 2024-03-12 11:40:42.829 UTC [50174][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:42.829 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 752 2024-03-12 11:40:42.832 UTC [50174][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:42.832 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 752 2024-03-12 11:40:42.835 UTC [50174][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:42.835 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 752 2024-03-12 11:40:42.855 UTC [50174][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:42.855 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 752 2024-03-12 11:40:42.858 UTC [50174][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:42.858 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 752 2024-03-12 11:40:42.862 UTC [50174][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:42.862 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 752 2024-03-12 11:40:42.865 UTC [50174][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:42.865 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 752 2024-03-12 11:40:42.875 UTC [50174][logical replication parallel worker] LOG: process 50174 detected deadlock while waiting for AccessShareLock on remote transaction 752 of subscription 16397 of database 5 after 10.047 ms 2024-03-12 11:40:42.875 UTC [50174][logical replication parallel worker] DETAIL: Process holding the lock: 50090. Wait queue: . 2024-03-12 11:40:42.875 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 752 2024-03-12 11:40:42.875 UTC [50174][logical replication parallel worker] ERROR: deadlock detected 2024-03-12 11:40:42.875 UTC [50174][logical replication parallel worker] DETAIL: Process 50174 waits for AccessShareLock on remote transaction 752 of subscription 16397 of database 5; blocked by process 50090. Process 50090 waits for ShareLock on transaction 766; blocked by process 50174. Process 50174: Process 50090: 2024-03-12 11:40:42.875 UTC [50174][logical replication parallel worker] HINT: See server log for query details. 2024-03-12 11:40:42.875 UTC [50174][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 752 2024-03-12 11:40:42.876 UTC [50090][logical replication apply worker] ERROR: logical replication parallel apply worker exited due to error 2024-03-12 11:40:42.876 UTC [50090][logical replication apply worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 752 logical replication parallel apply worker processing remote data for replication origin "pg_16397" during message type "INSERT" for replication target relation "public.test_tab_2" in transaction 753, finished at 0/20DE4D8 2024-03-12 11:40:42.879 UTC [48820][logical replication launcher] DEBUG: starting logical replication worker for subscription "tap_sub" 2024-03-12 11:40:42.879 UTC [48804][postmaster] DEBUG: unregistering background worker "logical replication apply worker for subscription 16397" 2024-03-12 11:40:42.879 UTC [48804][postmaster] LOG: background worker "logical replication apply worker" (PID 50090) exited with exit code 1 2024-03-12 11:40:42.879 UTC [48804][postmaster] DEBUG: unregistering background worker "logical replication parallel apply worker for subscription 16397" 2024-03-12 11:40:42.879 UTC [48804][postmaster] LOG: background worker "logical replication parallel worker" (PID 50174) exited with exit code 1 2024-03-12 11:40:42.879 UTC [48804][postmaster] DEBUG: registering background worker "logical replication apply worker for subscription 16397" 2024-03-12 11:40:42.879 UTC [48804][postmaster] DEBUG: starting background worker process "logical replication apply worker for subscription 16397" 2024-03-12 11:40:42.890 UTC [50658][logical replication apply worker] LOG: logical replication apply worker for subscription "tap_sub" has started 2024-03-12 11:40:42.890 UTC [50658][logical replication apply worker] DEBUG: connecting to publisher using connection string "port=54314 host=/tmp/3olC9SZ3Vm dbname=postgres application_name=tap_sub" 2024-03-12 11:40:42.898 UTC [50658][logical replication apply worker] DEBUG: logical replication apply worker for subscription "tap_sub" two_phase is DISABLED 2024-03-12 11:40:42.904 UTC [50667][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-03-12 11:40:42.904 UTC [50667][client backend] [[unknown]][20/1:0] LOG: connection authenticated: user="postgres" method=trust (/tmp/cirrus-ci-build/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117) 2024-03-12 11:40:42.904 UTC [50667][client backend] [[unknown]][20/1:0] LOG: connection authorized: user=postgres database=postgres application_name=015_stream.pl 2024-03-12 11:40:42.905 UTC [50667][client backend] [015_stream.pl][20/2:0] LOG: statement: DROP INDEX idx_tab 2024-03-12 11:40:42.907 UTC [50667][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.006 user=postgres database=postgres host=[local] 2024-03-12 11:40:43.218 UTC [50658][logical replication apply worker] DEBUG: starting logical replication worker for subscription "tap_sub" 2024-03-12 11:40:43.218 UTC [50658][logical replication apply worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM START" in transaction 752 2024-03-12 11:40:43.218 UTC [48804][postmaster] DEBUG: registering background worker "logical replication parallel apply worker for subscription 16397" 2024-03-12 11:40:43.218 UTC [48804][postmaster] DEBUG: starting background worker process "logical replication parallel apply worker for subscription 16397" 2024-03-12 11:40:43.224 UTC [50836][logical replication parallel worker] LOG: logical replication apply worker for subscription "tap_sub" has started 2024-03-12 11:40:43.256 UTC [50836][logical replication parallel worker] DEBUG: applied 4984 changes in the streaming chunk 2024-03-12 11:40:43.256 UTC [50836][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 752 2024-03-12 11:40:43.256 UTC [50836][logical replication parallel worker] DEBUG: applied 17 changes in the streaming chunk 2024-03-12 11:40:43.256 UTC [50836][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 752 2024-03-12 11:40:43.256 UTC [50836][logical replication parallel worker] DEBUG: finished processing the STREAM COMMIT command 2024-03-12 11:40:43.256 UTC [50836][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM COMMIT" in transaction 752, finished at 0/20DE508 2024-03-12 11:40:43.397 UTC [50943][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-03-12 11:40:43.398 UTC [50943][client backend] [[unknown]][21/1:0] LOG: connection authenticated: user="postgres" method=trust (/tmp/cirrus-ci-build/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117) 2024-03-12 11:40:43.398 UTC [50943][client backend] [[unknown]][21/1:0] LOG: connection authorized: user=postgres database=postgres application_name=015_stream.pl 2024-03-12 11:40:43.399 UTC [50943][client backend] [015_stream.pl][21/2:0] LOG: statement: SELECT count(*) FROM test_tab_2 2024-03-12 11:40:43.404 UTC [50943][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.006 user=postgres database=postgres host=[local] 2024-03-12 11:40:43.494 UTC [51018][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-03-12 11:40:43.495 UTC [51018][client backend] [[unknown]][22/1:0] LOG: connection authenticated: user="postgres" method=trust (/tmp/cirrus-ci-build/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117) 2024-03-12 11:40:43.495 UTC [51018][client backend] [[unknown]][22/1:0] LOG: connection authorized: user=postgres database=postgres application_name=015_stream.pl 2024-03-12 11:40:43.495 UTC [51018][client backend] [015_stream.pl][22/2:0] LOG: statement: CREATE UNIQUE INDEX idx_tab on test_tab_2(a) 2024-03-12 11:40:43.498 UTC [51018][client backend] [015_stream.pl][22/2:772] DEBUG: building index "idx_tab" on table "test_tab_2" serially 2024-03-12 11:40:43.498 UTC [51018][client backend] [015_stream.pl][22/2:772] DEBUG: index "idx_tab" can safely use deduplication 2024-03-12 11:40:43.500 UTC [51018][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.006 user=postgres database=postgres host=[local] 2024-03-12 11:40:43.609 UTC [50836][logical replication parallel worker] DEBUG: applied 498 changes in the streaming chunk 2024-03-12 11:40:43.609 UTC [50836][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 755 2024-03-12 11:40:43.612 UTC [50836][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:43.612 UTC [50836][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 755 2024-03-12 11:40:43.615 UTC [50836][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:43.615 UTC [50836][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 755 2024-03-12 11:40:43.619 UTC [50836][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:43.619 UTC [50836][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 755 2024-03-12 11:40:43.622 UTC [50836][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:43.622 UTC [50836][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 755 2024-03-12 11:40:43.625 UTC [50836][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:43.625 UTC [50836][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 755 2024-03-12 11:40:43.628 UTC [50836][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:43.628 UTC [50836][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 755 2024-03-12 11:40:43.632 UTC [50836][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:43.632 UTC [50836][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 755 2024-03-12 11:40:43.642 UTC [50836][logical replication parallel worker] LOG: process 50836 still waiting for AccessShareLock on remote transaction 755 of subscription 16397 of database 5 after 10.094 ms 2024-03-12 11:40:43.642 UTC [50836][logical replication parallel worker] DETAIL: Process holding the lock: 50658. Wait queue: 50836. 2024-03-12 11:40:43.642 UTC [50836][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 755 2024-03-12 11:40:43.657 UTC [50836][logical replication parallel worker] LOG: process 50836 acquired AccessShareLock on remote transaction 755 of subscription 16397 of database 5 after 24.922 ms 2024-03-12 11:40:43.657 UTC [50836][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 755 2024-03-12 11:40:43.665 UTC [50836][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:43.665 UTC [50836][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 755 2024-03-12 11:40:43.668 UTC [50836][logical replication parallel worker] DEBUG: applied 497 changes in the streaming chunk 2024-03-12 11:40:43.668 UTC [50836][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 755 2024-03-12 11:40:43.668 UTC [50658][logical replication apply worker] DEBUG: starting logical replication worker for subscription "tap_sub" 2024-03-12 11:40:43.668 UTC [50658][logical replication apply worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM START" in transaction 756 2024-03-12 11:40:43.668 UTC [48804][postmaster] DEBUG: registering background worker "logical replication parallel apply worker for subscription 16397" 2024-03-12 11:40:43.668 UTC [48804][postmaster] DEBUG: starting background worker process "logical replication parallel apply worker for subscription 16397" 2024-03-12 11:40:43.678 UTC [50836][logical replication parallel worker] LOG: process 50836 still waiting for AccessShareLock on remote transaction 755 of subscription 16397 of database 5 after 10.045 ms 2024-03-12 11:40:43.678 UTC [50836][logical replication parallel worker] DETAIL: Process holding the lock: 50658. Wait queue: 50836. 2024-03-12 11:40:43.678 UTC [50836][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 755 2024-03-12 11:40:43.688 UTC [51122][logical replication parallel worker] LOG: logical replication apply worker for subscription "tap_sub" has started 2024-03-12 11:40:43.703 UTC [51122][logical replication parallel worker] LOG: process 51122 detected deadlock while waiting for ShareLock on transaction 773 after 12.024 ms 2024-03-12 11:40:43.703 UTC [51122][logical replication parallel worker] DETAIL: Process holding the lock: 50836. Wait queue: . 2024-03-12 11:40:43.703 UTC [51122][logical replication parallel worker] CONTEXT: while inserting index tuple (21,225) in relation "idx_tab" processing remote data for replication origin "pg_16397" during message type "INSERT" for replication target relation "public.test_tab_2" in transaction 756 2024-03-12 11:40:43.703 UTC [51122][logical replication parallel worker] ERROR: deadlock detected 2024-03-12 11:40:43.703 UTC [51122][logical replication parallel worker] DETAIL: Process 51122 waits for ShareLock on transaction 773; blocked by process 50836. Process 50836 waits for AccessShareLock on remote transaction 755 of subscription 16397 of database 5; blocked by process 50658. Process 50658 waits for AccessShareLock on remote transaction 756 of subscription 16397 of database 5; blocked by process 51122. Process 51122: Process 50836: Process 50658: 2024-03-12 11:40:43.703 UTC [51122][logical replication parallel worker] HINT: See server log for query details. 2024-03-12 11:40:43.703 UTC [51122][logical replication parallel worker] CONTEXT: while inserting index tuple (21,225) in relation "idx_tab" processing remote data for replication origin "pg_16397" during message type "INSERT" for replication target relation "public.test_tab_2" in transaction 756 2024-03-12 11:40:43.704 UTC [50658][logical replication apply worker] ERROR: logical replication parallel apply worker exited due to error 2024-03-12 11:40:43.704 UTC [50658][logical replication apply worker] CONTEXT: while inserting index tuple (21,225) in relation "idx_tab" processing remote data for replication origin "pg_16397" during message type "INSERT" for replication target relation "public.test_tab_2" in transaction 756 logical replication parallel apply worker processing remote data for replication origin "pg_16397" during message type "STREAM COMMIT" in transaction 756, finished at 0/217B3A8 2024-03-12 11:40:43.705 UTC [48804][postmaster] DEBUG: unregistering background worker "logical replication parallel apply worker for subscription 16397" 2024-03-12 11:40:43.705 UTC [48804][postmaster] LOG: background worker "logical replication parallel worker" (PID 51122) exited with exit code 1 2024-03-12 11:40:43.705 UTC [50836][logical replication parallel worker] FATAL: terminating logical replication worker due to administrator command 2024-03-12 11:40:43.705 UTC [50836][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM STOP" in transaction 755 2024-03-12 11:40:43.706 UTC [48804][postmaster] DEBUG: unregistering background worker "logical replication parallel apply worker for subscription 16397" 2024-03-12 11:40:43.706 UTC [48804][postmaster] LOG: background worker "logical replication parallel worker" (PID 50836) exited with exit code 1 TRAP: failed Assert("dlist_is_empty(&(MyProc->myProcLocks[i]))"), File: "../src/backend/storage/lmgr/proc.c", Line: 861, PID: 50658 postgres: subscriber: logical replication apply worker for subscription 16397 (ExceptionalCondition+0x56)[0x5564e5c0b7f2] postgres: subscriber: logical replication apply worker for subscription 16397 (+0x1051215)[0x5564e594e215] postgres: subscriber: logical replication apply worker for subscription 16397 (shmem_exit+0x2cd)[0x5564e590638f] postgres: subscriber: logical replication apply worker for subscription 16397 (+0x1009493)[0x5564e5906493] postgres: subscriber: logical replication apply worker for subscription 16397 (proc_exit+0x1a)[0x5564e5906651] postgres: subscriber: logical replication apply worker for subscription 16397 (BackgroundWorkerMain+0x161)[0x5564e58071d4] postgres: subscriber: logical replication apply worker for subscription 16397 (+0xf14604)[0x5564e5811604] postgres: subscriber: logical replication apply worker for subscription 16397 (+0xf148da)[0x5564e58118da] postgres: subscriber: logical replication apply worker for subscription 16397 (+0xf154a1)[0x5564e58124a1] postgres: subscriber: logical replication apply worker for subscription 16397 (+0xf15ca1)[0x5564e5812ca1] postgres: subscriber: logical replication apply worker for subscription 16397 (BackgroundWorkerInitializeConnection+0x0)[0x5564e5814839] postgres: subscriber: logical replication apply worker for subscription 16397 (main+0x393)[0x5564e563fa1c] /lib/x86_64-linux-gnu/libc.so.6(__libc_start_main+0xea)[0x7f0e215e5d0a] postgres: subscriber: logical replication apply worker for subscription 16397 (_start+0x2a)[0x5564e51af21a] 2024-03-12 11:40:43.711 UTC [48820][logical replication launcher] DEBUG: starting logical replication worker for subscription "tap_sub" 2024-03-12 11:40:43.711 UTC [48804][postmaster] DEBUG: registering background worker "logical replication apply worker for subscription 16397" 2024-03-12 11:40:43.712 UTC [48804][postmaster] DEBUG: starting background worker process "logical replication apply worker for subscription 16397" 2024-03-12 11:40:43.724 UTC [51148][logical replication apply worker] LOG: logical replication apply worker for subscription "tap_sub" has started 2024-03-12 11:40:43.724 UTC [51148][logical replication apply worker] DEBUG: connecting to publisher using connection string "port=54314 host=/tmp/3olC9SZ3Vm dbname=postgres application_name=tap_sub" 2024-03-12 11:40:43.737 UTC [51148][logical replication apply worker] DEBUG: logical replication apply worker for subscription "tap_sub" two_phase is DISABLED 2024-03-12 11:40:43.793 UTC [51185][not initialized] [[unknown]][:0] LOG: connection received: host=[local] 2024-03-12 11:40:43.794 UTC [51185][client backend] [[unknown]][23/1:0] LOG: connection authenticated: user="postgres" method=trust (/tmp/cirrus-ci-build/build/testrun/subscription/015_stream/data/t_015_stream_subscriber_data/pgdata/pg_hba.conf:117) 2024-03-12 11:40:43.794 UTC [51185][client backend] [[unknown]][23/1:0] LOG: connection authorized: user=postgres database=postgres application_name=015_stream.pl 2024-03-12 11:40:43.796 UTC [51185][client backend] [015_stream.pl][23/2:0] LOG: statement: DROP INDEX idx_tab 2024-03-12 11:40:43.799 UTC [51185][client backend] [015_stream.pl][:0] LOG: disconnection: session time: 0:00:00.006 user=postgres database=postgres host=[local] 2024-03-12 11:40:44.092 UTC [51148][logical replication apply worker] DEBUG: starting logical replication worker for subscription "tap_sub" 2024-03-12 11:40:44.092 UTC [51148][logical replication apply worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM START" in transaction 756 2024-03-12 11:40:44.092 UTC [48804][postmaster] DEBUG: registering background worker "logical replication parallel apply worker for subscription 16397" 2024-03-12 11:40:44.092 UTC [48804][postmaster] DEBUG: starting background worker process "logical replication parallel apply worker for subscription 16397" 2024-03-12 11:40:44.109 UTC [51312][logical replication parallel worker] LOG: logical replication apply worker for subscription "tap_sub" has started 2024-03-12 11:40:44.120 UTC [51312][logical replication parallel worker] LOG: process 51312 still waiting for AccessExclusiveLock on remote transaction 756 of subscription 16397 of database 5 after 10.041 ms 2024-03-12 11:40:44.120 UTC [51312][logical replication parallel worker] DETAIL: Process holding the lock: 50658. Wait queue: 51312. 2024-03-12 11:40:44.120 UTC [51312][logical replication parallel worker] CONTEXT: processing remote data for replication origin "pg_16397" during message type "STREAM START" in transaction 756 2024-03-12 11:40:44.480 UTC [48804][postmaster] LOG: background worker "logical replication apply worker" (PID 50658) was terminated by signal 6: Aborted 2024-03-12 11:40:44.480 UTC [48804][postmaster] LOG: terminating any other active server processes 2024-03-12 11:40:44.483 UTC [48804][postmaster] LOG: shutting down because restart_after_crash is off 2024-03-12 11:40:44.502 UTC [48804][postmaster] LOG: database system is shut down