From 7550b8ad52f2ecf1e051931518fed272eba2e3b3 Mon Sep 17 00:00:00 2001
From: velioglu <velioglu@ceng.metu.edu.tr>
Date: Wed, 9 Aug 2017 11:26:19 +0300
Subject: [PATCH] Fix anchor shard id selection when reference table exists

---
 src/backend/distributed/planner/multi_physical_planner.c | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/backend/distributed/planner/multi_physical_planner.c b/src/backend/distributed/planner/multi_physical_planner.c
index 53eeba729..851597393 100644
--- a/src/backend/distributed/planner/multi_physical_planner.c
+++ b/src/backend/distributed/planner/multi_physical_planner.c
@@ -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;