mirror of https://github.com/citusdata/citus.git
commit
5604669db5
|
@ -2007,13 +2007,13 @@ SubquerySqlTaskList(Job *job)
|
|||
{
|
||||
ShardInterval *shardInterval = (ShardInterval *) lfirst(shardIntervalCell);
|
||||
|
||||
tableSize += ShardLength(shardInterval->shardId);
|
||||
|
||||
RangeTableFragment *shardFragment = palloc0(fragmentSize);
|
||||
shardFragment->fragmentReference = &(shardInterval->shardId);
|
||||
shardFragment->fragmentType = CITUS_RTE_RELATION;
|
||||
shardFragment->rangeTableId = tableId;
|
||||
|
||||
tableSize += ShardLength(shardInterval->shardId);
|
||||
|
||||
if (tableId == 1)
|
||||
{
|
||||
List *fragmentCombination = list_make1(shardFragment);
|
||||
|
|
Loading…
Reference in New Issue