From 34bd766cc3e70f63fffcec350357d53ff0439636 Mon Sep 17 00:00:00 2001 From: Brian Cloutier Date: Fri, 23 Sep 2016 20:51:20 +0300 Subject: [PATCH] Fix master_remove_node --- src/backend/distributed/master/master_metadata_utility.c | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/src/backend/distributed/master/master_metadata_utility.c b/src/backend/distributed/master/master_metadata_utility.c index 81516575c..6e98359e3 100644 --- a/src/backend/distributed/master/master_metadata_utility.c +++ b/src/backend/distributed/master/master_metadata_utility.c @@ -206,7 +206,7 @@ ShardLength(uint64 shardId) bool NodeHasShardPlacements(char *nodeName, int32 nodePort) { - const int scanKeyCount = 3; + const int scanKeyCount = 2; const bool indexOK = true; bool hasPlacements = false; @@ -222,8 +222,6 @@ NodeHasShardPlacements(char *nodeName, int32 nodePort) BTEqualStrategyNumber, F_TEXTEQ, CStringGetTextDatum(nodeName)); ScanKeyInit(&scanKey[1], Anum_pg_dist_shard_placement_nodeport, BTEqualStrategyNumber, F_INT4EQ, Int32GetDatum(nodePort)); - ScanKeyInit(&scanKey[2], Anum_pg_dist_shard_placement_shardstate, - BTEqualStrategyNumber, F_INT4EQ, Int32GetDatum(FILE_FINALIZED)); scanDescriptor = systable_beginscan(pgShardPlacement, DistShardPlacementNodeidIndexId(), indexOK,