You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@impala.apache.org by ta...@apache.org on 2018/11/19 17:27:29 UTC
[2/6] impala git commit: IMPALA-7367: Pack StringValue and
CollectionValue slots
http://git-wip-us.apache.org/repos/asf/impala/blob/2a4835cf/testdata/workloads/functional-planner/queries/PlannerTest/tpch-all.test
----------------------------------------------------------------------
diff --git a/testdata/workloads/functional-planner/queries/PlannerTest/tpch-all.test b/testdata/workloads/functional-planner/queries/PlannerTest/tpch-all.test
index 10efec9..4bab956 100644
--- a/testdata/workloads/functional-planner/queries/PlannerTest/tpch-all.test
+++ b/testdata/workloads/functional-planner/queries/PlannerTest/tpch-all.test
@@ -517,7 +517,7 @@ PLAN-ROOT SINK
runtime filters: RF002 -> l_orderkey
---- DISTRIBUTEDPLAN
Max Per-Host Resource Reservation: Memory=41.38MB Threads=8
-Per-Host Resource Estimates: Memory=546MB
+Per-Host Resource Estimates: Memory=545MB
PLAN-ROOT SINK
|
11:MERGING-EXCHANGE [UNPARTITIONED]
@@ -642,8 +642,8 @@ group by
order by
o_orderpriority
---- PLAN
-Max Per-Host Resource Reservation: Memory=34.00MB Threads=3
-Per-Host Resource Estimates: Memory=458MB
+Max Per-Host Resource Reservation: Memory=25.50MB Threads=3
+Per-Host Resource Estimates: Memory=450MB
PLAN-ROOT SINK
|
04:SORT
@@ -666,8 +666,8 @@ PLAN-ROOT SINK
predicates: l_commitdate < l_receiptdate
runtime filters: RF000 -> l_orderkey
---- DISTRIBUTEDPLAN
-Max Per-Host Resource Reservation: Memory=42.44MB Threads=7
-Per-Host Resource Estimates: Memory=497MB
+Max Per-Host Resource Reservation: Memory=38.69MB Threads=7
+Per-Host Resource Estimates: Memory=493MB
PLAN-ROOT SINK
|
09:MERGING-EXCHANGE [UNPARTITIONED]
@@ -703,8 +703,8 @@ PLAN-ROOT SINK
predicates: l_commitdate < l_receiptdate
runtime filters: RF000 -> l_orderkey
---- PARALLELPLANS
-Max Per-Host Resource Reservation: Memory=77.38MB Threads=9
-Per-Host Resource Estimates: Memory=450MB
+Max Per-Host Resource Reservation: Memory=73.62MB Threads=9
+Per-Host Resource Estimates: Memory=446MB
PLAN-ROOT SINK
|
09:MERGING-EXCHANGE [UNPARTITIONED]
@@ -828,7 +828,7 @@ PLAN-ROOT SINK
runtime filters: RF005 -> l_suppkey, RF010 -> l_orderkey
---- DISTRIBUTEDPLAN
Max Per-Host Resource Reservation: Memory=70.14MB Threads=14
-Per-Host Resource Estimates: Memory=668MB
+Per-Host Resource Estimates: Memory=667MB
PLAN-ROOT SINK
|
20:MERGING-EXCHANGE [UNPARTITIONED]
@@ -1148,8 +1148,8 @@ PLAN-ROOT SINK
predicates: l_shipdate <= '1996-12-31', l_shipdate >= '1995-01-01'
runtime filters: RF006 -> l_suppkey, RF008 -> l_orderkey
---- DISTRIBUTEDPLAN
-Max Per-Host Resource Reservation: Memory=103.95MB Threads=15
-Per-Host Resource Estimates: Memory=717MB
+Max Per-Host Resource Reservation: Memory=86.95MB Threads=15
+Per-Host Resource Estimates: Memory=699MB
PLAN-ROOT SINK
|
21:MERGING-EXCHANGE [UNPARTITIONED]
@@ -1224,8 +1224,8 @@ PLAN-ROOT SINK
predicates: l_shipdate <= '1996-12-31', l_shipdate >= '1995-01-01'
runtime filters: RF006 -> l_suppkey, RF008 -> l_orderkey
---- PARALLELPLANS
-Max Per-Host Resource Reservation: Memory=160.78MB Threads=17
-Per-Host Resource Estimates: Memory=670MB
+Max Per-Host Resource Reservation: Memory=144.78MB Threads=17
+Per-Host Resource Estimates: Memory=655MB
PLAN-ROOT SINK
|
21:MERGING-EXCHANGE [UNPARTITIONED]
@@ -1431,8 +1431,8 @@ PLAN-ROOT SINK
partitions=1/1 files=1 size=23.08MB
runtime filters: RF004 -> c_nationkey, RF006 -> c_custkey
---- DISTRIBUTEDPLAN
-Max Per-Host Resource Reservation: Memory=73.34MB Threads=21
-Per-Host Resource Estimates: Memory=759MB
+Max Per-Host Resource Reservation: Memory=71.46MB Threads=21
+Per-Host Resource Estimates: Memory=756MB
PLAN-ROOT SINK
|
29:MERGING-EXCHANGE [UNPARTITIONED]
@@ -1531,8 +1531,8 @@ PLAN-ROOT SINK
partitions=1/1 files=1 size=718.94MB
runtime filters: RF008 -> l_suppkey, RF010 -> l_orderkey, RF012 -> l_partkey
---- PARALLELPLANS
-Max Per-Host Resource Reservation: Memory=142.92MB Threads=25
-Per-Host Resource Estimates: Memory=726MB
+Max Per-Host Resource Reservation: Memory=141.05MB Threads=25
+Per-Host Resource Estimates: Memory=724MB
PLAN-ROOT SINK
|
29:MERGING-EXCHANGE [UNPARTITIONED]
@@ -1694,7 +1694,7 @@ order by
o_year desc
---- PLAN
Max Per-Host Resource Reservation: Memory=114.76MB Threads=7
-Per-Host Resource Estimates: Memory=844MB
+Per-Host Resource Estimates: Memory=838MB
PLAN-ROOT SINK
|
12:SORT
@@ -1746,8 +1746,8 @@ PLAN-ROOT SINK
partitions=1/1 files=1 size=718.94MB
runtime filters: RF002 -> l_partkey, RF003 -> l_suppkey, RF006 -> l_suppkey, RF008 -> l_orderkey, RF010 -> l_partkey
---- DISTRIBUTEDPLAN
-Max Per-Host Resource Reservation: Memory=140.70MB Threads=15
-Per-Host Resource Estimates: Memory=896MB
+Max Per-Host Resource Reservation: Memory=123.70MB Threads=15
+Per-Host Resource Estimates: Memory=879MB
PLAN-ROOT SINK
|
21:MERGING-EXCHANGE [UNPARTITIONED]
@@ -1820,8 +1820,8 @@ PLAN-ROOT SINK
partitions=1/1 files=1 size=718.94MB
runtime filters: RF002 -> l_partkey, RF003 -> l_suppkey, RF006 -> l_suppkey, RF008 -> l_orderkey, RF010 -> l_partkey
---- PARALLELPLANS
-Max Per-Host Resource Reservation: Memory=247.39MB Threads=17
-Per-Host Resource Estimates: Memory=884MB
+Max Per-Host Resource Reservation: Memory=230.39MB Threads=17
+Per-Host Resource Estimates: Memory=867MB
PLAN-ROOT SINK
|
21:MERGING-EXCHANGE [UNPARTITIONED]
@@ -1990,7 +1990,7 @@ PLAN-ROOT SINK
runtime filters: RF000 -> c_nationkey, RF002 -> c_custkey
---- DISTRIBUTEDPLAN
Max Per-Host Resource Reservation: Memory=124.45MB Threads=11
-Per-Host Resource Estimates: Memory=669MB
+Per-Host Resource Estimates: Memory=668MB
PLAN-ROOT SINK
|
15:MERGING-EXCHANGE [UNPARTITIONED]
@@ -2048,7 +2048,7 @@ PLAN-ROOT SINK
runtime filters: RF004 -> l_orderkey
---- PARALLELPLANS
Max Per-Host Resource Reservation: Memory=163.89MB Threads=13
-Per-Host Resource Estimates: Memory=608MB
+Per-Host Resource Estimates: Memory=607MB
PLAN-ROOT SINK
|
15:MERGING-EXCHANGE [UNPARTITIONED]
@@ -2424,7 +2424,7 @@ order by
l_shipmode
---- PLAN
Max Per-Host Resource Reservation: Memory=51.00MB Threads=3
-Per-Host Resource Estimates: Memory=477MB
+Per-Host Resource Estimates: Memory=475MB
PLAN-ROOT SINK
|
04:SORT
@@ -2483,7 +2483,7 @@ PLAN-ROOT SINK
runtime filters: RF000 -> l_orderkey
---- PARALLELPLANS
Max Per-Host Resource Reservation: Memory=101.88MB Threads=9
-Per-Host Resource Estimates: Memory=475MB
+Per-Host Resource Estimates: Memory=474MB
PLAN-ROOT SINK
|
09:MERGING-EXCHANGE [UNPARTITIONED]
@@ -2672,8 +2672,8 @@ where
and l_shipdate >= '1995-09-01'
and l_shipdate < '1995-10-01'
---- PLAN
-Max Per-Host Resource Reservation: Memory=34.00MB Threads=3
-Per-Host Resource Estimates: Memory=346MB
+Max Per-Host Resource Reservation: Memory=25.50MB Threads=3
+Per-Host Resource Estimates: Memory=338MB
PLAN-ROOT SINK
|
03:AGGREGATE [FINALIZE]
@@ -2720,7 +2720,7 @@ PLAN-ROOT SINK
runtime filters: RF000 -> l_partkey
---- PARALLELPLANS
Max Per-Host Resource Reservation: Memory=41.75MB Threads=7
-Per-Host Resource Estimates: Memory=299MB
+Per-Host Resource Estimates: Memory=298MB
PLAN-ROOT SINK
|
07:AGGREGATE [FINALIZE]
@@ -2821,8 +2821,8 @@ PLAN-ROOT SINK
partitions=1/1 files=1 size=1.33MB
runtime filters: RF000 -> s_suppkey
---- DISTRIBUTEDPLAN
-Max Per-Host Resource Reservation: Memory=44.69MB Threads=10
-Per-Host Resource Estimates: Memory=639MB
+Max Per-Host Resource Reservation: Memory=43.75MB Threads=10
+Per-Host Resource Estimates: Memory=638MB
PLAN-ROOT SINK
|
17:MERGING-EXCHANGE [UNPARTITIONED]
@@ -3017,7 +3017,7 @@ PLAN-ROOT SINK
partitions=1/1 files=1 size=112.71MB
runtime filters: RF000 -> ps_partkey
---- DISTRIBUTEDPLAN
-Max Per-Host Resource Reservation: Memory=54.56MB Threads=9
+Max Per-Host Resource Reservation: Memory=46.81MB Threads=9
Per-Host Resource Estimates: Memory=334MB
PLAN-ROOT SINK
|
@@ -3069,7 +3069,7 @@ PLAN-ROOT SINK
runtime filters: RF000 -> ps_partkey
---- PARALLELPLANS
Max Per-Host Resource Reservation: Memory=93.62MB Threads=11
-Per-Host Resource Estimates: Memory=393MB
+Per-Host Resource Estimates: Memory=392MB
PLAN-ROOT SINK
|
14:MERGING-EXCHANGE [UNPARTITIONED]
@@ -3319,7 +3319,7 @@ order by
limit 100
---- PLAN
Max Per-Host Resource Reservation: Memory=111.50MB Threads=5
-Per-Host Resource Estimates: Memory=898MB
+Per-Host Resource Estimates: Memory=891MB
PLAN-ROOT SINK
|
09:TOP-N [LIMIT=100]
@@ -3538,8 +3538,8 @@ where
)
)
---- PLAN
-Max Per-Host Resource Reservation: Memory=19.88MB Threads=3
-Per-Host Resource Estimates: Memory=332MB
+Max Per-Host Resource Reservation: Memory=18.94MB Threads=3
+Per-Host Resource Estimates: Memory=331MB
PLAN-ROOT SINK
|
03:AGGREGATE [FINALIZE]
@@ -3559,8 +3559,8 @@ PLAN-ROOT SINK
predicates: l_shipmode IN ('AIR', 'AIR REG'), l_shipinstruct = 'DELIVER IN PERSON'
runtime filters: RF000 -> l_partkey
---- DISTRIBUTEDPLAN
-Max Per-Host Resource Reservation: Memory=19.88MB Threads=5
-Per-Host Resource Estimates: Memory=352MB
+Max Per-Host Resource Reservation: Memory=18.94MB Threads=5
+Per-Host Resource Estimates: Memory=351MB
PLAN-ROOT SINK
|
06:AGGREGATE [FINALIZE]
@@ -3587,8 +3587,8 @@ PLAN-ROOT SINK
predicates: l_shipmode IN ('AIR', 'AIR REG'), l_shipinstruct = 'DELIVER IN PERSON'
runtime filters: RF000 -> l_partkey
---- PARALLELPLANS
-Max Per-Host Resource Reservation: Memory=39.75MB Threads=5
-Per-Host Resource Estimates: Memory=278MB
+Max Per-Host Resource Reservation: Memory=37.88MB Threads=5
+Per-Host Resource Estimates: Memory=276MB
PLAN-ROOT SINK
|
06:AGGREGATE [FINALIZE]
http://git-wip-us.apache.org/repos/asf/impala/blob/2a4835cf/testdata/workloads/functional-planner/queries/PlannerTest/tpch-kudu.test
----------------------------------------------------------------------
diff --git a/testdata/workloads/functional-planner/queries/PlannerTest/tpch-kudu.test b/testdata/workloads/functional-planner/queries/PlannerTest/tpch-kudu.test
index 373fa87..cc35a26 100644
--- a/testdata/workloads/functional-planner/queries/PlannerTest/tpch-kudu.test
+++ b/testdata/workloads/functional-planner/queries/PlannerTest/tpch-kudu.test
@@ -390,7 +390,7 @@ order by
l_year
---- PLAN
Max Per-Host Resource Reservation: Memory=76.69MB Threads=7
-Per-Host Resource Estimates: Memory=90MB
+Per-Host Resource Estimates: Memory=85MB
PLAN-ROOT SINK
|
12:SORT
@@ -656,7 +656,7 @@ order by
limit 20
---- PLAN
Max Per-Host Resource Reservation: Memory=44.44MB Threads=5
-Per-Host Resource Estimates: Memory=71MB
+Per-Host Resource Estimates: Memory=67MB
PLAN-ROOT SINK
|
08:TOP-N [LIMIT=20]
@@ -1005,7 +1005,7 @@ order by
p_type,
p_size
---- PLAN
-Max Per-Host Resource Reservation: Memory=16.75MB Threads=4
+Max Per-Host Resource Reservation: Memory=14.88MB Threads=4
Per-Host Resource Estimates: Memory=22MB
PLAN-ROOT SINK
|
@@ -1121,7 +1121,7 @@ order by
limit 100
---- PLAN
Max Per-Host Resource Reservation: Memory=81.25MB Threads=5
-Per-Host Resource Estimates: Memory=158MB
+Per-Host Resource Estimates: Memory=153MB
PLAN-ROOT SINK
|
09:TOP-N [LIMIT=100]
http://git-wip-us.apache.org/repos/asf/impala/blob/2a4835cf/testdata/workloads/functional-planner/queries/PlannerTest/tpch-nested.test
----------------------------------------------------------------------
diff --git a/testdata/workloads/functional-planner/queries/PlannerTest/tpch-nested.test b/testdata/workloads/functional-planner/queries/PlannerTest/tpch-nested.test
index 12bb1c9..7bc9da5 100644
--- a/testdata/workloads/functional-planner/queries/PlannerTest/tpch-nested.test
+++ b/testdata/workloads/functional-planner/queries/PlannerTest/tpch-nested.test
@@ -34,7 +34,7 @@ PLAN-ROOT SINK
| group by: l_returnflag, l_linestatus
|
00:SCAN HDFS [tpch_nested_parquet.customer.c_orders.o_lineitems]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates: l_shipdate <= '1998-09-02'
---- DISTRIBUTEDPLAN
Max Per-Host Resource Reservation: Memory=112.00MB Threads=4
@@ -58,7 +58,7 @@ PLAN-ROOT SINK
| group by: l_returnflag, l_linestatus
|
00:SCAN HDFS [tpch_nested_parquet.customer.c_orders.o_lineitems]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates: l_shipdate <= '1998-09-02'
====
# TPCH-Q2
@@ -132,7 +132,7 @@ PLAN-ROOT SINK
| | | 19:UNNEST [r.r_nations n]
| | |
| | 16:SCAN HDFS [tpch_nested_parquet.region r]
-| | partitions=1/1 files=1 size=3.44KB
+| | partitions=1/1 files=1 size=3.41KB
| | predicates: r_name = 'EUROPE', !empty(r.r_nations)
| |
| 12:SUBPLAN
@@ -161,7 +161,7 @@ PLAN-ROOT SINK
| | 09:UNNEST [r.r_nations n]
| |
| 06:SCAN HDFS [tpch_nested_parquet.region r]
-| partitions=1/1 files=1 size=3.44KB
+| partitions=1/1 files=1 size=3.41KB
| predicates: r_name = 'EUROPE', !empty(r.r_nations)
|
23:HASH JOIN [INNER JOIN]
@@ -227,7 +227,7 @@ PLAN-ROOT SINK
| | | 19:UNNEST [r.r_nations n]
| | |
| | 16:SCAN HDFS [tpch_nested_parquet.region r]
-| | partitions=1/1 files=1 size=3.44KB
+| | partitions=1/1 files=1 size=3.41KB
| | predicates: r_name = 'EUROPE', !empty(r.r_nations)
| |
| 12:SUBPLAN
@@ -258,7 +258,7 @@ PLAN-ROOT SINK
| | 09:UNNEST [r.r_nations n]
| |
| 06:SCAN HDFS [tpch_nested_parquet.region r]
-| partitions=1/1 files=1 size=3.44KB
+| partitions=1/1 files=1 size=3.41KB
| predicates: r_name = 'EUROPE', !empty(r.r_nations)
|
23:HASH JOIN [INNER JOIN, BROADCAST]
@@ -336,7 +336,7 @@ PLAN-ROOT SINK
| 03:UNNEST [c.c_orders o]
|
00:SCAN HDFS [tpch_nested_parquet.customer c]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates: c_mktsegment = 'BUILDING', !empty(c.c_orders)
predicates on o: !empty(o.o_lineitems), o_orderdate < '1995-03-15'
predicates on l: l_shipdate > '1995-03-15'
@@ -379,7 +379,7 @@ PLAN-ROOT SINK
| 03:UNNEST [c.c_orders o]
|
00:SCAN HDFS [tpch_nested_parquet.customer c]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates: c_mktsegment = 'BUILDING', !empty(c.c_orders)
predicates on o: !empty(o.o_lineitems), o_orderdate < '1995-03-15'
predicates on l: l_shipdate > '1995-03-15'
@@ -436,13 +436,13 @@ PLAN-ROOT SINK
| 03:UNNEST [c.c_orders o]
|
00:SCAN HDFS [tpch_nested_parquet.customer c]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates: !empty(c.c_orders)
predicates on o: o_orderdate >= '1993-07-01', o_orderdate < '1993-10-01'
predicates on o_lineitems: l_commitdate < l_receiptdate
---- DISTRIBUTEDPLAN
Max Per-Host Resource Reservation: Memory=96.00MB Threads=4
-Per-Host Resource Estimates: Memory=632MB
+Per-Host Resource Estimates: Memory=630MB
PLAN-ROOT SINK
|
13:MERGING-EXCHANGE [UNPARTITIONED]
@@ -478,7 +478,7 @@ PLAN-ROOT SINK
| 03:UNNEST [c.c_orders o]
|
00:SCAN HDFS [tpch_nested_parquet.customer c]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates: !empty(c.c_orders)
predicates on o: o_orderdate >= '1993-07-01', o_orderdate < '1993-10-01'
predicates on o_lineitems: l_commitdate < l_receiptdate
@@ -538,7 +538,7 @@ PLAN-ROOT SINK
| | 13:UNNEST [r.r_nations n]
| |
| 10:SCAN HDFS [tpch_nested_parquet.region r]
-| partitions=1/1 files=1 size=3.44KB
+| partitions=1/1 files=1 size=3.41KB
| predicates: r_name = 'ASIA', !empty(r.r_nations)
|
01:SUBPLAN
@@ -558,13 +558,13 @@ PLAN-ROOT SINK
| 03:UNNEST [c.c_orders o]
|
00:SCAN HDFS [tpch_nested_parquet.customer c]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates: !empty(c.c_orders)
predicates on o: !empty(o.o_lineitems), o_orderdate >= '1994-01-01', o_orderdate < '1995-01-01'
runtime filters: RF000 -> c_nationkey, RF004 -> c.c_nationkey
---- DISTRIBUTEDPLAN
Max Per-Host Resource Reservation: Memory=110.02MB Threads=8
-Per-Host Resource Estimates: Memory=1.29GB
+Per-Host Resource Estimates: Memory=1.26GB
PLAN-ROOT SINK
|
23:MERGING-EXCHANGE [UNPARTITIONED]
@@ -607,7 +607,7 @@ PLAN-ROOT SINK
| | 13:UNNEST [r.r_nations n]
| |
| 10:SCAN HDFS [tpch_nested_parquet.region r]
-| partitions=1/1 files=1 size=3.44KB
+| partitions=1/1 files=1 size=3.41KB
| predicates: r_name = 'ASIA', !empty(r.r_nations)
|
01:SUBPLAN
@@ -627,7 +627,7 @@ PLAN-ROOT SINK
| 03:UNNEST [c.c_orders o]
|
00:SCAN HDFS [tpch_nested_parquet.customer c]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates: !empty(c.c_orders)
predicates on o: !empty(o.o_lineitems), o_orderdate >= '1994-01-01', o_orderdate < '1995-01-01'
runtime filters: RF000 -> c_nationkey, RF004 -> c.c_nationkey
@@ -652,7 +652,7 @@ PLAN-ROOT SINK
| output: sum(l_extendedprice * l_discount)
|
00:SCAN HDFS [tpch_nested_parquet.customer.c_orders.o_lineitems]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates: l_discount <= 0.07, l_discount >= 0.05, l_quantity < 24, l_shipdate < '1995-01-01', l_shipdate >= '1994-01-01'
---- DISTRIBUTEDPLAN
Max Per-Host Resource Reservation: Memory=16.00MB Threads=3
@@ -668,7 +668,7 @@ PLAN-ROOT SINK
| output: sum(l_extendedprice * l_discount)
|
00:SCAN HDFS [tpch_nested_parquet.customer.c_orders.o_lineitems]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates: l_discount <= 0.07, l_discount >= 0.05, l_quantity < 24, l_shipdate < '1995-01-01', l_shipdate >= '1994-01-01'
====
# TPCH-Q7
@@ -727,14 +727,14 @@ PLAN-ROOT SINK
| runtime filters: RF000 <- n2.n_nationkey
|
|--11:SCAN HDFS [tpch_nested_parquet.region.r_nations n2]
-| partitions=1/1 files=1 size=3.44KB
+| partitions=1/1 files=1 size=3.41KB
|
13:HASH JOIN [INNER JOIN]
| hash predicates: s_nationkey = n1.n_nationkey
| runtime filters: RF002 <- n1.n_nationkey
|
|--10:SCAN HDFS [tpch_nested_parquet.region.r_nations n1]
-| partitions=1/1 files=1 size=3.44KB
+| partitions=1/1 files=1 size=3.41KB
|
12:HASH JOIN [INNER JOIN]
| hash predicates: l_suppkey = s_suppkey
@@ -760,7 +760,7 @@ PLAN-ROOT SINK
| 03:UNNEST [c.c_orders o]
|
00:SCAN HDFS [tpch_nested_parquet.customer c]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates: !empty(c.c_orders)
predicates on o: !empty(o.o_lineitems)
predicates on l: l_shipdate >= '1995-01-01', l_shipdate <= '1996-12-31'
@@ -794,7 +794,7 @@ PLAN-ROOT SINK
|--19:EXCHANGE [BROADCAST]
| |
| 11:SCAN HDFS [tpch_nested_parquet.region.r_nations n2]
-| partitions=1/1 files=1 size=3.44KB
+| partitions=1/1 files=1 size=3.41KB
|
13:HASH JOIN [INNER JOIN, BROADCAST]
| hash predicates: s_nationkey = n1.n_nationkey
@@ -803,7 +803,7 @@ PLAN-ROOT SINK
|--18:EXCHANGE [BROADCAST]
| |
| 10:SCAN HDFS [tpch_nested_parquet.region.r_nations n1]
-| partitions=1/1 files=1 size=3.44KB
+| partitions=1/1 files=1 size=3.41KB
|
12:HASH JOIN [INNER JOIN, BROADCAST]
| hash predicates: l_suppkey = s_suppkey
@@ -831,7 +831,7 @@ PLAN-ROOT SINK
| 03:UNNEST [c.c_orders o]
|
00:SCAN HDFS [tpch_nested_parquet.customer c]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates: !empty(c.c_orders)
predicates on o: !empty(o.o_lineitems)
predicates on l: l_shipdate >= '1995-01-01', l_shipdate <= '1996-12-31'
@@ -890,7 +890,7 @@ PLAN-ROOT SINK
| runtime filters: RF000 <- n2.n_nationkey
|
|--16:SCAN HDFS [tpch_nested_parquet.region.r_nations n2]
-| partitions=1/1 files=1 size=3.44KB
+| partitions=1/1 files=1 size=3.41KB
|
19:HASH JOIN [INNER JOIN]
| hash predicates: c_nationkey = n1.n_nationkey
@@ -905,7 +905,7 @@ PLAN-ROOT SINK
| | 14:UNNEST [r.r_nations n1]
| |
| 11:SCAN HDFS [tpch_nested_parquet.region r]
-| partitions=1/1 files=1 size=3.44KB
+| partitions=1/1 files=1 size=3.41KB
| predicates: r_name = 'AMERICA', !empty(r.r_nations)
|
18:HASH JOIN [INNER JOIN]
@@ -939,7 +939,7 @@ PLAN-ROOT SINK
| 03:UNNEST [c.c_orders o]
|
00:SCAN HDFS [tpch_nested_parquet.customer c]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates: !empty(c.c_orders)
predicates on o: !empty(o.o_lineitems), o_orderdate >= '1995-01-01', o_orderdate <= '1996-12-31'
runtime filters: RF002 -> c_nationkey
@@ -971,7 +971,7 @@ PLAN-ROOT SINK
|--26:EXCHANGE [BROADCAST]
| |
| 16:SCAN HDFS [tpch_nested_parquet.region.r_nations n2]
-| partitions=1/1 files=1 size=3.44KB
+| partitions=1/1 files=1 size=3.41KB
|
19:HASH JOIN [INNER JOIN, BROADCAST]
| hash predicates: c_nationkey = n1.n_nationkey
@@ -988,7 +988,7 @@ PLAN-ROOT SINK
| | 14:UNNEST [r.r_nations n1]
| |
| 11:SCAN HDFS [tpch_nested_parquet.region r]
-| partitions=1/1 files=1 size=3.44KB
+| partitions=1/1 files=1 size=3.41KB
| predicates: r_name = 'AMERICA', !empty(r.r_nations)
|
18:HASH JOIN [INNER JOIN, BROADCAST]
@@ -1026,7 +1026,7 @@ PLAN-ROOT SINK
| 03:UNNEST [c.c_orders o]
|
00:SCAN HDFS [tpch_nested_parquet.customer c]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates: !empty(c.c_orders)
predicates on o: !empty(o.o_lineitems), o_orderdate >= '1995-01-01', o_orderdate <= '1996-12-31'
runtime filters: RF002 -> c_nationkey
@@ -1063,8 +1063,8 @@ order by
nation,
o_year desc
---- PLAN
-Max Per-Host Resource Reservation: Memory=72.31MB Threads=5
-Per-Host Resource Estimates: Memory=830MB
+Max Per-Host Resource Reservation: Memory=68.56MB Threads=5
+Per-Host Resource Estimates: Memory=827MB
PLAN-ROOT SINK
|
16:SORT
@@ -1079,7 +1079,7 @@ PLAN-ROOT SINK
| runtime filters: RF000 <- n_nationkey
|
|--11:SCAN HDFS [tpch_nested_parquet.region.r_nations n]
-| partitions=1/1 files=1 size=3.44KB
+| partitions=1/1 files=1 size=3.41KB
|
13:HASH JOIN [INNER JOIN]
| hash predicates: l_partkey = p_partkey
@@ -1113,11 +1113,11 @@ PLAN-ROOT SINK
| 03:UNNEST [o.o_lineitems l]
|
00:SCAN HDFS [tpch_nested_parquet.customer.c_orders o]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates: !empty(o.o_lineitems)
---- DISTRIBUTEDPLAN
-Max Per-Host Resource Reservation: Memory=143.33MB Threads=10
-Per-Host Resource Estimates: Memory=1.12GB
+Max Per-Host Resource Reservation: Memory=139.58MB Threads=10
+Per-Host Resource Estimates: Memory=1.11GB
PLAN-ROOT SINK
|
22:MERGING-EXCHANGE [UNPARTITIONED]
@@ -1143,7 +1143,7 @@ PLAN-ROOT SINK
|--19:EXCHANGE [BROADCAST]
| |
| 11:SCAN HDFS [tpch_nested_parquet.region.r_nations n]
-| partitions=1/1 files=1 size=3.44KB
+| partitions=1/1 files=1 size=3.41KB
|
13:HASH JOIN [INNER JOIN, BROADCAST]
| hash predicates: l_partkey = p_partkey
@@ -1181,7 +1181,7 @@ PLAN-ROOT SINK
| 03:UNNEST [o.o_lineitems l]
|
00:SCAN HDFS [tpch_nested_parquet.customer.c_orders o]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates: !empty(o.o_lineitems)
====
# TPCH-Q10
@@ -1234,7 +1234,7 @@ PLAN-ROOT SINK
| runtime filters: RF000 <- n_nationkey
|
|--09:SCAN HDFS [tpch_nested_parquet.region.r_nations n]
-| partitions=1/1 files=1 size=3.44KB
+| partitions=1/1 files=1 size=3.41KB
|
01:SUBPLAN
|
@@ -1253,7 +1253,7 @@ PLAN-ROOT SINK
| 03:UNNEST [c.c_orders o]
|
00:SCAN HDFS [tpch_nested_parquet.customer c]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates: !empty(c.c_orders)
predicates on o: !empty(o.o_lineitems), o_orderdate >= '1993-10-01', o_orderdate < '1994-01-01'
predicates on l: l_returnflag = 'R'
@@ -1287,7 +1287,7 @@ PLAN-ROOT SINK
|--13:EXCHANGE [BROADCAST]
| |
| 09:SCAN HDFS [tpch_nested_parquet.region.r_nations n]
-| partitions=1/1 files=1 size=3.44KB
+| partitions=1/1 files=1 size=3.41KB
|
01:SUBPLAN
|
@@ -1306,7 +1306,7 @@ PLAN-ROOT SINK
| 03:UNNEST [c.c_orders o]
|
00:SCAN HDFS [tpch_nested_parquet.customer c]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates: !empty(c.c_orders)
predicates on o: !empty(o.o_lineitems), o_orderdate >= '1993-10-01', o_orderdate < '1994-01-01'
predicates on l: l_returnflag = 'R'
@@ -1364,7 +1364,7 @@ PLAN-ROOT SINK
| | runtime filters: RF002 <- n_nationkey
| |
| |--13:SCAN HDFS [tpch_nested_parquet.region.r_nations n]
-| | partitions=1/1 files=1 size=3.44KB
+| | partitions=1/1 files=1 size=3.41KB
| | predicates: n_name = 'GERMANY'
| |
| 09:SUBPLAN
@@ -1389,7 +1389,7 @@ PLAN-ROOT SINK
| runtime filters: RF000 <- n_nationkey
|
|--05:SCAN HDFS [tpch_nested_parquet.region.r_nations n]
-| partitions=1/1 files=1 size=3.44KB
+| partitions=1/1 files=1 size=3.41KB
| predicates: n_name = 'GERMANY'
|
01:SUBPLAN
@@ -1435,7 +1435,7 @@ PLAN-ROOT SINK
| |--21:EXCHANGE [BROADCAST]
| | |
| | 13:SCAN HDFS [tpch_nested_parquet.region.r_nations n]
-| | partitions=1/1 files=1 size=3.44KB
+| | partitions=1/1 files=1 size=3.41KB
| | predicates: n_name = 'GERMANY'
| |
| 09:SUBPLAN
@@ -1468,7 +1468,7 @@ PLAN-ROOT SINK
|--18:EXCHANGE [BROADCAST]
| |
| 05:SCAN HDFS [tpch_nested_parquet.region.r_nations n]
-| partitions=1/1 files=1 size=3.44KB
+| partitions=1/1 files=1 size=3.41KB
| predicates: n_name = 'GERMANY'
|
01:SUBPLAN
@@ -1534,7 +1534,7 @@ PLAN-ROOT SINK
| 03:UNNEST [o.o_lineitems l]
|
00:SCAN HDFS [tpch_nested_parquet.customer.c_orders o]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates: !empty(o.o_lineitems)
predicates on l: l_shipmode IN ('MAIL', 'SHIP'), l_commitdate < l_receiptdate, l_shipdate < l_commitdate, l_receiptdate >= '1994-01-01', l_receiptdate < '1995-01-01'
---- DISTRIBUTEDPLAN
@@ -1567,7 +1567,7 @@ PLAN-ROOT SINK
| 03:UNNEST [o.o_lineitems l]
|
00:SCAN HDFS [tpch_nested_parquet.customer.c_orders o]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates: !empty(o.o_lineitems)
predicates on l: l_shipmode IN ('MAIL', 'SHIP'), l_commitdate < l_receiptdate, l_shipdate < l_commitdate, l_receiptdate >= '1994-01-01', l_receiptdate < '1995-01-01'
====
@@ -1617,7 +1617,7 @@ PLAN-ROOT SINK
| 03:UNNEST [c.c_orders]
|
00:SCAN HDFS [tpch_nested_parquet.customer c]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates on c_orders: (NOT o_comment LIKE '%special%requests%')
---- DISTRIBUTEDPLAN
Max Per-Host Resource Reservation: Memory=94.94MB Threads=5
@@ -1659,7 +1659,7 @@ PLAN-ROOT SINK
| 03:UNNEST [c.c_orders]
|
00:SCAN HDFS [tpch_nested_parquet.customer c]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates on c_orders: (NOT o_comment LIKE '%special%requests%')
====
# TPCH-Q14
@@ -1678,8 +1678,8 @@ where
and l_shipdate >= '1995-09-01'
and l_shipdate < '1995-10-01'
---- PLAN
-Max Per-Host Resource Reservation: Memory=36.00MB Threads=3
-Per-Host Resource Estimates: Memory=402MB
+Max Per-Host Resource Reservation: Memory=27.50MB Threads=3
+Per-Host Resource Estimates: Memory=394MB
PLAN-ROOT SINK
|
03:AGGREGATE [FINALIZE]
@@ -1693,12 +1693,12 @@ PLAN-ROOT SINK
| partitions=1/1 files=1 size=6.23MB
|
00:SCAN HDFS [tpch_nested_parquet.customer.c_orders.o_lineitems l]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates: l_shipdate < '1995-10-01', l_shipdate >= '1995-09-01'
runtime filters: RF000 -> l_partkey
---- DISTRIBUTEDPLAN
-Max Per-Host Resource Reservation: Memory=36.00MB Threads=5
-Per-Host Resource Estimates: Memory=422MB
+Max Per-Host Resource Reservation: Memory=27.50MB Threads=5
+Per-Host Resource Estimates: Memory=414MB
PLAN-ROOT SINK
|
06:AGGREGATE [FINALIZE]
@@ -1719,7 +1719,7 @@ PLAN-ROOT SINK
| partitions=1/1 files=1 size=6.23MB
|
00:SCAN HDFS [tpch_nested_parquet.customer.c_orders.o_lineitems l]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates: l_shipdate < '1995-10-01', l_shipdate >= '1995-09-01'
runtime filters: RF000 -> l_partkey
====
@@ -1756,7 +1756,7 @@ where
order by
s_suppkey
---- PLAN
-Max Per-Host Resource Reservation: Memory=104.88MB Threads=4
+Max Per-Host Resource Reservation: Memory=103.94MB Threads=4
Per-Host Resource Estimates: Memory=1.16GB
PLAN-ROOT SINK
|
@@ -1774,7 +1774,7 @@ PLAN-ROOT SINK
| | group by: l_suppkey
| |
| 03:SCAN HDFS [tpch_nested_parquet.customer.c_orders.o_lineitems l]
-| partitions=1/1 files=4 size=288.99MB
+| partitions=1/1 files=4 size=288.96MB
| predicates: l_shipdate < '1996-04-01', l_shipdate >= '1996-01-01'
|
06:HASH JOIN [INNER JOIN]
@@ -1789,7 +1789,7 @@ PLAN-ROOT SINK
| group by: l_suppkey
|
01:SCAN HDFS [tpch_nested_parquet.customer.c_orders.o_lineitems l]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates: l_shipdate < '1996-04-01', l_shipdate >= '1996-01-01'
runtime filters: RF000 -> l.l_suppkey
---- DISTRIBUTEDPLAN
@@ -1827,7 +1827,7 @@ PLAN-ROOT SINK
| | group by: l_suppkey
| |
| 03:SCAN HDFS [tpch_nested_parquet.customer.c_orders.o_lineitems l]
-| partitions=1/1 files=4 size=288.99MB
+| partitions=1/1 files=4 size=288.96MB
| predicates: l_shipdate < '1996-04-01', l_shipdate >= '1996-01-01'
|
06:HASH JOIN [INNER JOIN, PARTITIONED]
@@ -1850,7 +1850,7 @@ PLAN-ROOT SINK
| group by: l_suppkey
|
01:SCAN HDFS [tpch_nested_parquet.customer.c_orders.o_lineitems l]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates: l_shipdate < '1996-04-01', l_shipdate >= '1996-01-01'
runtime filters: RF000 -> l.l_suppkey
====
@@ -2000,7 +2000,7 @@ PLAN-ROOT SINK
| | group by: l_partkey
| |
| 02:SCAN HDFS [tpch_nested_parquet.customer.c_orders.o_lineitems l]
-| partitions=1/1 files=4 size=288.99MB
+| partitions=1/1 files=4 size=288.96MB
|
04:HASH JOIN [INNER JOIN]
| hash predicates: l_partkey = p_partkey
@@ -2012,7 +2012,7 @@ PLAN-ROOT SINK
| runtime filters: RF000 -> p_partkey
|
00:SCAN HDFS [tpch_nested_parquet.customer.c_orders.o_lineitems l]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
runtime filters: RF000 -> l.l_partkey, RF002 -> l_partkey
---- DISTRIBUTEDPLAN
Max Per-Host Resource Reservation: Memory=154.94MB Threads=8
@@ -2043,7 +2043,7 @@ PLAN-ROOT SINK
| | group by: l_partkey
| |
| 02:SCAN HDFS [tpch_nested_parquet.customer.c_orders.o_lineitems l]
-| partitions=1/1 files=4 size=288.99MB
+| partitions=1/1 files=4 size=288.96MB
|
10:EXCHANGE [HASH(p_partkey)]
|
@@ -2059,7 +2059,7 @@ PLAN-ROOT SINK
| runtime filters: RF000 -> p_partkey
|
00:SCAN HDFS [tpch_nested_parquet.customer.c_orders.o_lineitems l]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
runtime filters: RF000 -> l.l_partkey, RF002 -> l_partkey
====
# TPCH-Q18
@@ -2110,7 +2110,7 @@ PLAN-ROOT SINK
| 03:UNNEST [c.c_orders o]
|
00:SCAN HDFS [tpch_nested_parquet.customer c]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates: !empty(c.c_orders)
---- DISTRIBUTEDPLAN
Max Per-Host Resource Reservation: Memory=24.00MB Threads=3
@@ -2145,7 +2145,7 @@ PLAN-ROOT SINK
| 03:UNNEST [c.c_orders o]
|
00:SCAN HDFS [tpch_nested_parquet.customer c]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates: !empty(c.c_orders)
====
# TPCH-Q19
@@ -2186,8 +2186,8 @@ where
)
)
---- PLAN
-Max Per-Host Resource Reservation: Memory=29.88MB Threads=3
-Per-Host Resource Estimates: Memory=596MB
+Max Per-Host Resource Reservation: Memory=28.94MB Threads=3
+Per-Host Resource Estimates: Memory=595MB
PLAN-ROOT SINK
|
03:AGGREGATE [FINALIZE]
@@ -2203,12 +2203,12 @@ PLAN-ROOT SINK
| predicates: p_size >= 1
|
00:SCAN HDFS [tpch_nested_parquet.customer.c_orders.o_lineitems l]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates: l_shipmode IN ('AIR', 'AIR REG'), l_shipinstruct = 'DELIVER IN PERSON'
runtime filters: RF000 -> l_partkey
---- DISTRIBUTEDPLAN
-Max Per-Host Resource Reservation: Memory=29.88MB Threads=5
-Per-Host Resource Estimates: Memory=616MB
+Max Per-Host Resource Reservation: Memory=28.94MB Threads=5
+Per-Host Resource Estimates: Memory=615MB
PLAN-ROOT SINK
|
06:AGGREGATE [FINALIZE]
@@ -2231,7 +2231,7 @@ PLAN-ROOT SINK
| predicates: p_size >= 1
|
00:SCAN HDFS [tpch_nested_parquet.customer.c_orders.o_lineitems l]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates: l_shipmode IN ('AIR', 'AIR REG'), l_shipinstruct = 'DELIVER IN PERSON'
runtime filters: RF000 -> l_partkey
====
@@ -2297,7 +2297,7 @@ PLAN-ROOT SINK
| | runtime filters: RF006 <- n_nationkey
| |
| |--05:SCAN HDFS [tpch_nested_parquet.region.r_nations n]
-| | partitions=1/1 files=1 size=3.44KB
+| | partitions=1/1 files=1 size=3.41KB
| | predicates: n_name = 'CANADA'
| |
| 01:SUBPLAN
@@ -2318,7 +2318,7 @@ PLAN-ROOT SINK
| group by: l_partkey, l_suppkey
|
07:SCAN HDFS [tpch_nested_parquet.customer.c_orders.o_lineitems l]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates: l_shipdate < '1995-01-01', l_shipdate >= '1994-01-01'
runtime filters: RF000 -> l.l_partkey, RF001 -> l.l_suppkey
---- DISTRIBUTEDPLAN
@@ -2363,7 +2363,7 @@ PLAN-ROOT SINK
| |--16:EXCHANGE [BROADCAST]
| | |
| | 05:SCAN HDFS [tpch_nested_parquet.region.r_nations n]
-| | partitions=1/1 files=1 size=3.44KB
+| | partitions=1/1 files=1 size=3.41KB
| | predicates: n_name = 'CANADA'
| |
| 01:SUBPLAN
@@ -2390,7 +2390,7 @@ PLAN-ROOT SINK
| group by: l_partkey, l_suppkey
|
07:SCAN HDFS [tpch_nested_parquet.customer.c_orders.o_lineitems l]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates: l_shipdate < '1995-01-01', l_shipdate >= '1994-01-01'
runtime filters: RF000 -> l.l_partkey, RF001 -> l.l_suppkey
====
@@ -2465,7 +2465,7 @@ PLAN-ROOT SINK
| runtime filters: RF000 <- n_nationkey
|
|--10:SCAN HDFS [tpch_nested_parquet.region.r_nations n]
-| partitions=1/1 files=1 size=3.44KB
+| partitions=1/1 files=1 size=3.41KB
| predicates: n_name = 'SAUDI ARABIA'
|
11:HASH JOIN [INNER JOIN]
@@ -2492,7 +2492,7 @@ PLAN-ROOT SINK
| 04:UNNEST [c.c_orders o]
|
01:SCAN HDFS [tpch_nested_parquet.customer c]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates: !empty(c.c_orders)
predicates on o: !empty(o.o_lineitems), o_orderstatus = 'F'
predicates on l1: l1.l_receiptdate > l1.l_commitdate
@@ -2540,7 +2540,7 @@ PLAN-ROOT SINK
|--22:EXCHANGE [BROADCAST]
| |
| 10:SCAN HDFS [tpch_nested_parquet.region.r_nations n]
-| partitions=1/1 files=1 size=3.44KB
+| partitions=1/1 files=1 size=3.41KB
| predicates: n_name = 'SAUDI ARABIA'
|
11:HASH JOIN [INNER JOIN, BROADCAST]
@@ -2569,7 +2569,7 @@ PLAN-ROOT SINK
| 04:UNNEST [c.c_orders o]
|
01:SCAN HDFS [tpch_nested_parquet.customer c]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates: !empty(c.c_orders)
predicates on o: !empty(o.o_lineitems), o_orderstatus = 'F'
predicates on l1: l1.l_receiptdate > l1.l_commitdate
@@ -2640,7 +2640,7 @@ PLAN-ROOT SINK
| predicates: c_acctbal > 0, substr(c_phone, 1, 2) IN ('13', '31', '23', '29', '30', '18', '17')
|
00:SCAN HDFS [tpch_nested_parquet.customer c]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates: substr(c_phone, 1, 2) IN ('13', '31', '23', '29', '30', '18', '17')
---- DISTRIBUTEDPLAN
Max Per-Host Resource Reservation: Memory=25.94MB Threads=8
@@ -2689,6 +2689,6 @@ PLAN-ROOT SINK
| predicates: c_acctbal > 0, substr(c_phone, 1, 2) IN ('13', '31', '23', '29', '30', '18', '17')
|
00:SCAN HDFS [tpch_nested_parquet.customer c]
- partitions=1/1 files=4 size=288.99MB
+ partitions=1/1 files=4 size=288.96MB
predicates: substr(c_phone, 1, 2) IN ('13', '31', '23', '29', '30', '18', '17')
====
http://git-wip-us.apache.org/repos/asf/impala/blob/2a4835cf/testdata/workloads/functional-query/queries/QueryTest/explain-level2.test
----------------------------------------------------------------------
diff --git a/testdata/workloads/functional-query/queries/QueryTest/explain-level2.test b/testdata/workloads/functional-query/queries/QueryTest/explain-level2.test
index 4bbb72b..7d65337 100644
--- a/testdata/workloads/functional-query/queries/QueryTest/explain-level2.test
+++ b/testdata/workloads/functional-query/queries/QueryTest/explain-level2.test
@@ -17,7 +17,7 @@ row_regex:.*| mem-estimate=[0-9.]*[A-Z]*B mem-reservation=[0-9.]*[A-Z]*B thread
'|'
'04:EXCHANGE [UNPARTITIONED]'
row_regex:.*| mem-estimate=[0-9.]*[A-Z]*B mem-reservation=[0-9.]*[A-Z]*B thread-reservation=0
-'| tuple-ids=0,1 row-size=454B cardinality=5757710'
+'| tuple-ids=0,1 row-size=402B cardinality=5757710'
'| in pipelines: 00(GETNEXT)'
'|'
'F00:PLAN FRAGMENT [RANDOM] hosts=3 instances=3'
@@ -27,12 +27,12 @@ row_regex:.*Per-Host Resources: mem-estimate=[0-9.]*[A-Z]*B mem-reservation=[0-9
'| fk/pk conjuncts: l_orderkey = o_orderkey'
'| runtime filters: RF000[bloom] <- o_orderkey'
row_regex:.*| mem-estimate=[0-9.]*[A-Z]*B mem-reservation=[0-9.]*[A-Z]*B spill-buffer=[0-9.]*MB thread-reservation=0.*
-'| tuple-ids=0,1 row-size=454B cardinality=5757710'
+'| tuple-ids=0,1 row-size=402B cardinality=5757710'
'| in pipelines: 00(GETNEXT), 01(OPEN)'
'|'
'|--03:EXCHANGE [BROADCAST]'
row_regex:.*| | mem-estimate=[0-9.]*[A-Z]*B mem-reservation=[0-9.]*[A-Z]*B thread-reservation=0
-'| | tuple-ids=1 row-size=191B cardinality=1500000'
+'| | tuple-ids=1 row-size=171B cardinality=1500000'
'| | in pipelines: 01(GETNEXT)'
'| |'
'| F01:PLAN FRAGMENT [RANDOM] hosts=2 instances=2'
@@ -44,7 +44,7 @@ row_regex:.*table: rows=1500000 size=.*
'| columns: all'
row_regex:.*| extrapolated-rows=disabled max-scan-range-rows=[0-9]*.*
row_regex:.*| mem-estimate=[0-9.]*[A-Z]*B mem-reservation=[0-9.]*[A-Z]*B thread-reservation=1.*
-'| tuple-ids=1 row-size=191B cardinality=1500000'
+'| tuple-ids=1 row-size=171B cardinality=1500000'
'| in pipelines: 01(GETNEXT)'
'|'
'00:SCAN HDFS [tpch.lineitem, RANDOM]'
@@ -55,7 +55,7 @@ row_regex:.*table: rows=6001215 size=.*
' columns: all'
row_regex:.* extrapolated-rows=disabled max-scan-range-rows=[0-9]*.*
row_regex:.* mem-estimate=[0-9.]*[A-Z]*B mem-reservation=[0-9.]*[A-Z]*B thread-reservation=1.*
-' tuple-ids=0 row-size=263B cardinality=6001215'
+' tuple-ids=0 row-size=231B cardinality=6001215'
' in pipelines: 00(GETNEXT)'
====
---- QUERY
http://git-wip-us.apache.org/repos/asf/impala/blob/2a4835cf/testdata/workloads/functional-query/queries/QueryTest/explain-level3.test
----------------------------------------------------------------------
diff --git a/testdata/workloads/functional-query/queries/QueryTest/explain-level3.test b/testdata/workloads/functional-query/queries/QueryTest/explain-level3.test
index 730b896..23e97f0 100644
--- a/testdata/workloads/functional-query/queries/QueryTest/explain-level3.test
+++ b/testdata/workloads/functional-query/queries/QueryTest/explain-level3.test
@@ -17,7 +17,7 @@ row_regex:.* | mem-estimate=[0-9.]*[A-Z]*B mem-reservation=[0-9.]*[A-Z]*B thre
' |'
' 04:EXCHANGE [UNPARTITIONED]'
row_regex:.* mem-estimate=[0-9.]*[A-Z]*B mem-reservation=[0-9.]*[A-Z]*B thread-reservation=0
-' tuple-ids=0,1 row-size=454B cardinality=5757710'
+' tuple-ids=0,1 row-size=402B cardinality=5757710'
' in pipelines: 00(GETNEXT)'
''
'F00:PLAN FRAGMENT [RANDOM] hosts=3 instances=3'
@@ -29,12 +29,12 @@ row_regex:.* | mem-estimate=[0-9.]*[A-Z]*B mem-reservation=[0-9.]*[A-Z]*B thre
' | fk/pk conjuncts: l_orderkey = o_orderkey'
' | runtime filters: RF000[bloom] <- o_orderkey'
row_regex:.* | mem-estimate=[0-9.]*[A-Z]*B mem-reservation=[0-9.]*[A-Z]*B spill-buffer=[0-9.]*MB thread-reservation=.*
-' | tuple-ids=0,1 row-size=454B cardinality=5757710'
+' | tuple-ids=0,1 row-size=402B cardinality=5757710'
' | in pipelines: 00(GETNEXT), 01(OPEN)'
' |'
' |--03:EXCHANGE [BROADCAST]'
row_regex:.* | mem-estimate=[0-9.]*[A-Z]*B mem-reservation=[0-9.]*[A-Z]*B thread-reservation=0
-' | tuple-ids=1 row-size=191B cardinality=1500000'
+' | tuple-ids=1 row-size=171B cardinality=1500000'
' | in pipelines: 01(GETNEXT)'
' |'
' 00:SCAN HDFS [tpch.lineitem, RANDOM]'
@@ -45,7 +45,7 @@ row_regex:.*table: rows=6001215 size=.*
' columns: all'
row_regex:.*| extrapolated-rows=disabled max-scan-range-rows=[0-9]*.*
row_regex:.* mem-estimate=[0-9.]*[A-Z]*B mem-reservation=[0-9.]*[A-Z]*B thread-reservation=1.*
-' tuple-ids=0 row-size=263B cardinality=6001215'
+' tuple-ids=0 row-size=231B cardinality=6001215'
' in pipelines: 00(GETNEXT)'
''
'F01:PLAN FRAGMENT [RANDOM] hosts=2 instances=2'
@@ -59,7 +59,7 @@ row_regex:.*table: rows=1500000 size=.*
' columns: all'
row_regex:.* extrapolated-rows=disabled max-scan-range-rows=[0-9]*.*
row_regex:.* mem-estimate=[0-9.]*[A-Z]*B mem-reservation=[0-9.]*[A-Z]*B thread-reservation=.*
-' tuple-ids=1 row-size=191B cardinality=1500000'
+' tuple-ids=1 row-size=171B cardinality=1500000'
' in pipelines: 01(GETNEXT)'
====
---- QUERY
http://git-wip-us.apache.org/repos/asf/impala/blob/2a4835cf/testdata/workloads/functional-query/queries/QueryTest/spilling-no-debug-action.test
----------------------------------------------------------------------
diff --git a/testdata/workloads/functional-query/queries/QueryTest/spilling-no-debug-action.test b/testdata/workloads/functional-query/queries/QueryTest/spilling-no-debug-action.test
index c82ea17..195500c 100644
--- a/testdata/workloads/functional-query/queries/QueryTest/spilling-no-debug-action.test
+++ b/testdata/workloads/functional-query/queries/QueryTest/spilling-no-debug-action.test
@@ -67,7 +67,7 @@ row_regex: .*NumHashTableBuildsSkipped: .* \([1-9][0-9]*\)
---- QUERY
# Aggregation query that will OOM and fail to spill because of IMPALA-3304 without
# any help from DEBUG_ACTION.
-set mem_limit=100m;
+set mem_limit=80m;
select l_orderkey, group_concat(l_comment) comments
from lineitem
group by l_orderkey