Skip to content

Commit e520e30

Browse files
committed
Add GUC gp_use_streaming_hashagg
Swtich GUC to check results and avoid a lot of plan diffs in pax test cases. Authored-by: Zhang Mingli avamingli@gmail.com
1 parent 5a6c2a4 commit e520e30

20 files changed

Lines changed: 62 additions & 1 deletion

contrib/pax_storage/src/test/regress/sql/agg_pushdown.sql

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,8 @@
11
-- disable ORCA
22
SET optimizer TO off;
3+
-- start_ignore
4+
set gp_use_streaming_hashagg = off;
5+
-- end_ignore
36

47
-- Test case group 1: basic functions
58
CREATE TABLE agg_pushdown_parent (

contrib/pax_storage/src/test/regress/sql/aggregates.sql

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,9 @@
11
--
22
-- AGGREGATES
33
--
4+
-- start_ignore
5+
set gp_use_streaming_hashagg = off;
6+
-- end_ignore
47

58
-- start_ignore
69
-- end_ignore

contrib/pax_storage/src/test/regress/sql/bfv_aggregate.sql

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,8 @@
11
create schema bfv_aggregate;
22
set search_path=bfv_aggregate;
3+
-- start_ignore
4+
set gp_use_streaming_hashagg = off;
5+
-- end_ignore
36

47
--
58
-- Window function with outer references in PARTITION BY/ORDER BY clause

contrib/pax_storage/src/test/regress/sql/direct_dispatch.sql

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,8 @@
11
-- turn off autostats so we don't have to worry about the logging of the autostat queries
22
set gp_autostats_mode = None;
3+
-- start_ignore
4+
set gp_use_streaming_hashagg = off;
5+
-- end_ignore
36

47
-- create needed tables (in a transaction, for speed)
58
begin;

contrib/pax_storage/src/test/regress/sql/eagerfree.sql

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,8 @@
11
create schema eagerfree;
22
set search_path=eagerfree;
3+
-- start_ignore
4+
set gp_use_streaming_hashagg = off;
5+
-- end_ignore
36

47
create table smallt (i int, t text, d date) distributed by (i);
58
insert into smallt select i%10, 'text ' || (i%15), '2011-01-01'::date + ((i%20) || ' days')::interval

contrib/pax_storage/src/test/regress/sql/gp_aggregates_costs.sql

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,9 @@ insert into cost_agg_t2 select i, random() * 99999, i % 300000 from generate_ser
55
analyze cost_agg_t1;
66
analyze cost_agg_t2;
77

8+
-- start_ignore
9+
set gp_use_streaming_hashagg = off;
10+
-- end_ignore
811
--
912
-- Test planner's decisions on aggregates when only little memory is available.
1013
--

contrib/pax_storage/src/test/regress/sql/gp_hashagg.sql

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,9 @@ insert into hashagg_test values (1,1,'1/1/2006','hi',2);
1010
insert into hashagg_test values (1,1,'1/2/2006','hi',3);
1111
insert into hashagg_test values (1,1,'1/3/2006','hi',4);
1212

13+
-- start_ignore
14+
set gp_use_streaming_hashagg = off;
15+
-- end_ignore
1316
-- this will get the wrong answer (right number of rows, wrong aggregates)
1417
set enable_seqscan=off;
1518
select grp,sum(v) from hashagg_test where id1 = 1 and id2 = 1 and day between '1/1/2006' and '1/31/2006' group by grp order by sum(v) desc;

contrib/pax_storage/src/test/regress/sql/gporca.sql

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,9 @@
11
--
22
-- ORCA tests
33
--
4+
-- start_ignore
5+
set gp_use_streaming_hashagg = off;
6+
-- end_ignore
47

58
-- show version
69
SELECT count(*) from gp_opt_version();

contrib/pax_storage/src/test/regress/sql/indexjoin.sql

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,9 @@ CREATE TABLE my_tt_agg_small (
44
trade_price numeric,
55
trade_volume bigint
66
) DISTRIBUTED BY (symbol);
7+
-- start_ignore
8+
set gp_use_streaming_hashagg = off;
9+
-- end_ignore
710

811

912
CREATE TABLE my_tq_agg_small (

contrib/pax_storage/src/test/regress/sql/limit_gp.sql

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,9 @@
22
-- Check for MPP-19310 and MPP-19857 where mksort produces wrong result
33
-- on OPT build, and fails assertion on debug build if a "LIMIT" query
44
-- spills to disk.
5+
-- start_ignore
6+
set gp_use_streaming_hashagg = off;
7+
-- end_ignore
58

69
CREATE TABLE mksort_limit_test_table(dkey INT, jkey INT, rval REAL, tval TEXT default repeat('abcdefghijklmnopqrstuvwxyz', 300)) DISTRIBUTED BY (dkey);
710
INSERT INTO mksort_limit_test_table VALUES(generate_series(1, 10000), generate_series(10001, 20000), sqrt(generate_series(10001, 20000)));

0 commit comments

Comments
 (0)