Parsed test spec with 5 sessions starting permutation: s2-begin s2-create_distributed_table s3-create_distributed_table s2-commit step s2-begin: BEGIN; step s2-create_distributed_table: SELECT create_distributed_table('concurrent_table_2', 'id', colocate_with := 'concurrent_table_1'); create_distributed_table --------------------------------------------------------------------- (1 row) step s3-create_distributed_table: SELECT create_distributed_table('concurrent_table_3', 'id', colocate_with := 'concurrent_table_1'); create_distributed_table --------------------------------------------------------------------- (1 row) step s2-commit: COMMIT; starting permutation: s2-begin s2-create_distributed_table s1-move-shard-logical s2-commit s3-sanity-check s3-sanity-check-2 step s2-begin: BEGIN; step s2-create_distributed_table: SELECT create_distributed_table('concurrent_table_2', 'id', colocate_with := 'concurrent_table_1'); create_distributed_table --------------------------------------------------------------------- (1 row) step s1-move-shard-logical: WITH shardid AS (SELECT shardid FROM pg_dist_shard where logicalrelid = 'concurrent_table_1'::regclass ORDER BY shardid LIMIT 1) SELECT citus_move_Shard_placement(shardid.shardid, 'localhost', 57637, 'localhost', 57638) FROM shardid; ERROR: could not acquire the lock required to move public.concurrent_table_1 step s2-commit: COMMIT; step s3-sanity-check: SELECT count(*) FROM pg_dist_shard LEFT JOIN pg_dist_shard_placement USING(shardid) WHERE nodename IS NULL; count --------------------------------------------------------------------- 0 (1 row) step s3-sanity-check-2: SELECT count(*) FROM concurrent_table_1 JOIN concurrent_table_2 USING (id); count --------------------------------------------------------------------- 0 (1 row) starting permutation: s2-begin s2-create_distributed_table s1-move-shard-block s2-commit s3-sanity-check s3-sanity-check-2 step s2-begin: BEGIN; step s2-create_distributed_table: SELECT create_distributed_table('concurrent_table_2', 'id', colocate_with := 'concurrent_table_1'); create_distributed_table --------------------------------------------------------------------- (1 row) step s1-move-shard-block: WITH shardid AS (SELECT shardid FROM pg_dist_shard where logicalrelid = 'concurrent_table_1'::regclass ORDER BY shardid LIMIT 1) SELECT citus_move_Shard_placement(shardid.shardid, 'localhost', 57637, 'localhost', 57638, 'block_writes') FROM shardid; ERROR: could not acquire the lock required to move public.concurrent_table_1 step s2-commit: COMMIT; step s3-sanity-check: SELECT count(*) FROM pg_dist_shard LEFT JOIN pg_dist_shard_placement USING(shardid) WHERE nodename IS NULL; count --------------------------------------------------------------------- 0 (1 row) step s3-sanity-check-2: SELECT count(*) FROM concurrent_table_1 JOIN concurrent_table_2 USING (id); count --------------------------------------------------------------------- 0 (1 row) starting permutation: s2-begin s2-create_distributed_table s1-split-block s2-commit s3-sanity-check s3-sanity-check-2 step s2-begin: BEGIN; step s2-create_distributed_table: SELECT create_distributed_table('concurrent_table_2', 'id', colocate_with := 'concurrent_table_1'); create_distributed_table --------------------------------------------------------------------- (1 row) step s1-split-block: WITH shardid AS (SELECT shardid FROM pg_dist_shard where logicalrelid = 'concurrent_table_1'::regclass ORDER BY shardid LIMIT 1) SELECT citus_split_shard_by_split_points( shardid.shardid, ARRAY['2113265921'], ARRAY[(SELECT * FROM first_node_id), (SELECT * FROM first_node_id)], 'block_writes') FROM shardid; ERROR: could not acquire the lock required to split public.concurrent_table_1 step s2-commit: COMMIT; step s3-sanity-check: SELECT count(*) FROM pg_dist_shard LEFT JOIN pg_dist_shard_placement USING(shardid) WHERE nodename IS NULL; count --------------------------------------------------------------------- 0 (1 row) step s3-sanity-check-2: SELECT count(*) FROM concurrent_table_1 JOIN concurrent_table_2 USING (id); count --------------------------------------------------------------------- 0 (1 row) starting permutation: s4-begin s4-move-shard-logical s5-setup-rep-factor s5-create_implicit_colocated_distributed_table s4-commit s3-sanity-check s3-sanity-check-3 s3-sanity-check-4 step s4-begin: BEGIN; step s4-move-shard-logical: WITH shardid AS (SELECT shardid FROM pg_dist_shard where logicalrelid = 'concurrent_table_4'::regclass ORDER BY shardid LIMIT 1) SELECT citus_move_Shard_placement(shardid.shardid, 'localhost', 57637, 'localhost', 57638) FROM shardid; citus_move_shard_placement --------------------------------------------------------------------- (1 row) step s5-setup-rep-factor: SET citus.shard_replication_factor TO 1; step s5-create_implicit_colocated_distributed_table: SELECT create_distributed_table('concurrent_table_5', 'id'); ERROR: could not acquire the lock required to colocate distributed table public.concurrent_table_1 step s4-commit: commit; step s3-sanity-check: SELECT count(*) FROM pg_dist_shard LEFT JOIN pg_dist_shard_placement USING(shardid) WHERE nodename IS NULL; count --------------------------------------------------------------------- 0 (1 row) step s3-sanity-check-3: SELECT count(DISTINCT colocationid) FROM pg_dist_partition WHERE logicalrelid IN ('concurrent_table_4', 'concurrent_table_5'); count --------------------------------------------------------------------- 1 (1 row) step s3-sanity-check-4: SELECT count(*) FROM concurrent_table_4 JOIN concurrent_table_5 USING (id); count --------------------------------------------------------------------- 0 (1 row) starting permutation: s4-begin s4-move-shard-block s5-setup-rep-factor s5-create_implicit_colocated_distributed_table s4-commit s3-sanity-check s3-sanity-check-3 s3-sanity-check-4 step s4-begin: BEGIN; step s4-move-shard-block: WITH shardid AS (SELECT shardid FROM pg_dist_shard where logicalrelid = 'concurrent_table_4'::regclass ORDER BY shardid LIMIT 1) SELECT citus_move_Shard_placement(shardid.shardid, 'localhost', 57637, 'localhost', 57638, 'block_writes') FROM shardid; citus_move_shard_placement --------------------------------------------------------------------- (1 row) step s5-setup-rep-factor: SET citus.shard_replication_factor TO 1; step s5-create_implicit_colocated_distributed_table: SELECT create_distributed_table('concurrent_table_5', 'id'); ERROR: could not acquire the lock required to colocate distributed table public.concurrent_table_1 step s4-commit: commit; step s3-sanity-check: SELECT count(*) FROM pg_dist_shard LEFT JOIN pg_dist_shard_placement USING(shardid) WHERE nodename IS NULL; count --------------------------------------------------------------------- 0 (1 row) step s3-sanity-check-3: SELECT count(DISTINCT colocationid) FROM pg_dist_partition WHERE logicalrelid IN ('concurrent_table_4', 'concurrent_table_5'); count --------------------------------------------------------------------- 1 (1 row) step s3-sanity-check-4: SELECT count(*) FROM concurrent_table_4 JOIN concurrent_table_5 USING (id); count --------------------------------------------------------------------- 0 (1 row)