diff --git a/src/backend/distributed/planner/multi_physical_planner.c b/src/backend/distributed/planner/multi_physical_planner.c index 88675c1b6..181db5e9d 100644 --- a/src/backend/distributed/planner/multi_physical_planner.c +++ b/src/backend/distributed/planner/multi_physical_planner.c @@ -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);