Updating SQL test query

users/niupre/DeferredDropSimplified
Nitish Upreti 2022-08-15 17:17:50 -07:00
parent 27dae42843
commit cfd914ac4a
2 changed files with 5 additions and 2 deletions

View File

@ -3599,7 +3599,7 @@ InitializeDistCache(void)
DistShardScanKey[0].sk_collation = InvalidOid;
DistShardScanKey[0].sk_attno = Anum_pg_dist_shard_logicalrelid;
fmgr_info_cxt(F_OIDEQ,
fmgr_info_cxt(F_INT4EQ,
&DistShardScanKey[1].sk_func,
MetadataCacheMemoryContext);
DistShardScanKey[1].sk_strategy = BTLessStrategyNumber;

View File

@ -188,7 +188,10 @@ CREATE TABLE cluster_management_test_colocated (col_1 text, col_2 int);
SELECT create_distributed_table('cluster_management_test_colocated', 'col_1', 'hash', colocate_with => 'cluster_management_test');
-- Check that colocated shards don't get created for shards that are to be deleted
SELECT logicalrelid, shardid, shardstate, nodename, nodeport FROM pg_dist_shard_placement NATURAL JOIN pg_dist_shard ORDER BY shardstate, shardid;
SELECT logicalrelid, shardid, shardstate, nodename, nodeport
FROM pg_dist_shard_placement
INNER JOIN pg_dist_shard USING (shardid)
ORDER BY shardstate, shardid;
-- clean-up
SELECT 1 FROM master_add_node('localhost', :worker_2_port);