summaryrefslogtreecommitdiff
path: root/src/backend/executor/nodeGather.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/backend/executor/nodeGather.c')
-rw-r--r--src/backend/executor/nodeGather.c4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/backend/executor/nodeGather.c b/src/backend/executor/nodeGather.c
index 4f8a17df7da..1283d5b737a 100644
--- a/src/backend/executor/nodeGather.c
+++ b/src/backend/executor/nodeGather.c
@@ -168,13 +168,13 @@ ExecGather(PlanState *pstate)
/* Initialize, or re-initialize, shared state needed by workers. */
if (!node->pei)
- node->pei = ExecInitParallelPlan(node->ps.lefttree,
+ node->pei = ExecInitParallelPlan(outerPlanState(node),
estate,
gather->initParam,
gather->num_workers,
node->tuples_needed);
else
- ExecParallelReinitialize(node->ps.lefttree,
+ ExecParallelReinitialize(outerPlanState(node),
node->pei,
gather->initParam);