Fix anchor shard id selection when reference table exists

pull/1532/head
velioglu 2017-08-09 11:26:19 +03:00
parent ceba81ce35
commit 7550b8ad52
1 changed files with 1 additions and 1 deletions

View File

@ -2392,7 +2392,7 @@ SubqueryTaskCreate(Query *originalQuery, ShardInterval *shardInterval,
subqueryTask = CreateBasicTask(jobId, taskId, SQL_TASK, queryString->data);
subqueryTask->dependedTaskList = NULL;
subqueryTask->anchorShardId = selectAnchorShardId;
subqueryTask->anchorShardId = shardInterval->shardId;
subqueryTask->taskPlacementList = selectPlacementList;
subqueryTask->upsertQuery = false;
subqueryTask->relationShardList = relationShardList;