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

Merge pull request #910 from citusdata/int8-nodeport 

Treat nodePort as the 8byte number it is
pull/901/head
Brian Cloutier 2016-10-25 17:12:44 +03:00 committed by GitHub
parent 2e96f6ab27 c6b74b023f
commit 750855bcc0
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -222,7 +222,7 @@ NodeHasActiveShardPlacements(char *nodeName, int32 nodePort)
ScanKeyInit(&scanKey[0], Anum_pg_dist_shard_placement_nodename, ScanKeyInit(&scanKey[0], Anum_pg_dist_shard_placement_nodename,
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_INT8EQ, Int64GetDatum(nodePort));
ScanKeyInit(&scanKey[2], Anum_pg_dist_shard_placement_shardstate, ScanKeyInit(&scanKey[2], Anum_pg_dist_shard_placement_shardstate,
BTEqualStrategyNumber, F_INT4EQ, Int32GetDatum(FILE_FINALIZED)); BTEqualStrategyNumber, F_INT4EQ, Int32GetDatum(FILE_FINALIZED));