mirror of https://github.com/citusdata/citus.git
Fix one test failure after editorconfig changes
parent
5862926517
commit
d5d7a44f7a
|
@ -7,7 +7,7 @@ create_distributed_table
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
step add-node:
|
step add-node:
|
||||||
SELECT 1 FROM master_add_node('localhost', 57636, groupid => 0);
|
SELECT 1 FROM master_add_node('localhost', 57636, groupid => 0);
|
||||||
|
|
||||||
?column?
|
?column?
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
|
@ -15,7 +15,7 @@ step add-node:
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
step replicate-reference-tables:
|
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
|
replicate_reference_tables
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
|
@ -33,27 +33,27 @@ step s1-update-dist-table:
|
||||||
|
|
||||||
step s2-lock-ref-table-placement-on-coordinator:
|
step s2-lock-ref-table-placement-on-coordinator:
|
||||||
DO $$
|
DO $$
|
||||||
DECLARE refshardid int;
|
DECLARE refshardid int;
|
||||||
BEGIN
|
BEGIN
|
||||||
SELECT shardid INTO refshardid FROM pg_dist_shard WHERE logicalrelid='ref_table'::regclass;
|
SELECT shardid INTO refshardid FROM pg_dist_shard WHERE logicalrelid='ref_table'::regclass;
|
||||||
EXECUTE format('SELECT * from ref_table_%s FOR UPDATE', refshardid::text);
|
EXECUTE format('SELECT * from ref_table_%s FOR UPDATE', refshardid::text);
|
||||||
END
|
END
|
||||||
$$;
|
$$;
|
||||||
|
|
||||||
step s1-lock-ref-table-placement-on-coordinator:
|
step s1-lock-ref-table-placement-on-coordinator:
|
||||||
DO $$
|
DO $$
|
||||||
DECLARE refshardid int;
|
DECLARE refshardid int;
|
||||||
BEGIN
|
BEGIN
|
||||||
SELECT shardid INTO refshardid FROM pg_dist_shard WHERE logicalrelid='ref_table'::regclass;
|
SELECT shardid INTO refshardid FROM pg_dist_shard WHERE logicalrelid='ref_table'::regclass;
|
||||||
EXECUTE format('SELECT * from ref_table_%s FOR UPDATE', refshardid::text);
|
EXECUTE format('SELECT * from ref_table_%s FOR UPDATE', refshardid::text);
|
||||||
END
|
END
|
||||||
$$;
|
$$;
|
||||||
<waiting ...>
|
<waiting ...>
|
||||||
step s2-update-dist-table:
|
step s2-update-dist-table:
|
||||||
update dist_table set b = 2 where a = 1;
|
update dist_table set b = 2 where a = 1;
|
||||||
<waiting ...>
|
<waiting ...>
|
||||||
step deadlock-checker-call:
|
step deadlock-checker-call:
|
||||||
SELECT check_distributed_deadlocks();
|
SELECT check_distributed_deadlocks();
|
||||||
|
|
||||||
check_distributed_deadlocks
|
check_distributed_deadlocks
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
|
@ -82,7 +82,7 @@ create_distributed_table
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
step add-node:
|
step add-node:
|
||||||
SELECT 1 FROM master_add_node('localhost', 57636, groupid => 0);
|
SELECT 1 FROM master_add_node('localhost', 57636, groupid => 0);
|
||||||
|
|
||||||
?column?
|
?column?
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
|
@ -90,7 +90,7 @@ step add-node:
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
step replicate-reference-tables:
|
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
|
replicate_reference_tables
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
|
@ -107,7 +107,7 @@ step s1-update-ref-table:
|
||||||
update ref_table set a = a + 1;
|
update ref_table set a = a + 1;
|
||||||
|
|
||||||
step s2-sleep:
|
step s2-sleep:
|
||||||
SELECT pg_sleep(0.5);
|
SELECT pg_sleep(0.5);
|
||||||
|
|
||||||
pg_sleep
|
pg_sleep
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
|
@ -115,33 +115,33 @@ pg_sleep
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
step s2-view-dist:
|
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
|
|idle |Client |ClientRead|postgres|regression
|
||||||
|
|
||||||
SELECT check_distributed_deadlocks();
|
SELECT check_distributed_deadlocks();
|
||||||
|idle |Client |ClientRead|postgres|regression
|
|idle |Client |ClientRead|postgres|regression
|
||||||
|
|
||||||
update ref_table set a = a + 1;
|
|
||||||
|idle in transaction|Client |ClientRead|postgres|regression
|
|
||||||
(3 rows)
|
(3 rows)
|
||||||
|
|
||||||
step s2-view-worker:
|
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
|
FROM citus_stat_activity
|
||||||
WHERE query NOT ILIKE ALL(VALUES
|
WHERE query NOT ILIKE ALL(VALUES
|
||||||
('%application_name%'),
|
('%application_name%'),
|
||||||
('%pg_prepared_xacts%'),
|
('%pg_prepared_xacts%'),
|
||||||
('%COMMIT%'),
|
('%COMMIT%'),
|
||||||
('%dump_local_%'),
|
('%dump_local_%'),
|
||||||
('%citus_internal_local_blocked_processes%'),
|
('%citus_internal_local_blocked_processes%'),
|
||||||
('%add_node%'),
|
('%add_node%'),
|
||||||
('%csa_from_one_node%'),
|
('%csa_from_one_node%'),
|
||||||
('%pg_locks%'))
|
('%pg_locks%'))
|
||||||
AND is_worker_query = true
|
AND is_worker_query = true
|
||||||
AND backend_type = 'client backend'
|
AND backend_type = 'client backend'
|
||||||
AND query != ''
|
AND query != ''
|
||||||
|
@ -172,7 +172,7 @@ create_distributed_table
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
step add-node:
|
step add-node:
|
||||||
SELECT 1 FROM master_add_node('localhost', 57636, groupid => 0);
|
SELECT 1 FROM master_add_node('localhost', 57636, groupid => 0);
|
||||||
|
|
||||||
?column?
|
?column?
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
|
@ -180,7 +180,7 @@ step add-node:
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
step replicate-reference-tables:
|
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
|
replicate_reference_tables
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
|
@ -197,9 +197,9 @@ step s1-update-ref-table:
|
||||||
update ref_table set a = a + 1;
|
update ref_table set a = a + 1;
|
||||||
|
|
||||||
step s2-active-transactions:
|
step s2-active-transactions:
|
||||||
-- Admin should be able to see all transactions
|
-- Admin should be able to see all transactions
|
||||||
SELECT count(*) FROM get_all_active_transactions() WHERE transaction_number != 0;
|
SELECT count(*) FROM get_all_active_transactions() WHERE transaction_number != 0;
|
||||||
SELECT count(*) FROM get_global_active_transactions() WHERE transaction_number != 0;
|
SELECT count(*) FROM get_global_active_transactions() WHERE transaction_number != 0;
|
||||||
|
|
||||||
count
|
count
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
|
|
Loading…
Reference in New Issue