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

Reidnent

niupre/TestDeferredDropAndCleanup
Nitish Upreti 2022-08-30 17:40:52 -07:00
parent c8b7817bec
commit c58594ef36
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -151,7 +151,8 @@ static List * ExecuteSplitShardReplicationSetupUDF(WorkerNode *sourceWorkerNode,
DistributionColumnMap * DistributionColumnMap *
distributionColumnOverrides); distributionColumnOverrides);
static void ExecuteSplitShardReleaseSharedMemory(WorkerNode *sourceWorkerNode); static void ExecuteSplitShardReleaseSharedMemory(WorkerNode *sourceWorkerNode);
static void AddDummyShardEntryInMap(HTAB *mapOfPlacementToDummyShardList, uint32 targetNodeId, static void AddDummyShardEntryInMap(HTAB *mapOfPlacementToDummyShardList, uint32
targetNodeId,
ShardInterval *shardInterval); ShardInterval *shardInterval);
static uint64 GetNextShardIdForSplitChild(void); static uint64 GetNextShardIdForSplitChild(void);
static void AcquireNonblockingSplitLock(Oid relationId); static void AcquireNonblockingSplitLock(Oid relationId);
@ -1486,7 +1487,7 @@ NonBlockingShardSplit(SplitOperation splitOperation,
* information. * information.
*/ */
HTAB *mapOfPlacementToDummyShardList = CreateSimpleHash(NodeAndOwner, HTAB *mapOfPlacementToDummyShardList = CreateSimpleHash(NodeAndOwner,
GroupedShardSplitInfos); GroupedShardSplitInfos);
CreateDummyShardsForShardGroup( CreateDummyShardsForShardGroup(
mapOfPlacementToDummyShardList, mapOfPlacementToDummyShardList,
sourceColocatedShardIntervalList, sourceColocatedShardIntervalList,