Commit681aa43

Maksim Milyutin

committed

Fix problem with parallel queries when none partition is selected

1 parent5327ca9 commit681aa43Copy full SHA for 681aa43

File tree

+24

-5

lines changed

+24

-5

lines changed

Lines changed: 8 additions & 5 deletions

Original file line number	Diff line number	Diff line change
`@@ -1878,12 +1878,15 @@ set_append_rel_pathlist(PlannerInfo root, RelOptInfo rel, Index rti,`
`1878`	`1878`
`1879`	`1879`	`parallel_workers=Max(parallel_workers,path->parallel_workers);`
`1880`	`1880`	`}`
`1881`		`-Assert(parallel_workers>0);`
`1882`	`1881`
`1883`		`-/* Generate a partial append path. */`
`1884`		`-appendpath=create_append_path(rel,partial_subpaths,NULL,`
`1885`		`-parallel_workers);`
`1886`		`-add_partial_path(rel, (Path*)appendpath);`
	`1882`	`+if (parallel_workers>0)`
	`1883`	`+{`
	`1884`	`+`
	`1885`	`+/* Generate a partial append path. */`
	`1886`	`+appendpath=create_append_path(rel,partial_subpaths,NULL,`
	`1887`	`+parallel_workers);`
	`1888`	`+add_partial_path(rel, (Path*)appendpath);`
	`1889`	`+}`
`1887`	`1890`	`}`
`1888`	`1891`	`#endif`
`1889`	`1892`

Lines changed: 16 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -580,6 +580,22 @@ def ordered(obj):`
`580`	`580`	`res_tuples=sorted(map(lambdax:x[0],res_tuples))`
`581`	`581`	`expected= [1,2,3,4,5]`
`582`	`582`	`self.assertEqual(res_tuples,expected)`
	`583`	`+`
	`584`	`+# Check the case when none partition is selected in result plan`
	`585`	`+test_query='select * from range_partitioned where i < 1'`
	`586`	`+plan=con.execute('select query_plan(\'%s\')'%test_query)[0][0]`
	`587`	`+expected=json.loads("""`
	`588`	`+ [`
	`589`	`+ {`
	`590`	`+ "Plan": {`
	`591`	`+ "Node Type": "Result",`
	`592`	`+ "Parallel Aware": false,`
	`593`	`+ "One-Time Filter": "false"`
	`594`	`+ }`
	`595`	`+ }`
	`596`	`+ ]`
	`597`	`+ """)`
	`598`	`+self.assertEqual(ordered(plan),ordered(expected))`
`583`	`599`	`# import ipdb; ipdb.set_trace()`
`584`	`600`
`585`	`601`	`# Remove all objects for testing`

Comments

(0)