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
