diff options
Diffstat (limited to 'src/backend/executor/nodeGather.c')
| -rw-r--r-- | src/backend/executor/nodeGather.c | 6 |
1 files changed, 1 insertions, 5 deletions
diff --git a/src/backend/executor/nodeGather.c b/src/backend/executor/nodeGather.c index b368b48d01d..b6e82d1664f 100644 --- a/src/backend/executor/nodeGather.c +++ b/src/backend/executor/nodeGather.c @@ -456,11 +456,7 @@ ExecReScanGather(GatherState *node) node->initialized = false; if (node->pei) - { - ReinitializeParallelDSM(node->pei->pcxt); - node->pei->tqueue = - ExecParallelReinitializeTupleQueues(node->pei->pcxt); - } + ExecParallelReinitialize(node->pei); ExecReScan(node->ps.lefttree); } |