aboutsummaryrefslogtreecommitdiff
path: root/src/backend/executor/nodeGatherMerge.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/backend/executor/nodeGatherMerge.c')
-rw-r--r--src/backend/executor/nodeGatherMerge.c4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/backend/executor/nodeGatherMerge.c b/src/backend/executor/nodeGatherMerge.c
index a488cc6d8be..3b1007f3526 100644
--- a/src/backend/executor/nodeGatherMerge.c
+++ b/src/backend/executor/nodeGatherMerge.c
@@ -212,13 +212,13 @@ ExecGatherMerge(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,
gm->initParam,
gm->num_workers,
node->tuples_needed);
else
- ExecParallelReinitialize(node->ps.lefttree,
+ ExecParallelReinitialize(outerPlanState(node),
node->pei,
gm->initParam);