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

Fix master_remove_node

pull/801/merge
Brian Cloutier 2016-09-23 20:51:20 +03:00
parent cd6a1b8d58
commit 34bd766cc3
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/backend/distributed/master/master_metadata_utility.c
View File

@ -206,7 +206,7 @@ ShardLength(uint64 shardId)
bool bool
NodeHasShardPlacements(char *nodeName, int32 nodePort) NodeHasShardPlacements(char *nodeName, int32 nodePort)
{ {
const int scanKeyCount = 3; const int scanKeyCount = 2;
const bool indexOK = true; const bool indexOK = true;
bool hasPlacements = false; bool hasPlacements = false;
@ -222,8 +222,6 @@ NodeHasShardPlacements(char *nodeName, int32 nodePort)
BTEqualStrategyNumber, F_TEXTEQ, CStringGetTextDatum(nodeName)); BTEqualStrategyNumber, F_TEXTEQ, CStringGetTextDatum(nodeName));
ScanKeyInit(&scanKey[1], Anum_pg_dist_shard_placement_nodeport, ScanKeyInit(&scanKey[1], Anum_pg_dist_shard_placement_nodeport,
BTEqualStrategyNumber, F_INT4EQ, Int32GetDatum(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, scanDescriptor = systable_beginscan(pgShardPlacement,
DistShardPlacementNodeidIndexId(), indexOK, DistShardPlacementNodeidIndexId(), indexOK,