diff --git a/src/test/regress/expected/isolation_replicate_reference_tables_to_coordinator.out b/src/test/regress/expected/isolation_replicate_reference_tables_to_coordinator.out index e37724e4b..6dba1643d 100644 --- a/src/test/regress/expected/isolation_replicate_reference_tables_to_coordinator.out +++ b/src/test/regress/expected/isolation_replicate_reference_tables_to_coordinator.out @@ -7,7 +7,7 @@ create_distributed_table (1 row) step add-node: - SELECT 1 FROM master_add_node('localhost', 57636, groupid => 0); + SELECT 1 FROM master_add_node('localhost', 57636, groupid => 0); ?column? --------------------------------------------------------------------- @@ -15,7 +15,7 @@ step add-node: (1 row) step replicate-reference-tables: - SELECT replicate_reference_tables(shard_transfer_mode := 'block_writes'); + SELECT replicate_reference_tables(shard_transfer_mode := 'block_writes'); replicate_reference_tables --------------------------------------------------------------------- @@ -33,27 +33,27 @@ step s1-update-dist-table: step s2-lock-ref-table-placement-on-coordinator: DO $$ - DECLARE refshardid int; - BEGIN + DECLARE refshardid int; + BEGIN SELECT shardid INTO refshardid FROM pg_dist_shard WHERE logicalrelid='ref_table'::regclass; EXECUTE format('SELECT * from ref_table_%s FOR UPDATE', refshardid::text); - END + END $$; step s1-lock-ref-table-placement-on-coordinator: DO $$ - DECLARE refshardid int; - BEGIN + DECLARE refshardid int; + BEGIN SELECT shardid INTO refshardid FROM pg_dist_shard WHERE logicalrelid='ref_table'::regclass; EXECUTE format('SELECT * from ref_table_%s FOR UPDATE', refshardid::text); - END + END $$; step s2-update-dist-table: update dist_table set b = 2 where a = 1; step deadlock-checker-call: - SELECT check_distributed_deadlocks(); + SELECT check_distributed_deadlocks(); check_distributed_deadlocks --------------------------------------------------------------------- @@ -82,7 +82,7 @@ create_distributed_table (1 row) step add-node: - SELECT 1 FROM master_add_node('localhost', 57636, groupid => 0); + SELECT 1 FROM master_add_node('localhost', 57636, groupid => 0); ?column? --------------------------------------------------------------------- @@ -90,7 +90,7 @@ step add-node: (1 row) step replicate-reference-tables: - SELECT replicate_reference_tables(shard_transfer_mode := 'block_writes'); + SELECT replicate_reference_tables(shard_transfer_mode := 'block_writes'); replicate_reference_tables --------------------------------------------------------------------- @@ -107,7 +107,7 @@ step s1-update-ref-table: update ref_table set a = a + 1; step s2-sleep: - SELECT pg_sleep(0.5); + SELECT pg_sleep(0.5); pg_sleep --------------------------------------------------------------------- @@ -115,33 +115,33 @@ pg_sleep (1 row) step s2-view-dist: - SELECT query, state, wait_event_type, wait_event, usename, datname FROM citus_dist_stat_activity WHERE backend_type = 'client backend' AND query NOT ILIKE ALL(VALUES('%pg_prepared_xacts%'), ('%COMMIT%'), ('%pg_isolation_test_session_is_blocked%'), ('%BEGIN%'), ('%add_node%')) ORDER BY query DESC; + SELECT query, state, wait_event_type, wait_event, usename, datname FROM citus_dist_stat_activity WHERE backend_type = 'client backend' AND query NOT ILIKE ALL(VALUES('%pg_prepared_xacts%'), ('%COMMIT%'), ('%pg_isolation_test_session_is_blocked%'), ('%BEGIN%'), ('%add_node%')) ORDER BY query DESC; -query |state |wait_event_type|wait_event|usename |datname +query |state |wait_event_type|wait_event|usename |datname --------------------------------------------------------------------- - SELECT replicate_reference_tables(shard_transfer_mode := 'block_writes'); + update ref_table set a = a + 1; + |idle in transaction|Client |ClientRead|postgres|regression + + SELECT replicate_reference_tables(shard_transfer_mode := 'block_writes'); |idle |Client |ClientRead|postgres|regression - SELECT check_distributed_deadlocks(); + SELECT check_distributed_deadlocks(); |idle |Client |ClientRead|postgres|regression - - update ref_table set a = a + 1; - |idle in transaction|Client |ClientRead|postgres|regression (3 rows) step s2-view-worker: - SELECT query, state, wait_event_type, wait_event, usename, datname + SELECT query, state, wait_event_type, wait_event, usename, datname FROM citus_stat_activity WHERE query NOT ILIKE ALL(VALUES - ('%application_name%'), - ('%pg_prepared_xacts%'), - ('%COMMIT%'), - ('%dump_local_%'), - ('%citus_internal_local_blocked_processes%'), - ('%add_node%'), - ('%csa_from_one_node%'), - ('%pg_locks%')) + ('%application_name%'), + ('%pg_prepared_xacts%'), + ('%COMMIT%'), + ('%dump_local_%'), + ('%citus_internal_local_blocked_processes%'), + ('%add_node%'), + ('%csa_from_one_node%'), + ('%pg_locks%')) AND is_worker_query = true AND backend_type = 'client backend' AND query != '' @@ -172,7 +172,7 @@ create_distributed_table (1 row) step add-node: - SELECT 1 FROM master_add_node('localhost', 57636, groupid => 0); + SELECT 1 FROM master_add_node('localhost', 57636, groupid => 0); ?column? --------------------------------------------------------------------- @@ -180,7 +180,7 @@ step add-node: (1 row) step replicate-reference-tables: - SELECT replicate_reference_tables(shard_transfer_mode := 'block_writes'); + SELECT replicate_reference_tables(shard_transfer_mode := 'block_writes'); replicate_reference_tables --------------------------------------------------------------------- @@ -197,9 +197,9 @@ step s1-update-ref-table: update ref_table set a = a + 1; step s2-active-transactions: - -- Admin should be able to see all transactions - SELECT count(*) FROM get_all_active_transactions() WHERE transaction_number != 0; - SELECT count(*) FROM get_global_active_transactions() WHERE transaction_number != 0; + -- Admin should be able to see all transactions + SELECT count(*) FROM get_all_active_transactions() WHERE transaction_number != 0; + SELECT count(*) FROM get_global_active_transactions() WHERE transaction_number != 0; count ---------------------------------------------------------------------