Re: [HACKERS] Parallel Append implementation
Amul Sul <sulamul@gmail.com>
From: amul sul <sulamul@gmail.com>
To: Robert Haas <robertmhaas@gmail.com>
Cc: Amit Khandekar <amitdkhan.pg@gmail.com>,
Rafia Sabih <rafia.sabih@enterprisedb.com>, Amit Kapila <amit.kapila16@gmail.com>, Andres Freund <andres@anarazel.de>, Ashutosh Bapat <ashutosh.bapat@enterprisedb.com>, pgsql-hackers <pgsql-hackers@postgresql.org>
Date: 2017-11-23T04:15:08Z
Lists: pgsql-hackers
Attachments
- ParallelAppend_v20.patch (application/octet-stream) patch v20
On Wed, Nov 22, 2017 at 1:44 AM, Robert Haas <robertmhaas@gmail.com> wrote: > On Tue, Nov 21, 2017 at 6:57 AM, amul sul <sulamul@gmail.com> wrote: >> By doing following change on the v19 patch does the fix for me: >> >> --- a/src/backend/executor/nodeAppend.c >> +++ b/src/backend/executor/nodeAppend.c >> @@ -489,11 +489,9 @@ choose_next_subplan_for_worker(AppendState *node) >> } >> >> /* Pick the plan we found, and advance pa_next_plan one more time. */ >> - node->as_whichplan = pstate->pa_next_plan; >> + node->as_whichplan = pstate->pa_next_plan++; >> if (pstate->pa_next_plan == node->as_nplans) >> pstate->pa_next_plan = append->first_partial_plan; >> - else >> - pstate->pa_next_plan++; >> >> /* If non-partial, immediately mark as finished. */ >> if (node->as_whichplan < append->first_partial_plan) >> >> Attaching patch does same changes to Amit's ParallelAppend_v19_rebased.patch. > > Yes, that looks like a correct fix. Thanks. > Attaching updated version of "ParallelAppend_v19_rebased" includes this fix. Regards, Amul
Commits
-
Update parallel.sgml for Parallel Append
- ac535cd47806 11.0 landed
- e80f2b335ecd 12.0 landed
-
Support Parallel Append plan nodes.
- ab7271677812 11.0 landed
-
Remove BufFile's isTemp flag.
- 11e264517dff 11.0 cited
-
Improve comments for parallel executor estimation functions.
- 11c1d555cebe 11.0 landed
-
Separate reinitialization of shared parallel-scan state from ExecReScan.
- 41b0dd987d44 11.0 cited
-
Eat XIDs more efficiently in recovery TAP test.
- 08aed6604de2 10.0 cited
-
Avoid syntax error on platforms that have neither LOCALE_T nor ICU.
- 457a44487328 10.0 cited
-
Preparatory refactoring for parallel merge join support.
- a71f10189dc1 10.0 cited