mirror of https://github.com/citusdata/citus.git
Fix tests
parent
34edc252a9
commit
c092968f0d
|
@ -68,7 +68,7 @@ step s3-commit:
|
||||||
COMMIT;
|
COMMIT;
|
||||||
|
|
||||||
|
|
||||||
starting permutation: s1-create-table s1-begin s1-insert s1-verify-current-xact-is-on-worker s1-commit
|
starting permutation: s1-create-table s1-begin s1-insert s1-verify-current-xact-is-on-worker s1-drop-table s1-commit
|
||||||
step s1-create-table:
|
step s1-create-table:
|
||||||
-- some tests also use distributed table
|
-- some tests also use distributed table
|
||||||
CREATE TABLE distributed_transaction_id_table(some_value int, other_value int);
|
CREATE TABLE distributed_transaction_id_table(some_value int, other_value int);
|
||||||
|
@ -104,6 +104,9 @@ nodeport|xact_exists
|
||||||
57638|t
|
57638|t
|
||||||
(2 rows)
|
(2 rows)
|
||||||
|
|
||||||
|
step s1-drop-table:
|
||||||
|
DROP TABLE distributed_transaction_id_table;
|
||||||
|
|
||||||
step s1-commit:
|
step s1-commit:
|
||||||
COMMIT;
|
COMMIT;
|
||||||
|
|
||||||
|
|
|
@ -90,10 +90,7 @@ query |query_hostname |query_hostport|distribute
|
||||||
|
|
||||||
update ref_table set a = a + 1;
|
update ref_table set a = a + 1;
|
||||||
|coordinator_host| 57636|coordinator_host | 57636|idle in transaction|Client |ClientRead|postgres|regression
|
|coordinator_host| 57636|coordinator_host | 57636|idle in transaction|Client |ClientRead|postgres|regression
|
||||||
|
(1 row)
|
||||||
update ref_table set a = a + 1;
|
|
||||||
|localhost | 57636|coordinator_host | 57636|idle in transaction|Client |ClientRead|postgres|regression
|
|
||||||
(2 rows)
|
|
||||||
|
|
||||||
step s2-view-worker:
|
step s2-view-worker:
|
||||||
SELECT query, query_hostname, query_hostport, distributed_query_host_name,
|
SELECT query, query_hostname, query_hostport, distributed_query_host_name,
|
||||||
|
@ -108,9 +105,7 @@ query |q
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
UPDATE public.ref_table_1500775 ref_table SET a = (a OPERATOR(pg_catalog.+) 1)|localhost | 57638|coordinator_host | 57636|idle in transaction|Client |ClientRead|postgres|regression
|
UPDATE public.ref_table_1500775 ref_table SET a = (a OPERATOR(pg_catalog.+) 1)|localhost | 57638|coordinator_host | 57636|idle in transaction|Client |ClientRead|postgres|regression
|
||||||
UPDATE public.ref_table_1500775 ref_table SET a = (a OPERATOR(pg_catalog.+) 1)|localhost | 57637|coordinator_host | 57636|idle in transaction|Client |ClientRead|postgres|regression
|
UPDATE public.ref_table_1500775 ref_table SET a = (a OPERATOR(pg_catalog.+) 1)|localhost | 57637|coordinator_host | 57636|idle in transaction|Client |ClientRead|postgres|regression
|
||||||
UPDATE public.ref_table_1500775 ref_table SET a = (a OPERATOR(pg_catalog.+) 1)|coordinator_host| 57636|coordinator_host | 57636|idle in transaction|Client |ClientRead|postgres|regression
|
(2 rows)
|
||||||
UPDATE public.ref_table_1500775 ref_table SET a = (a OPERATOR(pg_catalog.+) 1)|localhost | 57636|coordinator_host | 57636|idle in transaction|Client |ClientRead|postgres|regression
|
|
||||||
(4 rows)
|
|
||||||
|
|
||||||
step s2-end:
|
step s2-end:
|
||||||
END;
|
END;
|
||||||
|
@ -146,12 +141,12 @@ step s2-active-transactions:
|
||||||
|
|
||||||
count
|
count
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
2
|
1
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
count
|
count
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
6
|
3
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
step s1-end:
|
step s1-end:
|
||||||
|
|
|
@ -497,12 +497,7 @@ SELECT shardid, nodename, nodeport
|
||||||
WHERE logicalrelid = 'numbers_append'::regclass order by placementid;
|
WHERE logicalrelid = 'numbers_append'::regclass order by placementid;
|
||||||
|
|
||||||
-- add the node back
|
-- add the node back
|
||||||
SET citus.log_remote_commands to true;
|
|
||||||
SET citus.worker_min_messages to debug4;
|
|
||||||
set client_min_messages to debug4;
|
|
||||||
SELECT 1 FROM master_activate_node('localhost', :worker_1_port);
|
SELECT 1 FROM master_activate_node('localhost', :worker_1_port);
|
||||||
reset citus.log_remote_commands;
|
|
||||||
reset citus.worker_min_messages;
|
|
||||||
RESET client_min_messages;
|
RESET client_min_messages;
|
||||||
RESET citus.shard_replication_factor;
|
RESET citus.shard_replication_factor;
|
||||||
-- add two new shards and verify they are created at both workers
|
-- add two new shards and verify they are created at both workers
|
||||||
|
|
|
@ -124,7 +124,7 @@ permutation "s1-begin" "s1-assign-transaction-id" "s1-get-all-transactions" "s2-
|
||||||
|
|
||||||
// now show that distributed transaction id on the coordinator
|
// now show that distributed transaction id on the coordinator
|
||||||
// is the same with the one on the worker
|
// is the same with the one on the worker
|
||||||
permutation "s1-create-table" "s1-begin" "s1-insert" "s1-verify-current-xact-is-on-worker" "s1-commit" "s1-drop-table"
|
permutation "s1-create-table" "s1-begin" "s1-insert" "s1-verify-current-xact-is-on-worker" "s1-drop-table" "s1-commit"
|
||||||
|
|
||||||
// we would initially forget the distributed transaction ID on pg_dist_partition invalidations
|
// we would initially forget the distributed transaction ID on pg_dist_partition invalidations
|
||||||
permutation "s1-begin" "s1-assign-transaction-id" "s1-has-transaction-number" "s2-vacuum" "s1-has-transaction-number" "s1-commit"
|
permutation "s1-begin" "s1-assign-transaction-id" "s1-has-transaction-number" "s2-vacuum" "s1-has-transaction-number" "s1-commit"
|
||||||
|
|
Loading…
Reference in New Issue