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

Close connection after each shard move (#4967)

pull/4965/head^2
SaitTalhaNisanci 2021-05-10 16:57:19 +03:00 committed by GitHub
parent 8cb505d6e1
commit 5a941814fd
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/backend/distributed/operations/shard_rebalancer.c
View File

@ -1117,7 +1117,6 @@ UpdateShardPlacement(PlacementUpdateEvent *placementUpdateEvent,
WorkerNode *sourceNode = placementUpdateEvent->sourceNode; WorkerNode *sourceNode = placementUpdateEvent->sourceNode;
WorkerNode *targetNode = placementUpdateEvent->targetNode; WorkerNode *targetNode = placementUpdateEvent->targetNode;
const char *doRepair = "false"; const char *doRepair = "false";
int connectionFlag = FORCE_NEW_CONNECTION;
Datum shardTranferModeLabelDatum = Datum shardTranferModeLabelDatum =
DirectFunctionCall1(enum_out, shardReplicationModeOid); DirectFunctionCall1(enum_out, shardReplicationModeOid);
@ -1189,6 +1188,7 @@ UpdateShardPlacement(PlacementUpdateEvent *placementUpdateEvent,
sourceNode->workerPort, sourceNode->workerPort,
REBALANCE_PROGRESS_MOVING); REBALANCE_PROGRESS_MOVING);
int connectionFlag = FORCE_NEW_CONNECTION;
MultiConnection *connection = GetNodeConnection(connectionFlag, LOCAL_HOST_NAME, MultiConnection *connection = GetNodeConnection(connectionFlag, LOCAL_HOST_NAME,
PostPortNumber); PostPortNumber);
@ -1202,6 +1202,7 @@ UpdateShardPlacement(PlacementUpdateEvent *placementUpdateEvent,
sourceNode->workerName, sourceNode->workerName,
sourceNode->workerPort, sourceNode->workerPort,
REBALANCE_PROGRESS_MOVED); REBALANCE_PROGRESS_MOVED);
CloseConnection(connection);
return true; return true;
} }