diff --git a/src/backend/executor/nodeGather.c b/src/backend/executor/nodeGather.c index 89266b5..384817c 100644 --- a/src/backend/executor/nodeGather.c +++ b/src/backend/executor/nodeGather.c @@ -173,6 +173,7 @@ ExecGather(PlanState *pstate) */ pcxt = node->pei->pcxt; LaunchParallelWorkers(pcxt); + WaitForParallelWorkersToAttach(pcxt); /* We save # workers launched for the benefit of EXPLAIN */ node->nworkers_launched = pcxt->nworkers_launched;