NotificationsYou must be signed in to change notification settings
Fork6
Star31

Commitbc049d0

committed

Always call ExecShutdownNode() if appropriate.

Call ExecShutdownNode() after ExecutePlan()'s loop, rather than at eachbreak. We had forgotten to do that in one case. The omission causedintermittent "temporary file leak" warnings from multi-batch parallelhash joins with a LIMIT clause.Back-patch to 11. Though the problem exists in theory in earlierparallel query releases, nothing really depended on it.Author: Kyotaro HoriguchiReviewed-by: Thomas Munro, Amit KapilaDiscussion:https://postgr.es/m/20191111.212418.2222262873417235945.horikyota.ntt%40gmail.com

1 parentd66e682 commitbc049d0Copy full SHA for bc049d0

File tree

1 file changed

-16

lines changed

src/backend/executor
- execMain.c

1 file changed

-16

lines changed

`‎src/backend/executor/execMain.c`

Lines changed: 7 additions & 16 deletions

Original file line number	Diff line number	Diff line change
`@@ -1727,15 +1727,7 @@ ExecutePlan(EState *estate,`
`1727`	`1727`	`* process so we just end the loop...`
`1728`	`1728`	`*/`
`1729`	`1729`	`if (TupIsNull(slot))`
`1730`		`-{`
`1731`		`-/*`
`1732`		`- * If we know we won't need to back up, we can release resources`
`1733`		`- * at this point.`
`1734`		`- */`
`1735`		`-if (!(estate->es_top_eflags&EXEC_FLAG_BACKWARD))`
`1736`		`-(void)ExecShutdownNode(planstate);`
`1737`	`1730`	`break;`
`1738`		`-}`
`1739`	`1731`
`1740`	`1732`	`/*`
`1741`	`1733`	`* If we have a junk filter, then project a new tuple with the junk`
`@@ -1778,17 +1770,16 @@ ExecutePlan(EState *estate,`
`1778`	`1770`	`*/`
`1779`	`1771`	`current_tuple_count++;`
`1780`	`1772`	`if (numberTuples&&numberTuples==current_tuple_count)`
`1781`		`-{`
`1782`		`-/*`
`1783`		`- * If we know we won't need to back up, we can release resources`
`1784`		`- * at this point.`
`1785`		`- */`
`1786`		`-if (!(estate->es_top_eflags&EXEC_FLAG_BACKWARD))`
`1787`		`-(void)ExecShutdownNode(planstate);`
`1788`	`1773`	`break;`
`1789`		`-}`
`1790`	`1774`	`}`
`1791`	`1775`
	`1776`	`+/*`
	`1777`	`+ * If we know we won't need to back up, we can release resources at this`
	`1778`	`+ * point.`
	`1779`	`+ */`
	`1780`	`+if (!(estate->es_top_eflags&EXEC_FLAG_BACKWARD))`
	`1781`	`+(void)ExecShutdownNode(planstate);`
	`1782`	`+`
`1792`	`1783`	`if (use_parallel_mode)`
`1793`	`1784`	`ExitParallelMode();`
`1794`	`1785`	`}`

0 commit comments

Comments

(0)

Movatterモバイル変換

Navigation Menu

Search code, repositories, users, issues, pull requests...

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Commitbc049d0

File tree

1 file changed

1 file changed

`‎src/backend/executor/execMain.c`

0 commit comments