diff --git a/src/test/regress/expected/failure_connection_establishment.out b/src/test/regress/expected/failure_connection_establishment.out index 54ee0093f..8166af534 100644 --- a/src/test/regress/expected/failure_connection_establishment.out +++ b/src/test/regress/expected/failure_connection_establishment.out @@ -70,7 +70,9 @@ HINT: To remove the local data, run: SELECT truncate_local_data_after_distribut (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 --------------------------------------------------------------------- 1450000 | 1450000 | products | 2 diff --git a/src/test/regress/sql/failure_connection_establishment.sql b/src/test/regress/sql/failure_connection_establishment.sql index 4d462fb61..eb8ba9e46 100644 --- a/src/test/regress/sql/failure_connection_establishment.sql +++ b/src/test/regress/sql/failure_connection_establishment.sql @@ -49,7 +49,9 @@ INSERT INTO r1 (id, name) VALUES 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();