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

Merge pull request #3779 from citusdata/insert-select-copy-cache-entry 

Try copying shard intervals out of cache for long lived borrow
pull/3778/head
Philip Dubé 2020-04-17 22:49:58 +00:00 committed by GitHub
parent a461ef20d9 8e79672839
commit c03d3714b3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 30 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
src/backend/distributed/executor/insert_select_executor.c
View File

@ -210,8 +210,37 @@ CoordinatorInsertSelectExecScanInternal(CustomScanState *node)
distSelectJob->jobId);
char *distResultPrefix = distResultPrefixString->data;
CitusTableCacheEntry *targetRelation =
CitusTableCacheEntry *cachedTargetRelation =
GetCitusTableCacheEntry(targetRelationId);
CitusTableCacheEntry *targetRelation = palloc(sizeof(CitusTableCacheEntry));
*targetRelation = *cachedTargetRelation;
#if PG_USE_ASSERT_CHECKING
/*
* These fields aren't used in the code which follows,
* therefore in assert builds NULL these fields to
* segfault if they were to be used.
*/
targetRelation->partitionKeySTring = NULL;
targetRelation->shardIntervalCompareFunction = NULL;
targetRelation->hashFunction = NULL;
targetRelation->arrayOfPlacementArrayLengths = NULL;
targetRelation->arrayOfPlacementArrays = NULL;
targetRelation->referencedRelationViaForeignKey = NULL;
targetRelation->referencingRelationsViaForeignKey = NULL;
#endif
targetRelation->partitionColumn = copyObject(
cachedTargetRelation->partitionColumn);
targetRelation->sortedShardIntervalArray =
palloc(targetRelation->shardIntervalArrayLength * sizeof(ShardInterval));
for (int shardIndex = 0; shardIndex <
targetRelation->shardIntervalArrayLength; shardIndex++)
{
targetRelation->sortedShardIntervalArray[shardIndex] =
CopyShardInterval(
cachedTargetRelation->sortedShardIntervalArray[shardIndex]);
}
int partitionColumnIndex =
PartitionColumnIndex(insertTargetList, targetRelation->partitionColumn);