Commit9c64ddd

committed

Fix Parallel Append crash.

1 parent979a36c commit9c64dddCopy full SHA for 9c64ddd

File tree

+10

-2

lines changed

+10

-2

lines changed

Lines changed: 10 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -506,8 +506,16 @@ choose_next_subplan_for_worker(AppendState *node)`
`506`	`506`	`node->as_whichplan=pstate->pa_next_plan++;`
`507`	`507`	`if (pstate->pa_next_plan >=node->as_nplans)`
`508`	`508`	`{`
`509`		`-Assert(append->first_partial_plan<node->as_nplans);`
`510`		`-pstate->pa_next_plan=append->first_partial_plan;`
	`509`	`+if (append->first_partial_plan<node->as_nplans)`
	`510`	`+pstate->pa_next_plan=append->first_partial_plan;`
	`511`	`+else`
	`512`	`+{`
	`513`	`+/*`
	`514`	`+ * We have only non-partial plans, and we already chose the last`
	`515`	`+ * one; so arrange for the other workers to immediately bail out.`
	`516`	`+ */`
	`517`	`+pstate->pa_next_plan=INVALID_SUBPLAN_INDEX;`
	`518`	`+}`
`511`	`519`	`}`
`512`	`520`
`513`	`521`	`/* If non-partial, immediately mark as finished. */`

Comments

(0)