From c3ed6ba62bdba48a0f97fe56228b8d43eb62b557 Mon Sep 17 00:00:00 2001 From: Brian Cloutier Date: Thu, 31 Mar 2016 12:35:07 +0000 Subject: [PATCH] Treat nodePort as the 64bit integer it is --- src/backend/distributed/master/master_metadata_utility.c | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/backend/distributed/master/master_metadata_utility.c b/src/backend/distributed/master/master_metadata_utility.c index 7e87b4326..c65a81195 100644 --- a/src/backend/distributed/master/master_metadata_utility.c +++ b/src/backend/distributed/master/master_metadata_utility.c @@ -337,7 +337,7 @@ TupleToShardPlacement(TupleDesc tupleDescriptor, HeapTuple heapTuple) shardPlacement->shardLength = DatumGetInt64(shardLength); shardPlacement->shardState = DatumGetUInt32(shardState); shardPlacement->nodeName = TextDatumGetCString(nodeName); - shardPlacement->nodePort = DatumGetUInt32(nodePort); + shardPlacement->nodePort = DatumGetInt64(nodePort); return shardPlacement; } @@ -420,7 +420,7 @@ InsertShardPlacementRow(uint64 shardId, char shardState, uint64 shardLength, values[Anum_pg_dist_shard_placement_shardstate - 1] = CharGetDatum(shardState); values[Anum_pg_dist_shard_placement_shardlength - 1] = Int64GetDatum(shardLength); values[Anum_pg_dist_shard_placement_nodename - 1] = CStringGetTextDatum(nodeName); - values[Anum_pg_dist_shard_placement_nodeport - 1] = UInt32GetDatum(nodePort); + values[Anum_pg_dist_shard_placement_nodeport - 1] = Int64GetDatum(nodePort); /* open shard placement relation and insert new tuple */ pgDistShardPlacement = heap_open(DistShardPlacementRelationId(), RowExclusiveLock);