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

fix

tenant-schema-isolation-complete-view
Onur Tirtir 2023-10-16 16:13:31 +03:00
parent 01b2bf5e3c
commit ac97d54515
3 changed files with 1 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -99,7 +99,6 @@ static int WorkerNodeListGetNodeWithGroupId(List *workerNodeList, int32 nodeGrou
RebalancerPlacementSeparationContext * RebalancerPlacementSeparationContext *
PrepareRebalancerPlacementSeparationContext(List *activeWorkerNodeList, PrepareRebalancerPlacementSeparationContext(List *activeWorkerNodeList,
List *rebalancePlacementList, List *rebalancePlacementList,
WorkerNode *drainWorkerNode,
FmgrInfo *shardAllowedOnNodeUDF) FmgrInfo *shardAllowedOnNodeUDF)
{ {
HTAB *nodePlacementGroupHash = HTAB *nodePlacementGroupHash =
@ -115,7 +114,7 @@ PrepareRebalancerPlacementSeparationContext(List *activeWorkerNodeList,
rebalancePlacementList = SortList(rebalancePlacementList, CompareShardPlacements); rebalancePlacementList = SortList(rebalancePlacementList, CompareShardPlacements);
InitRebalancerPlacementSeparationContext(context, activeWorkerNodeList, InitRebalancerPlacementSeparationContext(context, activeWorkerNodeList,
rebalancePlacementList, drainWorkerNode); rebalancePlacementList);
TryAssignPlacementGroupsToNodeGroups(context, TryAssignPlacementGroupsToNodeGroups(context,
activeWorkerNodeList, activeWorkerNodeList,

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

@ -598,7 +598,6 @@ GetRebalanceSteps(RebalanceOptions *options)
PrepareRebalancerPlacementSeparationContext( PrepareRebalancerPlacementSeparationContext(
activeWorkerList, activeWorkerList,
FlattenNestedList(activeShardPlacementListList), FlattenNestedList(activeShardPlacementListList),
options->workerNode,
&context.shardAllowedOnNodeUDF); &context.shardAllowedOnNodeUDF);
return RebalancePlacementUpdates(activeWorkerList, return RebalancePlacementUpdates(activeWorkerList,

3
src/include/distributed/rebalancer_placement_separation.h
View File

@ -26,9 +26,6 @@ extern RebalancerPlacementSeparationContext * PrepareRebalancerPlacementSeparati
List List
* *
activeShardPlacementList, activeShardPlacementList,
WorkerNode
*
drainWorkerNode,
FmgrInfo FmgrInfo
* *
shardAllowedOnNodeUDF); shardAllowedOnNodeUDF);