http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/64fd0115/testdata/workloads/functional-planner/queries/PlannerTest/sort-expr-materialization.test ---------------------------------------------------------------------- diff --git a/testdata/workloads/functional-planner/queries/PlannerTest/sort-expr-materialization.test b/testdata/workloads/functional-planner/queries/PlannerTest/sort-expr-materialization.test index 5845af2..3e5fb05 100644 --- a/testdata/workloads/functional-planner/queries/PlannerTest/sort-expr-materialization.test +++ b/testdata/workloads/functional-planner/queries/PlannerTest/sort-expr-materialization.test @@ -2,6 +2,7 @@ select * from functional.alltypes order by random() ---- PLAN F00:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=144.00MB mem-reservation=48.00MB PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -23,6 +24,7 @@ PLAN-ROOT SINK select * from functional.alltypes order by abs(id) + abs(id) ---- PLAN F00:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=144.00MB mem-reservation=48.00MB PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -44,6 +46,7 @@ PLAN-ROOT SINK select * from functional.alltypes order by tinyint_col + 1 ---- PLAN F00:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=144.00MB mem-reservation=48.00MB PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -65,6 +68,7 @@ select * from functional.alltypes order by dayofweek(timestamp_col), true, id + 1, string_col = date_string_col, id = tinyint_col ---- PLAN F00:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=144.00MB mem-reservation=48.00MB PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -87,6 +91,7 @@ select last_value(id) over (order by to_date(timestamp_col), bool_col is null) from functional.alltypes ---- PLAN F00:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=144.00MB mem-reservation=64.00MB PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -116,6 +121,7 @@ select id from functional.alltypes order by string_col like 'a.*b', id * bigint_ regexp_replace(string_col, 'a.*b', 'c') limit 10 ---- PLAN F00:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=128.00MB mem-reservation=0B PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -137,6 +143,7 @@ PLAN-ROOT SINK select * from functional.alltypes order by TestFn(double_col) ---- PLAN F00:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=144.00MB mem-reservation=48.00MB PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -158,6 +165,7 @@ PLAN-ROOT SINK select concat(date_string_col, string_col) c from functional.alltypes order by c ---- PLAN F00:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=144.00MB mem-reservation=48.00MB PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B |
http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/64fd0115/testdata/workloads/functional-planner/queries/PlannerTest/spillable-buffer-sizing.test ---------------------------------------------------------------------- diff --git a/testdata/workloads/functional-planner/queries/PlannerTest/spillable-buffer-sizing.test b/testdata/workloads/functional-planner/queries/PlannerTest/spillable-buffer-sizing.test index fb30e09..58fe1bf 100644 --- a/testdata/workloads/functional-planner/queries/PlannerTest/spillable-buffer-sizing.test +++ b/testdata/workloads/functional-planner/queries/PlannerTest/spillable-buffer-sizing.test @@ -4,9 +4,10 @@ from tpch_parquet.customer inner join tpch_parquet.nation on c_nationkey = n_nationkey ---- DISTRIBUTEDPLAN Per-Host Resource Reservation: Memory=1.06MB -Per-Host Resource Estimates: Memory=24.00MB +Per-Host Resource Estimates: Memory=40.00MB F02:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=0B mem-reservation=0B PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -15,6 +16,7 @@ PLAN-ROOT SINK | tuple-ids=0,1 row-size=355B cardinality=150000 | F00:PLAN FRAGMENT [RANDOM] hosts=1 instances=1 +Per-Host Resources: mem-estimate=24.00MB mem-reservation=1.06MB 02:HASH JOIN [INNER JOIN, BROADCAST] | hash predicates: c_nationkey = n_nationkey | fk/pk conjuncts: c_nationkey = n_nationkey @@ -27,6 +29,7 @@ F00:PLAN FRAGMENT [RANDOM] hosts=1 instances=1 | | tuple-ids=1 row-size=117B cardinality=25 | | | F01:PLAN FRAGMENT [RANDOM] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=16.00MB mem-reservation=0B | 01:SCAN HDFS [tpch_parquet.nation, RANDOM] | partitions=1/1 files=1 size=2.94KB | stats-rows=25 extrapolated-rows=disabled @@ -48,6 +51,7 @@ Per-Host Resource Reservation: Memory=2.12MB Per-Host Resource Estimates: Memory=80.01MB F02:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=0B mem-reservation=0B PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -56,6 +60,7 @@ PLAN-ROOT SINK | tuple-ids=0,1 row-size=355B cardinality=150000 | F00:PLAN FRAGMENT [RANDOM] hosts=1 instances=2 +Per-Host Resources: mem-estimate=48.01MB mem-reservation=2.12MB 02:HASH JOIN [INNER JOIN, BROADCAST] | hash-table-id=00 | hash predicates: c_nationkey = n_nationkey @@ -65,6 +70,7 @@ F00:PLAN FRAGMENT [RANDOM] hosts=1 instances=2 | tuple-ids=0,1 row-size=355B cardinality=150000 | |--F03:PLAN FRAGMENT [RANDOM] hosts=1 instances=2 +| | Per-Host Resources: included in parent fragment | JOIN BUILD | | join-table-id=00 plan-id=01 cohort-id=01 | | build expressions: n_nationkey @@ -75,6 +81,7 @@ F00:PLAN FRAGMENT [RANDOM] hosts=1 instances=2 | | tuple-ids=1 row-size=117B cardinality=25 | | | F01:PLAN FRAGMENT [RANDOM] hosts=1 instances=2 +| Per-Host Resources: mem-estimate=32.00MB mem-reservation=0B | 01:SCAN HDFS [tpch_parquet.nation, RANDOM] | partitions=1/1 files=1 size=2.94KB | stats-rows=25 extrapolated-rows=disabled @@ -98,9 +105,10 @@ from tpch_parquet.lineitem left join tpch_parquet.orders on l_orderkey = o_orderkey ---- DISTRIBUTEDPLAN Per-Host Resource Reservation: Memory=136.00MB -Per-Host Resource Estimates: Memory=380.41MB +Per-Host Resource Estimates: Memory=420.41MB F02:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=0B mem-reservation=0B PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -109,6 +117,7 @@ PLAN-ROOT SINK | tuple-ids=0,1N row-size=454B cardinality=6001215 | F00:PLAN FRAGMENT [RANDOM] hosts=3 instances=3 +Per-Host Resources: mem-estimate=380.41MB mem-reservation=136.00MB 02:HASH JOIN [LEFT OUTER JOIN, BROADCAST] | hash predicates: l_orderkey = o_orderkey | fk/pk conjuncts: l_orderkey = o_orderkey @@ -120,6 +129,7 @@ F00:PLAN FRAGMENT [RANDOM] hosts=3 instances=3 | | tuple-ids=1 row-size=191B cardinality=1500000 | | | F01:PLAN FRAGMENT [RANDOM] hosts=2 instances=2 +| Per-Host Resources: mem-estimate=40.00MB mem-reservation=0B | 01:SCAN HDFS [tpch_parquet.orders, RANDOM] | partitions=1/1 files=2 size=54.20MB | stats-rows=1500000 extrapolated-rows=disabled @@ -140,6 +150,7 @@ Per-Host Resource Reservation: Memory=272.00MB Per-Host Resource Estimates: Memory=840.83MB F02:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=0B mem-reservation=0B PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -148,6 +159,7 @@ PLAN-ROOT SINK | tuple-ids=0,1N row-size=454B cardinality=6001215 | F00:PLAN FRAGMENT [RANDOM] hosts=3 instances=6 +Per-Host Resources: mem-estimate=760.83MB mem-reservation=272.00MB 02:HASH JOIN [LEFT OUTER JOIN, BROADCAST] | hash-table-id=00 | hash predicates: l_orderkey = o_orderkey @@ -156,6 +168,7 @@ F00:PLAN FRAGMENT [RANDOM] hosts=3 instances=6 | tuple-ids=0,1N row-size=454B cardinality=6001215 | |--F03:PLAN FRAGMENT [RANDOM] hosts=2 instances=4 +| | Per-Host Resources: included in parent fragment | JOIN BUILD | | join-table-id=00 plan-id=01 cohort-id=01 | | build expressions: o_orderkey @@ -166,6 +179,7 @@ F00:PLAN FRAGMENT [RANDOM] hosts=3 instances=6 | | tuple-ids=1 row-size=191B cardinality=1500000 | | | F01:PLAN FRAGMENT [RANDOM] hosts=2 instances=4 +| Per-Host Resources: mem-estimate=80.00MB mem-reservation=0B | 01:SCAN HDFS [tpch_parquet.orders, RANDOM] | partitions=1/1 files=2 size=54.20MB | stats-rows=1500000 extrapolated-rows=disabled @@ -188,9 +202,10 @@ from tpch_parquet.orders join /*+shuffle*/ tpch_parquet.customer on o_custkey = c_custkey ---- DISTRIBUTEDPLAN Per-Host Resource Reservation: Memory=34.00MB -Per-Host Resource Estimates: Memory=58.69MB +Per-Host Resource Estimates: Memory=82.69MB F03:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=0B mem-reservation=0B PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -199,6 +214,7 @@ PLAN-ROOT SINK | tuple-ids=0,1 row-size=428B cardinality=1500000 | F02:PLAN FRAGMENT [HASH(o_custkey)] hosts=2 instances=2 +Per-Host Resources: mem-estimate=18.69MB mem-reservation=34.00MB 02:HASH JOIN [INNER JOIN, PARTITIONED] | hash predicates: o_custkey = c_custkey | fk/pk conjuncts: o_custkey = c_custkey @@ -211,6 +227,7 @@ F02:PLAN FRAGMENT [HASH(o_custkey)] hosts=2 instances=2 | | tuple-ids=1 row-size=238B cardinality=150000 | | | F01:PLAN FRAGMENT [RANDOM] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=24.00MB mem-reservation=0B | 01:SCAN HDFS [tpch_parquet.customer, RANDOM] | partitions=1/1 files=1 size=12.34MB | stats-rows=150000 extrapolated-rows=disabled @@ -224,6 +241,7 @@ F02:PLAN FRAGMENT [HASH(o_custkey)] hosts=2 instances=2 | tuple-ids=0 row-size=191B cardinality=1500000 | F00:PLAN FRAGMENT [RANDOM] hosts=2 instances=2 +Per-Host Resources: mem-estimate=40.00MB mem-reservation=0B 00:SCAN HDFS [tpch_parquet.orders, RANDOM] partitions=1/1 files=2 size=54.20MB runtime filters: RF000 -> o_custkey @@ -237,6 +255,7 @@ Per-Host Resource Reservation: Memory=34.00MB Per-Host Resource Estimates: Memory=146.69MB F03:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=0B mem-reservation=0B PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -245,6 +264,7 @@ PLAN-ROOT SINK | tuple-ids=0,1 row-size=428B cardinality=1500000 | F02:PLAN FRAGMENT [HASH(o_custkey)] hosts=2 instances=4 +Per-Host Resources: mem-estimate=18.69MB mem-reservation=34.00MB 02:HASH JOIN [INNER JOIN, PARTITIONED] | hash-table-id=00 | hash predicates: o_custkey = c_custkey @@ -254,6 +274,7 @@ F02:PLAN FRAGMENT [HASH(o_custkey)] hosts=2 instances=4 | tuple-ids=0,1 row-size=428B cardinality=1500000 | |--F04:PLAN FRAGMENT [HASH(o_custkey)] hosts=1 instances=2 +| | Per-Host Resources: included in parent fragment | JOIN BUILD | | join-table-id=00 plan-id=01 cohort-id=01 | | build expressions: c_custkey @@ -264,6 +285,7 @@ F02:PLAN FRAGMENT [HASH(o_custkey)] hosts=2 instances=4 | | tuple-ids=1 row-size=238B cardinality=150000 | | | F01:PLAN FRAGMENT [RANDOM] hosts=1 instances=2 +| Per-Host Resources: mem-estimate=48.00MB mem-reservation=0B | 01:SCAN HDFS [tpch_parquet.customer, RANDOM] | partitions=1/1 files=1 size=12.34MB | stats-rows=150000 extrapolated-rows=disabled @@ -277,6 +299,7 @@ F02:PLAN FRAGMENT [HASH(o_custkey)] hosts=2 instances=4 | tuple-ids=0 row-size=191B cardinality=1500000 | F00:PLAN FRAGMENT [RANDOM] hosts=2 instances=4 +Per-Host Resources: mem-estimate=80.00MB mem-reservation=0B 00:SCAN HDFS [tpch_parquet.orders, RANDOM] partitions=1/1 files=2 size=54.20MB runtime filters: RF000 -> o_custkey @@ -292,9 +315,10 @@ from tpch_parquet.orders join /*+broadcast*/ tpch_parquet.customer on o_custkey = c_custkey ---- DISTRIBUTEDPLAN Per-Host Resource Reservation: Memory=68.00MB -Per-Host Resource Estimates: Memory=77.38MB +Per-Host Resource Estimates: Memory=101.38MB F02:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=0B mem-reservation=0B PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -303,6 +327,7 @@ PLAN-ROOT SINK | tuple-ids=0,1 row-size=428B cardinality=1500000 | F00:PLAN FRAGMENT [RANDOM] hosts=2 instances=2 +Per-Host Resources: mem-estimate=77.38MB mem-reservation=68.00MB 02:HASH JOIN [INNER JOIN, BROADCAST] | hash predicates: o_custkey = c_custkey | fk/pk conjuncts: o_custkey = c_custkey @@ -315,6 +340,7 @@ F00:PLAN FRAGMENT [RANDOM] hosts=2 instances=2 | | tuple-ids=1 row-size=238B cardinality=150000 | | | F01:PLAN FRAGMENT [RANDOM] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=24.00MB mem-reservation=0B | 01:SCAN HDFS [tpch_parquet.customer, RANDOM] | partitions=1/1 files=1 size=12.34MB | stats-rows=150000 extrapolated-rows=disabled @@ -336,6 +362,7 @@ Per-Host Resource Reservation: Memory=136.00MB Per-Host Resource Estimates: Memory=202.76MB F02:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=0B mem-reservation=0B PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -344,6 +371,7 @@ PLAN-ROOT SINK | tuple-ids=0,1 row-size=428B cardinality=1500000 | F00:PLAN FRAGMENT [RANDOM] hosts=2 instances=4 +Per-Host Resources: mem-estimate=154.76MB mem-reservation=136.00MB 02:HASH JOIN [INNER JOIN, BROADCAST] | hash-table-id=00 | hash predicates: o_custkey = c_custkey @@ -353,6 +381,7 @@ F00:PLAN FRAGMENT [RANDOM] hosts=2 instances=4 | tuple-ids=0,1 row-size=428B cardinality=1500000 | |--F03:PLAN FRAGMENT [RANDOM] hosts=1 instances=2 +| | Per-Host Resources: included in parent fragment | JOIN BUILD | | join-table-id=00 plan-id=01 cohort-id=01 | | build expressions: c_custkey @@ -363,6 +392,7 @@ F00:PLAN FRAGMENT [RANDOM] hosts=2 instances=4 | | tuple-ids=1 row-size=238B cardinality=150000 | | | F01:PLAN FRAGMENT [RANDOM] hosts=1 instances=2 +| Per-Host Resources: mem-estimate=48.00MB mem-reservation=0B | 01:SCAN HDFS [tpch_parquet.customer, RANDOM] | partitions=1/1 files=1 size=12.34MB | stats-rows=150000 extrapolated-rows=disabled @@ -386,11 +416,12 @@ from functional_parquet.alltypes left join functional_parquet.alltypestiny on alltypes.id = alltypestiny.id ---- DISTRIBUTEDPLAN Per-Host Resource Reservation: Memory=136.00MB -Per-Host Resource Estimates: Memory=2.02GB +Per-Host Resource Estimates: Memory=2.03GB WARNING: The following tables are missing relevant table and/or column statistics. functional_parquet.alltypes, functional_parquet.alltypestiny F02:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=0B mem-reservation=0B PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -399,6 +430,7 @@ PLAN-ROOT SINK | tuple-ids=0,1N row-size=176B cardinality=unavailable | F00:PLAN FRAGMENT [RANDOM] hosts=3 instances=3 +Per-Host Resources: mem-estimate=2.02GB mem-reservation=136.00MB 02:HASH JOIN [LEFT OUTER JOIN, BROADCAST] | hash predicates: alltypes.id = alltypestiny.id | fk/pk conjuncts: assumed fk/pk @@ -410,6 +442,7 @@ F00:PLAN FRAGMENT [RANDOM] hosts=3 instances=3 | | tuple-ids=1 row-size=88B cardinality=unavailable | | | F01:PLAN FRAGMENT [RANDOM] hosts=3 instances=3 +| Per-Host Resources: mem-estimate=16.00MB mem-reservation=0B | 01:SCAN HDFS [functional_parquet.alltypestiny, RANDOM] | partitions=4/4 files=4 size=10.48KB | stats-rows=unavailable extrapolated-rows=disabled @@ -432,6 +465,7 @@ WARNING: The following tables are missing relevant table and/or column statistic functional_parquet.alltypestiny F02:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=0B mem-reservation=0B PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -440,6 +474,7 @@ PLAN-ROOT SINK | tuple-ids=0,1N row-size=176B cardinality=unavailable | F00:PLAN FRAGMENT [RANDOM] hosts=3 instances=6 +Per-Host Resources: mem-estimate=4.03GB mem-reservation=272.00MB 02:HASH JOIN [LEFT OUTER JOIN, BROADCAST] | hash-table-id=00 | hash predicates: alltypes.id = alltypestiny.id @@ -448,6 +483,7 @@ F00:PLAN FRAGMENT [RANDOM] hosts=3 instances=6 | tuple-ids=0,1N row-size=176B cardinality=unavailable | |--F03:PLAN FRAGMENT [RANDOM] hosts=3 instances=6 +| | Per-Host Resources: included in parent fragment | JOIN BUILD | | join-table-id=00 plan-id=01 cohort-id=01 | | build expressions: alltypestiny.id @@ -458,6 +494,7 @@ F00:PLAN FRAGMENT [RANDOM] hosts=3 instances=6 | | tuple-ids=1 row-size=88B cardinality=unavailable | | | F01:PLAN FRAGMENT [RANDOM] hosts=3 instances=6 +| Per-Host Resources: mem-estimate=32.00MB mem-reservation=0B | 01:SCAN HDFS [functional_parquet.alltypestiny, RANDOM] | partitions=4/4 files=4 size=10.48KB | stats-rows=unavailable extrapolated-rows=disabled @@ -483,6 +520,7 @@ Per-Host Resource Reservation: Memory=2.12MB Per-Host Resource Estimates: Memory=44.00MB F02:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=0B mem-reservation=0B PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -491,6 +529,7 @@ PLAN-ROOT SINK | tuple-ids=2 row-size=10B cardinality=25 | F01:PLAN FRAGMENT [HASH(c_nationkey)] hosts=1 instances=1 +Per-Host Resources: mem-estimate=10.00MB mem-reservation=2.12MB 03:AGGREGATE [FINALIZE] | output: avg:merge(c_acctbal) | group by: c_nationkey @@ -502,6 +541,7 @@ F01:PLAN FRAGMENT [HASH(c_nationkey)] hosts=1 instances=1 | tuple-ids=1 row-size=10B cardinality=25 | F00:PLAN FRAGMENT [RANDOM] hosts=1 instances=1 +Per-Host Resources: mem-estimate=34.00MB mem-reservation=0B 01:AGGREGATE [STREAMING] | output: avg(c_acctbal) | group by: c_nationkey @@ -520,6 +560,7 @@ Per-Host Resource Reservation: Memory=4.25MB Per-Host Resource Estimates: Memory=88.00MB F02:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=0B mem-reservation=0B PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -528,6 +569,7 @@ PLAN-ROOT SINK | tuple-ids=2 row-size=10B cardinality=25 | F01:PLAN FRAGMENT [HASH(c_nationkey)] hosts=1 instances=2 +Per-Host Resources: mem-estimate=20.00MB mem-reservation=4.25MB 03:AGGREGATE [FINALIZE] | output: avg:merge(c_acctbal) | group by: c_nationkey @@ -539,6 +581,7 @@ F01:PLAN FRAGMENT [HASH(c_nationkey)] hosts=1 instances=2 | tuple-ids=1 row-size=10B cardinality=25 | F00:PLAN FRAGMENT [RANDOM] hosts=1 instances=2 +Per-Host Resources: mem-estimate=68.00MB mem-reservation=0B 01:AGGREGATE [STREAMING] | output: avg(c_acctbal) | group by: c_nationkey @@ -561,9 +604,10 @@ group by 1, 2 having count(*) = 1 ---- DISTRIBUTEDPLAN Per-Host Resource Reservation: Memory=83.00MB -Per-Host Resource Estimates: Memory=165.28MB +Per-Host Resource Estimates: Memory=205.28MB F04:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=0B mem-reservation=0B PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -572,6 +616,7 @@ PLAN-ROOT SINK | tuple-ids=2 row-size=33B cardinality=4690314 | F03:PLAN FRAGMENT [HASH(l_orderkey,o_orderstatus)] hosts=3 instances=3 +Per-Host Resources: mem-estimate=18.04MB mem-reservation=66.00MB 07:AGGREGATE [FINALIZE] | output: count:merge(*) | group by: l_orderkey, o_orderstatus @@ -584,6 +629,7 @@ F03:PLAN FRAGMENT [HASH(l_orderkey,o_orderstatus)] hosts=3 instances=3 | tuple-ids=2 row-size=33B cardinality=4690314 | F02:PLAN FRAGMENT [HASH(l_orderkey)] hosts=3 instances=3 +Per-Host Resources: mem-estimate=67.24MB mem-reservation=17.00MB 03:AGGREGATE [STREAMING] | output: count(*) | group by: l_orderkey, o_orderstatus @@ -602,6 +648,7 @@ F02:PLAN FRAGMENT [HASH(l_orderkey)] hosts=3 instances=3 | | tuple-ids=1 row-size=25B cardinality=1500000 | | | F01:PLAN FRAGMENT [RANDOM] hosts=2 instances=2 +| Per-Host Resources: mem-estimate=40.00MB mem-reservation=0B | 01:SCAN HDFS [tpch_parquet.orders, RANDOM] | partitions=1/1 files=2 size=54.20MB | stats-rows=1500000 extrapolated-rows=disabled @@ -615,6 +662,7 @@ F02:PLAN FRAGMENT [HASH(l_orderkey)] hosts=3 instances=3 | tuple-ids=0 row-size=8B cardinality=6001215 | F00:PLAN FRAGMENT [RANDOM] hosts=3 instances=3 +Per-Host Resources: mem-estimate=80.00MB mem-reservation=0B 00:SCAN HDFS [tpch_parquet.lineitem, RANDOM] partitions=1/1 files=3 size=193.92MB runtime filters: RF000 -> l_orderkey @@ -628,6 +676,7 @@ Per-Host Resource Reservation: Memory=83.00MB Per-Host Resource Estimates: Memory=327.24MB F04:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=0B mem-reservation=0B PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -636,6 +685,7 @@ PLAN-ROOT SINK | tuple-ids=2 row-size=33B cardinality=4690314 | F03:PLAN FRAGMENT [HASH(l_orderkey,o_orderstatus)] hosts=3 instances=6 +Per-Host Resources: mem-estimate=20.00MB mem-reservation=66.00MB 07:AGGREGATE [FINALIZE] | output: count:merge(*) | group by: l_orderkey, o_orderstatus @@ -648,6 +698,7 @@ F03:PLAN FRAGMENT [HASH(l_orderkey,o_orderstatus)] hosts=3 instances=6 | tuple-ids=2 row-size=33B cardinality=4690314 | F02:PLAN FRAGMENT [HASH(l_orderkey)] hosts=3 instances=6 +Per-Host Resources: mem-estimate=67.24MB mem-reservation=17.00MB 03:AGGREGATE [STREAMING] | output: count(*) | group by: l_orderkey, o_orderstatus @@ -663,6 +714,7 @@ F02:PLAN FRAGMENT [HASH(l_orderkey)] hosts=3 instances=6 | tuple-ids=0,1 row-size=33B cardinality=5757710 | |--F05:PLAN FRAGMENT [HASH(l_orderkey)] hosts=2 instances=4 +| | Per-Host Resources: included in parent fragment | JOIN BUILD | | join-table-id=00 plan-id=01 cohort-id=01 | | build expressions: o_orderkey @@ -673,6 +725,7 @@ F02:PLAN FRAGMENT [HASH(l_orderkey)] hosts=3 instances=6 | | tuple-ids=1 row-size=25B cardinality=1500000 | | | F01:PLAN FRAGMENT [RANDOM] hosts=2 instances=4 +| Per-Host Resources: mem-estimate=80.00MB mem-reservation=0B | 01:SCAN HDFS [tpch_parquet.orders, RANDOM] | partitions=1/1 files=2 size=54.20MB | stats-rows=1500000 extrapolated-rows=disabled @@ -686,6 +739,7 @@ F02:PLAN FRAGMENT [HASH(l_orderkey)] hosts=3 instances=6 | tuple-ids=0 row-size=8B cardinality=6001215 | F00:PLAN FRAGMENT [RANDOM] hosts=3 instances=6 +Per-Host Resources: mem-estimate=160.00MB mem-reservation=0B 00:SCAN HDFS [tpch_parquet.lineitem, RANDOM] partitions=1/1 files=3 size=193.92MB runtime filters: RF000 -> l_orderkey @@ -703,6 +757,7 @@ Per-Host Resource Reservation: Memory=264.00MB Per-Host Resource Estimates: Memory=3.31GB F02:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=0B mem-reservation=0B PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -711,6 +766,7 @@ PLAN-ROOT SINK | tuple-ids=1 row-size=263B cardinality=6001215 | F01:PLAN FRAGMENT [HASH(tpch_parquet.lineitem.l_orderkey,tpch_parquet.lineitem.l_partkey,tpch_parquet.lineitem.l_suppkey,tpch_parquet.lineitem.l_linenumber,tpch_parquet.lineitem.l_quantity,tpch_parquet.lineitem.l_extendedprice,tpch_parquet.lineitem.l_discount,tpch_parquet.lineitem.l_tax,tpch_parquet.lineitem.l_returnflag,tpch_parquet.lineitem.l_linestatus,tpch_parquet.lineitem.l_shipdate,tpch_parquet.lineitem.l_commitdate,tpch_parquet.lineitem.l_receiptdate,tpch_parquet.lineitem.l_shipinstruct,tpch_parquet.lineitem.l_shipmode,tpch_parquet.lineitem.l_comment)] hosts=3 instances=3 +Per-Host Resources: mem-estimate=1.62GB mem-reservation=264.00MB 03:AGGREGATE [FINALIZE] | group by: tpch_parquet.lineitem.l_orderkey, tpch_parquet.lineitem.l_partkey, tpch_parquet.lineitem.l_suppkey, tpch_parquet.lineitem.l_linenumber, tpch_parquet.lineitem.l_quantity, tpch_parquet.lineitem.l_extendedprice, tpch_parquet.lineitem.l_discount, tpch_parquet.lineitem.l_tax, tpch_parquet.lineitem.l_returnflag, tpch_parquet.lineitem.l_linestatus, tpch_parquet.lineitem.l_shipdate, tpch_parquet.lineitem.l_commitdate, tpch_parquet.lineitem.l_receiptdate, tpch_parquet.lineitem.l_shipinstruct, tpch_parquet.lineitem.l_shipmode, tpch_parquet.lineitem.l_comment | mem-estimate=1.62GB mem-reservation=264.00MB @@ -721,6 +777,7 @@ F01:PLAN FRAGMENT [HASH(tpch_parquet.lineitem.l_orderkey,tpch_parquet.lineitem.l | tuple-ids=1 row-size=263B cardinality=6001215 | F00:PLAN FRAGMENT [RANDOM] hosts=3 instances=3 +Per-Host Resources: mem-estimate=1.69GB mem-reservation=0B 01:AGGREGATE [STREAMING] | group by: tpch_parquet.lineitem.l_orderkey, tpch_parquet.lineitem.l_partkey, tpch_parquet.lineitem.l_suppkey, tpch_parquet.lineitem.l_linenumber, tpch_parquet.lineitem.l_quantity, tpch_parquet.lineitem.l_extendedprice, tpch_parquet.lineitem.l_discount, tpch_parquet.lineitem.l_tax, tpch_parquet.lineitem.l_returnflag, tpch_parquet.lineitem.l_linestatus, tpch_parquet.lineitem.l_shipdate, tpch_parquet.lineitem.l_commitdate, tpch_parquet.lineitem.l_receiptdate, tpch_parquet.lineitem.l_shipinstruct, tpch_parquet.lineitem.l_shipmode, tpch_parquet.lineitem.l_comment | mem-estimate=1.62GB mem-reservation=0B @@ -738,6 +795,7 @@ Per-Host Resource Reservation: Memory=528.00MB Per-Host Resource Estimates: Memory=6.62GB F02:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=0B mem-reservation=0B PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -746,6 +804,7 @@ PLAN-ROOT SINK | tuple-ids=1 row-size=263B cardinality=6001215 | F01:PLAN FRAGMENT [HASH(tpch_parquet.lineitem.l_orderkey,tpch_parquet.lineitem.l_partkey,tpch_parquet.lineitem.l_suppkey,tpch_parquet.lineitem.l_linenumber,tpch_parquet.lineitem.l_quantity,tpch_parquet.lineitem.l_extendedprice,tpch_parquet.lineitem.l_discount,tpch_parquet.lineitem.l_tax,tpch_parquet.lineitem.l_returnflag,tpch_parquet.lineitem.l_linestatus,tpch_parquet.lineitem.l_shipdate,tpch_parquet.lineitem.l_commitdate,tpch_parquet.lineitem.l_receiptdate,tpch_parquet.lineitem.l_shipinstruct,tpch_parquet.lineitem.l_shipmode,tpch_parquet.lineitem.l_comment)] hosts=3 instances=6 +Per-Host Resources: mem-estimate=3.23GB mem-reservation=528.00MB 03:AGGREGATE [FINALIZE] | group by: tpch_parquet.lineitem.l_orderkey, tpch_parquet.lineitem.l_partkey, tpch_parquet.lineitem.l_suppkey, tpch_parquet.lineitem.l_linenumber, tpch_parquet.lineitem.l_quantity, tpch_parquet.lineitem.l_extendedprice, tpch_parquet.lineitem.l_discount, tpch_parquet.lineitem.l_tax, tpch_parquet.lineitem.l_returnflag, tpch_parquet.lineitem.l_linestatus, tpch_parquet.lineitem.l_shipdate, tpch_parquet.lineitem.l_commitdate, tpch_parquet.lineitem.l_receiptdate, tpch_parquet.lineitem.l_shipinstruct, tpch_parquet.lineitem.l_shipmode, tpch_parquet.lineitem.l_comment | mem-estimate=1.62GB mem-reservation=264.00MB @@ -756,6 +815,7 @@ F01:PLAN FRAGMENT [HASH(tpch_parquet.lineitem.l_orderkey,tpch_parquet.lineitem.l | tuple-ids=1 row-size=263B cardinality=6001215 | F00:PLAN FRAGMENT [RANDOM] hosts=3 instances=6 +Per-Host Resources: mem-estimate=3.39GB mem-reservation=0B 01:AGGREGATE [STREAMING] | group by: tpch_parquet.lineitem.l_orderkey, tpch_parquet.lineitem.l_partkey, tpch_parquet.lineitem.l_suppkey, tpch_parquet.lineitem.l_linenumber, tpch_parquet.lineitem.l_quantity, tpch_parquet.lineitem.l_extendedprice, tpch_parquet.lineitem.l_discount, tpch_parquet.lineitem.l_tax, tpch_parquet.lineitem.l_returnflag, tpch_parquet.lineitem.l_linestatus, tpch_parquet.lineitem.l_shipdate, tpch_parquet.lineitem.l_commitdate, tpch_parquet.lineitem.l_receiptdate, tpch_parquet.lineitem.l_shipinstruct, tpch_parquet.lineitem.l_shipmode, tpch_parquet.lineitem.l_comment | mem-estimate=1.62GB mem-reservation=0B @@ -780,6 +840,7 @@ WARNING: The following tables are missing relevant table and/or column statistic functional_parquet.alltypestiny F02:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=0B mem-reservation=0B PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -788,6 +849,7 @@ PLAN-ROOT SINK | tuple-ids=1 row-size=24B cardinality=unavailable | F01:PLAN FRAGMENT [HASH(string_col)] hosts=3 instances=3 +Per-Host Resources: mem-estimate=128.00MB mem-reservation=264.00MB 03:AGGREGATE [FINALIZE] | output: count:merge(*) | group by: string_col @@ -799,6 +861,7 @@ F01:PLAN FRAGMENT [HASH(string_col)] hosts=3 instances=3 | tuple-ids=1 row-size=24B cardinality=unavailable | F00:PLAN FRAGMENT [RANDOM] hosts=3 instances=3 +Per-Host Resources: mem-estimate=144.00MB mem-reservation=0B 01:AGGREGATE [STREAMING] | output: count(*) | group by: string_col @@ -819,6 +882,7 @@ WARNING: The following tables are missing relevant table and/or column statistic functional_parquet.alltypestiny F02:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=0B mem-reservation=0B PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -827,6 +891,7 @@ PLAN-ROOT SINK | tuple-ids=1 row-size=24B cardinality=unavailable | F01:PLAN FRAGMENT [HASH(string_col)] hosts=3 instances=6 +Per-Host Resources: mem-estimate=256.00MB mem-reservation=528.00MB 03:AGGREGATE [FINALIZE] | output: count:merge(*) | group by: string_col @@ -838,6 +903,7 @@ F01:PLAN FRAGMENT [HASH(string_col)] hosts=3 instances=6 | tuple-ids=1 row-size=24B cardinality=unavailable | F00:PLAN FRAGMENT [RANDOM] hosts=3 instances=6 +Per-Host Resources: mem-estimate=288.00MB mem-reservation=0B 01:AGGREGATE [STREAMING] | output: count(*) | group by: string_col http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/64fd0115/testdata/workloads/functional-planner/queries/PlannerTest/tablesample.test ---------------------------------------------------------------------- diff --git a/testdata/workloads/functional-planner/queries/PlannerTest/tablesample.test b/testdata/workloads/functional-planner/queries/PlannerTest/tablesample.test index fc8778e..868d6ca 100644 --- a/testdata/workloads/functional-planner/queries/PlannerTest/tablesample.test +++ b/testdata/workloads/functional-planner/queries/PlannerTest/tablesample.test @@ -2,6 +2,7 @@ select * from functional.alltypes tablesample system(10) repeatable(1234) ---- PLAN F00:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=32.00MB mem-reservation=0B PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -17,6 +18,7 @@ PLAN-ROOT SINK select * from functional.alltypes tablesample system(50) repeatable(1234) ---- PLAN F00:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=80.00MB mem-reservation=0B PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -34,6 +36,7 @@ select * from functional.alltypes tablesample system(50) repeatable(1234) where id < 10 ---- PLAN F00:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=80.00MB mem-reservation=0B PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -52,6 +55,7 @@ select * from functional.alltypes tablesample system(50) repeatable(1234) where year = 2009 ---- PLAN F00:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=48.00MB mem-reservation=0B PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -67,6 +71,7 @@ PLAN-ROOT SINK select * from functional.alltypes tablesample system(0) ---- PLAN F00:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=0B mem-reservation=0B PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -82,6 +87,7 @@ PLAN-ROOT SINK select * from functional.alltypes tablesample system(1) repeatable(1234) ---- PLAN F00:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=32.00MB mem-reservation=0B PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -98,6 +104,7 @@ select * from functional.alltypes tablesample system(1) repeatable(1234) where year = 2010 ---- PLAN F00:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=32.00MB mem-reservation=0B PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -113,6 +120,7 @@ PLAN-ROOT SINK select * from functional.alltypes tablesample system (100) ---- PLAN F00:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=128.00MB mem-reservation=0B PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -128,6 +136,7 @@ PLAN-ROOT SINK select id from functional_parquet.alltypes tablesample system(10) repeatable(1234) ---- PLAN F00:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=16.00MB mem-reservation=0B PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -145,6 +154,7 @@ select id from functional.alltypes t1 where exists ( where t1.id = t2.id) ---- PLAN F00:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=160.00MB mem-reservation=136.00MB PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | @@ -176,6 +186,7 @@ with t as (select * from functional.alltypes tablesample system(10) repeatable(1 select id from t ---- PLAN F00:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 +| Per-Host Resources: mem-estimate=32.00MB mem-reservation=0B PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B | http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/64fd0115/testdata/workloads/functional-query/queries/QueryTest/explain-level0.test ---------------------------------------------------------------------- diff --git a/testdata/workloads/functional-query/queries/QueryTest/explain-level0.test b/testdata/workloads/functional-query/queries/QueryTest/explain-level0.test index 06d76c8..64f9b45 100644 --- a/testdata/workloads/functional-query/queries/QueryTest/explain-level0.test +++ b/testdata/workloads/functional-query/queries/QueryTest/explain-level0.test @@ -6,7 +6,7 @@ select * from tpch.lineitem join tpch.orders on l_orderkey = o_orderkey; ---- RESULTS: VERIFY_IS_EQUAL 'Per-Host Resource Reservation: Memory=136.00MB' -'Per-Host Resource Estimates: Memory=388.41MB' +'Per-Host Resource Estimates: Memory=476.41MB' '' 'PLAN-ROOT SINK' '04:EXCHANGE [UNPARTITIONED]' http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/64fd0115/testdata/workloads/functional-query/queries/QueryTest/explain-level1.test ---------------------------------------------------------------------- diff --git a/testdata/workloads/functional-query/queries/QueryTest/explain-level1.test b/testdata/workloads/functional-query/queries/QueryTest/explain-level1.test index a082603..f59962c 100644 --- a/testdata/workloads/functional-query/queries/QueryTest/explain-level1.test +++ b/testdata/workloads/functional-query/queries/QueryTest/explain-level1.test @@ -6,7 +6,7 @@ select * from tpch.lineitem join tpch.orders on l_orderkey = o_orderkey; ---- RESULTS: VERIFY_IS_EQUAL 'Per-Host Resource Reservation: Memory=136.00MB' -'Per-Host Resource Estimates: Memory=388.41MB' +'Per-Host Resource Estimates: Memory=476.41MB' '' 'PLAN-ROOT SINK' '|' http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/64fd0115/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 8d4ff1f..2736543 100644 --- a/testdata/workloads/functional-query/queries/QueryTest/explain-level2.test +++ b/testdata/workloads/functional-query/queries/QueryTest/explain-level2.test @@ -6,9 +6,10 @@ select * from tpch.lineitem join tpch.orders on l_orderkey = o_orderkey; ---- RESULTS: VERIFY_IS_EQUAL 'Per-Host Resource Reservation: Memory=136.00MB' -'Per-Host Resource Estimates: Memory=388.41MB' +'Per-Host Resource Estimates: Memory=476.41MB' '' 'F02:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1' +'| Per-Host Resources: mem-estimate=0B mem-reservation=0B' 'PLAN-ROOT SINK' '| mem-estimate=0B mem-reservation=0B' '|' @@ -17,6 +18,7 @@ from tpch.lineitem join tpch.orders on l_orderkey = o_orderkey; '| tuple-ids=0,1 row-size=454B cardinality=5757710' '|' 'F00:PLAN FRAGMENT [RANDOM] hosts=3 instances=3' +'Per-Host Resources: mem-estimate=388.41MB mem-reservation=136.00MB' '02:HASH JOIN [INNER JOIN, BROADCAST]' '| hash predicates: l_orderkey = o_orderkey' '| fk/pk conjuncts: l_orderkey = o_orderkey' @@ -29,6 +31,7 @@ from tpch.lineitem join tpch.orders on l_orderkey = o_orderkey; '| | tuple-ids=1 row-size=191B cardinality=1500000' '| |' '| F01:PLAN FRAGMENT [RANDOM] hosts=2 instances=2' +'| Per-Host Resources: mem-estimate=88.00MB mem-reservation=0B' '| 01:SCAN HDFS [tpch.orders, RANDOM]' row_regex:.*partitions=1/1 files=1 size=.* '| stats-rows=1500000 extrapolated-rows=disabled' @@ -54,7 +57,7 @@ from functional_avro.alltypes t1 left outer join functional_avro.alltypes t3 on (t2.id = t3.id) where t1.month = 1 and t2.year = 2009 and t3.bool_col = false ---- RESULTS: VERIFY_IS_SUBSET -'Per-Host Resource Estimates: Memory=4.03GB' +'Per-Host Resource Estimates: Memory=4.07GB' 'WARNING: The following tables are missing relevant table and/or column statistics.' 'functional_avro.alltypes, functional_parquet.alltypessmall' ==== http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/64fd0115/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 4fff35a..31f4f5b 100644 --- a/testdata/workloads/functional-query/queries/QueryTest/explain-level3.test +++ b/testdata/workloads/functional-query/queries/QueryTest/explain-level3.test @@ -6,9 +6,10 @@ select * from tpch.lineitem join tpch.orders on l_orderkey = o_orderkey; ---- RESULTS: VERIFY_IS_EQUAL 'Per-Host Resource Reservation: Memory=136.00MB' -'Per-Host Resource Estimates: Memory=388.41MB' +'Per-Host Resource Estimates: Memory=476.41MB' '' 'F02:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1' +'Per-Host Resources: mem-estimate=0B mem-reservation=0B' ' PLAN-ROOT SINK' ' | mem-estimate=0B mem-reservation=0B' ' |' @@ -17,6 +18,7 @@ from tpch.lineitem join tpch.orders on l_orderkey = o_orderkey; ' tuple-ids=0,1 row-size=454B cardinality=5757710' '' 'F00:PLAN FRAGMENT [RANDOM] hosts=3 instances=3' +'Per-Host Resources: mem-estimate=388.41MB mem-reservation=136.00MB' ' DATASTREAM SINK [FRAGMENT=F02, EXCHANGE=04, UNPARTITIONED]' ' | mem-estimate=0B mem-reservation=0B' ' 02:HASH JOIN [INNER JOIN, BROADCAST]' @@ -40,6 +42,7 @@ row_regex:.*partitions=1/1 files=1 size=.* ' tuple-ids=0 row-size=263B cardinality=6001215' '' 'F01:PLAN FRAGMENT [RANDOM] hosts=2 instances=2' +'Per-Host Resources: mem-estimate=88.00MB mem-reservation=0B' ' DATASTREAM SINK [FRAGMENT=F00, EXCHANGE=03, BROADCAST]' ' | mem-estimate=0B mem-reservation=0B' ' 01:SCAN HDFS [tpch.orders, RANDOM]' http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/64fd0115/testdata/workloads/functional-query/queries/QueryTest/stats-extrapolation.test ---------------------------------------------------------------------- diff --git a/testdata/workloads/functional-query/queries/QueryTest/stats-extrapolation.test b/testdata/workloads/functional-query/queries/QueryTest/stats-extrapolation.test index 9de5480..b31bacf 100644 --- a/testdata/workloads/functional-query/queries/QueryTest/stats-extrapolation.test +++ b/testdata/workloads/functional-query/queries/QueryTest/stats-extrapolation.test @@ -32,6 +32,7 @@ explain select id from alltypes; 'Codegen disabled by planner' '' 'F00:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1' +'| Per-Host Resources: mem-estimate=16.00MB mem-reservation=0B' 'PLAN-ROOT SINK' '| mem-estimate=0B mem-reservation=0B' '|' @@ -54,6 +55,7 @@ explain select id from alltypes where month in (1, 2, 3); 'Codegen disabled by planner' '' 'F00:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1' +'| Per-Host Resources: mem-estimate=16.00MB mem-reservation=0B' 'PLAN-ROOT SINK' '| mem-estimate=0B mem-reservation=0B' '|' @@ -77,6 +79,7 @@ explain select id from alltypes; 'Per-Host Resource Estimates: Memory=16.00MB' '' 'F00:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1' +'| Per-Host Resources: mem-estimate=16.00MB mem-reservation=0B' 'PLAN-ROOT SINK' '| mem-estimate=0B mem-reservation=0B' '|' @@ -101,6 +104,7 @@ explain select id from alltypes where year = 2010; 'Codegen disabled by planner' '' 'F00:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1' +'| Per-Host Resources: mem-estimate=16.00MB mem-reservation=0B' 'PLAN-ROOT SINK' '| mem-estimate=0B mem-reservation=0B' '|' @@ -124,6 +128,7 @@ explain select id from alltypes where year = 2010; 'Codegen disabled by planner' '' 'F00:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1' +'| Per-Host Resources: mem-estimate=16.00MB mem-reservation=0B' 'PLAN-ROOT SINK' '| mem-estimate=0B mem-reservation=0B' '|'
