external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Consistent output

fix-flaky-failure_connection_establishment2
Jelte Fennema 2022-08-23 00:24:27 +02:00
parent c588a42114
commit b9bc7441bf
2 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/test/regress/expected/failure_connection_establishment.out
View File

@ -70,7 +70,9 @@ HINT: To remove the local data, run: SELECT truncate_local_data_after_distribut
(1 row) (1 row)
SELECT placementid, p.shardid, logicalrelid, groupid FROM pg_dist_placement p JOIN pg_dist_shard s ON p.shardid = s.shardid; SELECT placementid, p.shardid, logicalrelid, LEAST(2, groupid) groupid
FROM pg_dist_placement p JOIN pg_dist_shard s ON p.shardid = s.shardid
ORDER BY placementid;
placementid | shardid | logicalrelid | groupid placementid | shardid | logicalrelid | groupid
--------------------------------------------------------------------- ---------------------------------------------------------------------
1450000 | 1450000 | products | 2 1450000 | 1450000 | products | 2

4
src/test/regress/sql/failure_connection_establishment.sql
View File

@ -49,7 +49,9 @@ INSERT INTO r1 (id, name) VALUES
SELECT create_reference_table('r1'); SELECT create_reference_table('r1');
SELECT placementid, p.shardid, logicalrelid, groupid FROM pg_dist_placement p JOIN pg_dist_shard s ON p.shardid = s.shardid; SELECT placementid, p.shardid, logicalrelid, LEAST(2, groupid) groupid
FROM pg_dist_placement p JOIN pg_dist_shard s ON p.shardid = s.shardid
ORDER BY placementid;
SELECT citus.clear_network_traffic(); SELECT citus.clear_network_traffic();