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

Hello World shard split works

pull/6029/head
Nitish Upreti 2022-06-22 15:01:00 -07:00
parent a8e3344a40
commit ac29dbabf4
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -50,8 +50,7 @@ citus_split_shard_by_split_points(PG_FUNCTION_ARGS)
INT4OID);
ArrayType *nodeIdsArrayObject = PG_GETARG_ARRAYTYPE_P(2);
List *nodeIdsForPlacementList = TextArrayTypeToIntegerList(nodeIdsArrayObject,
INT4OID);
List *nodeIdsForPlacementList = IntegerArrayTypeToList(nodeIdsArrayObject);
Oid shardSplitModeOid = PG_GETARG_OID(3);
SplitMode shardSplitMode = LookupSplitMode(shardSplitModeOid);

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

@ -407,7 +407,8 @@ BlockingShardSplit(SplitOperation splitOperation,
/* Only single placement allowed (already validated by caller) */
List *sourcePlacementList = ActiveShardPlacementList(shardIntervalToSplit->shardId);
Assert(sourcePlacementList->length == 1);
WorkerNode *sourceShardToCopyNode = (WorkerNode *) linitial(sourcePlacementList);
ShardPlacement *sourceShardPlacement = (ShardPlacement *) linitial(sourcePlacementList);
WorkerNode *sourceShardToCopyNode = FindNodeWithNodeId(sourceShardPlacement->nodeId, false /* missingOk */);
/* Physically create split children and perform split copy */
List *splitOffShardList = NULL;