http://git-wip-us.apache.org/repos/asf/impala/blob/8cbec20e/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 b33a2c7..4e92766 100644 --- a/testdata/workloads/functional-planner/queries/PlannerTest/spillable-buffer-sizing.test +++ b/testdata/workloads/functional-planner/queries/PlannerTest/spillable-buffer-sizing.test @@ -4,20 +4,20 @@ from tpch_parquet.customer inner join tpch_parquet.nation on c_nationkey = n_nationkey ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=18.97MB Threads=5 -Per-Host Resource Estimates: Memory=43MB +Per-Host Resource Estimates: Memory=53MB F02:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 -| Per-Host Resources: mem-estimate=0B mem-reservation=0B thread-reservation=1 +| Per-Host Resources: mem-estimate=10.35MB mem-reservation=0B thread-reservation=1 PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B thread-reservation=0 | 04:EXCHANGE [UNPARTITIONED] -| mem-estimate=0B mem-reservation=0B thread-reservation=0 +| mem-estimate=10.35MB mem-reservation=0B thread-reservation=0 | tuple-ids=0,1 row-size=355B cardinality=150000 | in pipelines: 00(GETNEXT) | F00:PLAN FRAGMENT [RANDOM] hosts=1 instances=1 -Per-Host Resources: mem-estimate=26.94MB mem-reservation=18.94MB thread-reservation=2 runtime-filters-memory=1.00MB +Per-Host Resources: mem-estimate=26.95MB mem-reservation=18.94MB thread-reservation=2 runtime-filters-memory=1.00MB 02:HASH JOIN [INNER JOIN, BROADCAST] | hash predicates: c_nationkey = n_nationkey | fk/pk conjuncts: c_nationkey = n_nationkey @@ -27,7 +27,7 @@ Per-Host Resources: mem-estimate=26.94MB mem-reservation=18.94MB thread-reservat | in pipelines: 00(GETNEXT), 01(OPEN) | |--03:EXCHANGE [BROADCAST] -| | mem-estimate=0B mem-reservation=0B thread-reservation=0 +| | mem-estimate=16.00KB mem-reservation=0B thread-reservation=0 | | tuple-ids=1 row-size=117B cardinality=25 | | in pipelines: 01(GETNEXT) | | @@ -55,15 +55,15 @@ Per-Host Resources: mem-estimate=26.94MB mem-reservation=18.94MB thread-reservat in pipelines: 00(GETNEXT) ---- PARALLELPLANS Max Per-Host Resource Reservation: Memory=37.94MB Threads=5 -Per-Host Resource Estimates: Memory=86MB +Per-Host Resource Estimates: Memory=97MB F02:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 -| Per-Host Resources: mem-estimate=0B mem-reservation=0B thread-reservation=1 +| Per-Host Resources: mem-estimate=10.71MB mem-reservation=0B thread-reservation=1 PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B thread-reservation=0 | 04:EXCHANGE [UNPARTITIONED] -| mem-estimate=0B mem-reservation=0B thread-reservation=0 +| mem-estimate=10.71MB mem-reservation=0B thread-reservation=0 | tuple-ids=0,1 row-size=355B cardinality=150000 | in pipelines: 00(GETNEXT) | @@ -86,7 +86,7 @@ Per-Host Resources: mem-estimate=53.88MB mem-reservation=37.88MB thread-reservat | | mem-estimate=0B mem-reservation=0B thread-reservation=0 | | | 03:EXCHANGE [BROADCAST] -| | mem-estimate=0B mem-reservation=0B thread-reservation=0 +| | mem-estimate=16.00KB mem-reservation=0B thread-reservation=0 | | tuple-ids=1 row-size=117B cardinality=25 | | in pipelines: 01(GETNEXT) | | @@ -119,20 +119,20 @@ from tpch_parquet.lineitem left join tpch_parquet.orders on l_orderkey = o_orderkey ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=98.00MB Threads=5 -Per-Host Resource Estimates: Memory=420MB +Per-Host Resource Estimates: Memory=442MB F02:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 -| Per-Host Resources: mem-estimate=0B mem-reservation=0B thread-reservation=1 +| Per-Host Resources: mem-estimate=11.35MB mem-reservation=0B thread-reservation=1 PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B thread-reservation=0 | 04:EXCHANGE [UNPARTITIONED] -| mem-estimate=0B mem-reservation=0B thread-reservation=0 +| mem-estimate=11.35MB mem-reservation=0B thread-reservation=0 | tuple-ids=0,1N row-size=454B cardinality=6001215 | in pipelines: 00(GETNEXT) | F00:PLAN FRAGMENT [RANDOM] hosts=3 instances=3 -Per-Host Resources: mem-estimate=380.41MB mem-reservation=74.00MB thread-reservation=2 +Per-Host Resources: mem-estimate=390.80MB mem-reservation=74.00MB thread-reservation=2 02:HASH JOIN [LEFT OUTER JOIN, BROADCAST] | hash predicates: l_orderkey = o_orderkey | fk/pk conjuncts: l_orderkey = o_orderkey @@ -141,7 +141,7 @@ Per-Host Resources: mem-estimate=380.41MB mem-reservation=74.00MB thread-reserva | in pipelines: 00(GETNEXT), 01(OPEN) | |--03:EXCHANGE [BROADCAST] -| | mem-estimate=0B mem-reservation=0B thread-reservation=0 +| | mem-estimate=10.38MB mem-reservation=0B thread-reservation=0 | | tuple-ids=1 row-size=191B cardinality=1500000 | | in pipelines: 01(GETNEXT) | | @@ -158,25 +158,25 @@ Per-Host Resources: mem-estimate=380.41MB mem-reservation=74.00MB thread-reserva | in pipelines: 01(GETNEXT) | 00:SCAN HDFS [tpch_parquet.lineitem, RANDOM] - partitions=1/1 files=3 size=193.71MB + partitions=1/1 files=3 size=193.72MB stored statistics: - table: rows=6001215 size=193.71MB + table: rows=6001215 size=193.72MB columns: all - extrapolated-rows=disabled max-scan-range-rows=2141802 + extrapolated-rows=disabled max-scan-range-rows=2141530 mem-estimate=80.00MB mem-reservation=40.00MB thread-reservation=1 tuple-ids=0 row-size=263B cardinality=6001215 in pipelines: 00(GETNEXT) ---- PARALLELPLANS Max Per-Host Resource Reservation: Memory=196.00MB Threads=5 -Per-Host Resource Estimates: Memory=841MB +Per-Host Resource Estimates: Memory=854MB F02:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 -| Per-Host Resources: mem-estimate=0B mem-reservation=0B thread-reservation=1 +| Per-Host Resources: mem-estimate=12.71MB mem-reservation=0B thread-reservation=1 PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B thread-reservation=0 | 04:EXCHANGE [UNPARTITIONED] -| mem-estimate=0B mem-reservation=0B thread-reservation=0 +| mem-estimate=12.71MB mem-reservation=0B thread-reservation=0 | tuple-ids=0,1N row-size=454B cardinality=6001215 | in pipelines: 00(GETNEXT) | @@ -198,7 +198,7 @@ Per-Host Resources: mem-estimate=760.83MB mem-reservation=148.00MB thread-reserv | | mem-estimate=0B mem-reservation=0B thread-reservation=0 | | | 03:EXCHANGE [BROADCAST] -| | mem-estimate=0B mem-reservation=0B thread-reservation=0 +| | mem-estimate=10.76MB mem-reservation=0B thread-reservation=0 | | tuple-ids=1 row-size=191B cardinality=1500000 | | in pipelines: 01(GETNEXT) | | @@ -215,11 +215,11 @@ Per-Host Resources: mem-estimate=760.83MB mem-reservation=148.00MB thread-reserv | in pipelines: 01(GETNEXT) | 00:SCAN HDFS [tpch_parquet.lineitem, RANDOM] - partitions=1/1 files=3 size=193.71MB + partitions=1/1 files=3 size=193.72MB stored statistics: - table: rows=6001215 size=193.71MB + table: rows=6001215 size=193.72MB columns: all - extrapolated-rows=disabled max-scan-range-rows=2141802 + extrapolated-rows=disabled max-scan-range-rows=2141530 mem-estimate=80.00MB mem-reservation=40.00MB thread-reservation=0 tuple-ids=0 row-size=263B cardinality=6001215 in pipelines: 00(GETNEXT) @@ -230,20 +230,20 @@ from tpch_parquet.orders join /*+shuffle*/ tpch_parquet.customer on o_custkey = c_custkey ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=76.00MB Threads=6 -Per-Host Resource Estimates: Memory=100MB +Per-Host Resource Estimates: Memory=131MB F03:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 -| Per-Host Resources: mem-estimate=0B mem-reservation=0B thread-reservation=1 +| Per-Host Resources: mem-estimate=10.85MB mem-reservation=0B thread-reservation=1 PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B thread-reservation=0 | 05:EXCHANGE [UNPARTITIONED] -| mem-estimate=0B mem-reservation=0B thread-reservation=0 +| mem-estimate=10.85MB mem-reservation=0B thread-reservation=0 | tuple-ids=0,1 row-size=428B cardinality=1500000 | in pipelines: 00(GETNEXT) | F02:PLAN FRAGMENT [HASH(o_custkey)] hosts=2 instances=2 -Per-Host Resources: mem-estimate=35.00MB mem-reservation=35.00MB thread-reservation=1 runtime-filters-memory=1.00MB +Per-Host Resources: mem-estimate=55.62MB mem-reservation=35.00MB thread-reservation=1 runtime-filters-memory=1.00MB 02:HASH JOIN [INNER JOIN, PARTITIONED] | hash predicates: o_custkey = c_custkey | fk/pk conjuncts: o_custkey = c_custkey @@ -253,7 +253,7 @@ Per-Host Resources: mem-estimate=35.00MB mem-reservation=35.00MB thread-reservat | in pipelines: 00(GETNEXT), 01(OPEN) | |--04:EXCHANGE [HASH(c_custkey)] -| | mem-estimate=0B mem-reservation=0B thread-reservation=0 +| | mem-estimate=10.24MB mem-reservation=0B thread-reservation=0 | | tuple-ids=1 row-size=238B cardinality=150000 | | in pipelines: 01(GETNEXT) | | @@ -270,7 +270,7 @@ Per-Host Resources: mem-estimate=35.00MB mem-reservation=35.00MB thread-reservat | in pipelines: 01(GETNEXT) | 03:EXCHANGE [HASH(o_custkey)] -| mem-estimate=0B mem-reservation=0B thread-reservation=0 +| mem-estimate=10.38MB mem-reservation=0B thread-reservation=0 | tuple-ids=0 row-size=191B cardinality=1500000 | in pipelines: 00(GETNEXT) | @@ -288,20 +288,20 @@ Per-Host Resources: mem-estimate=41.00MB mem-reservation=25.00MB thread-reservat in pipelines: 00(GETNEXT) ---- PARALLELPLANS Max Per-Host Resource Reservation: Memory=118.00MB Threads=7 -Per-Host Resource Estimates: Memory=166MB +Per-Host Resource Estimates: Memory=199MB F03:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 -| Per-Host Resources: mem-estimate=0B mem-reservation=0B thread-reservation=1 +| Per-Host Resources: mem-estimate=11.70MB mem-reservation=0B thread-reservation=1 PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B thread-reservation=0 | 05:EXCHANGE [UNPARTITIONED] -| mem-estimate=0B mem-reservation=0B thread-reservation=0 +| mem-estimate=11.70MB mem-reservation=0B thread-reservation=0 | tuple-ids=0,1 row-size=428B cardinality=1500000 | in pipelines: 00(GETNEXT) | F02:PLAN FRAGMENT [HASH(o_custkey)] hosts=2 instances=4 -Per-Host Resources: mem-estimate=36.00MB mem-reservation=36.00MB thread-reservation=2 runtime-filters-memory=1.00MB +Per-Host Resources: mem-estimate=57.52MB mem-reservation=36.00MB thread-reservation=2 runtime-filters-memory=1.00MB 02:HASH JOIN [INNER JOIN, PARTITIONED] | hash-table-id=00 | hash predicates: o_custkey = c_custkey @@ -319,7 +319,7 @@ Per-Host Resources: mem-estimate=36.00MB mem-reservation=36.00MB thread-reservat | | mem-estimate=0B mem-reservation=0B thread-reservation=0 | | | 04:EXCHANGE [HASH(c_custkey)] -| | mem-estimate=0B mem-reservation=0B thread-reservation=0 +| | mem-estimate=10.47MB mem-reservation=0B thread-reservation=0 | | tuple-ids=1 row-size=238B cardinality=150000 | | in pipelines: 01(GETNEXT) | | @@ -336,7 +336,7 @@ Per-Host Resources: mem-estimate=36.00MB mem-reservation=36.00MB thread-reservat | in pipelines: 01(GETNEXT) | 03:EXCHANGE [HASH(o_custkey)] -| mem-estimate=0B mem-reservation=0B thread-reservation=0 +| mem-estimate=10.76MB mem-reservation=0B thread-reservation=0 | tuple-ids=0 row-size=191B cardinality=1500000 | in pipelines: 00(GETNEXT) | @@ -359,20 +359,20 @@ from tpch_parquet.orders join /*+broadcast*/ tpch_parquet.customer on o_custkey = c_custkey ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=75.00MB Threads=5 -Per-Host Resource Estimates: Memory=102MB +Per-Host Resource Estimates: Memory=123MB F02:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 -| Per-Host Resources: mem-estimate=0B mem-reservation=0B thread-reservation=1 +| Per-Host Resources: mem-estimate=10.85MB mem-reservation=0B thread-reservation=1 PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B thread-reservation=0 | 04:EXCHANGE [UNPARTITIONED] -| mem-estimate=0B mem-reservation=0B thread-reservation=0 +| mem-estimate=10.85MB mem-reservation=0B thread-reservation=0 | tuple-ids=0,1 row-size=428B cardinality=1500000 | in pipelines: 00(GETNEXT) | F00:PLAN FRAGMENT [RANDOM] hosts=2 instances=2 -Per-Host Resources: mem-estimate=78.38MB mem-reservation=59.00MB thread-reservation=2 runtime-filters-memory=1.00MB +Per-Host Resources: mem-estimate=88.62MB mem-reservation=59.00MB thread-reservation=2 runtime-filters-memory=1.00MB 02:HASH JOIN [INNER JOIN, BROADCAST] | hash predicates: o_custkey = c_custkey | fk/pk conjuncts: o_custkey = c_custkey @@ -382,7 +382,7 @@ Per-Host Resources: mem-estimate=78.38MB mem-reservation=59.00MB thread-reservat | in pipelines: 00(GETNEXT), 01(OPEN) | |--03:EXCHANGE [BROADCAST] -| | mem-estimate=0B mem-reservation=0B thread-reservation=0 +| | mem-estimate=10.24MB mem-reservation=0B thread-reservation=0 | | tuple-ids=1 row-size=238B cardinality=150000 | | in pipelines: 01(GETNEXT) | | @@ -410,15 +410,15 @@ Per-Host Resources: mem-estimate=78.38MB mem-reservation=59.00MB thread-reservat in pipelines: 00(GETNEXT) ---- PARALLELPLANS Max Per-Host Resource Reservation: Memory=150.00MB Threads=5 -Per-Host Resource Estimates: Memory=205MB +Per-Host Resource Estimates: Memory=216MB F02:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 -| Per-Host Resources: mem-estimate=0B mem-reservation=0B thread-reservation=1 +| Per-Host Resources: mem-estimate=11.70MB mem-reservation=0B thread-reservation=1 PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B thread-reservation=0 | 04:EXCHANGE [UNPARTITIONED] -| mem-estimate=0B mem-reservation=0B thread-reservation=0 +| mem-estimate=11.70MB mem-reservation=0B thread-reservation=0 | tuple-ids=0,1 row-size=428B cardinality=1500000 | in pipelines: 00(GETNEXT) | @@ -441,7 +441,7 @@ Per-Host Resources: mem-estimate=156.76MB mem-reservation=118.00MB thread-reserv | | mem-estimate=0B mem-reservation=0B thread-reservation=0 | | | 03:EXCHANGE [BROADCAST] -| | mem-estimate=0B mem-reservation=0B thread-reservation=0 +| | mem-estimate=10.47MB mem-reservation=0B thread-reservation=0 | | tuple-ids=1 row-size=238B cardinality=150000 | | in pipelines: 01(GETNEXT) | | @@ -479,12 +479,12 @@ WARNING: The following tables are missing relevant table and/or column statistic functional_parquet.alltypes, functional_parquet.alltypestiny F02:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 -| Per-Host Resources: mem-estimate=0B mem-reservation=0B thread-reservation=1 +| Per-Host Resources: mem-estimate=551.94KB mem-reservation=0B thread-reservation=1 PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B thread-reservation=0 | 04:EXCHANGE [UNPARTITIONED] -| mem-estimate=0B mem-reservation=0B thread-reservation=0 +| mem-estimate=551.94KB mem-reservation=0B thread-reservation=0 | tuple-ids=0,1N row-size=176B cardinality=unavailable | in pipelines: 00(GETNEXT) | @@ -498,7 +498,7 @@ Per-Host Resources: mem-estimate=2.02GB mem-reservation=34.09MB thread-reservati | in pipelines: 00(GETNEXT), 01(OPEN) | |--03:EXCHANGE [BROADCAST] -| | mem-estimate=0B mem-reservation=0B thread-reservation=0 +| | mem-estimate=275.91KB mem-reservation=0B thread-reservation=0 | | tuple-ids=1 row-size=88B cardinality=unavailable | | in pipelines: 01(GETNEXT) | | @@ -516,7 +516,7 @@ Per-Host Resources: mem-estimate=2.02GB mem-reservation=34.09MB thread-reservati | in pipelines: 01(GETNEXT) | 00:SCAN HDFS [functional_parquet.alltypes, RANDOM] - partitions=24/24 files=24 size=188.92KB + partitions=24/24 files=24 size=188.54KB stored statistics: table: rows=unavailable size=unavailable partitions: 0/24 rows=unavailable @@ -532,12 +532,12 @@ 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 thread-reservation=1 +| Per-Host Resources: mem-estimate=1.08MB mem-reservation=0B thread-reservation=1 PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B thread-reservation=0 | 04:EXCHANGE [UNPARTITIONED] -| mem-estimate=0B mem-reservation=0B thread-reservation=0 +| mem-estimate=1.08MB mem-reservation=0B thread-reservation=0 | tuple-ids=0,1N row-size=176B cardinality=unavailable | in pipelines: 00(GETNEXT) | @@ -559,7 +559,7 @@ Per-Host Resources: mem-estimate=4.03GB mem-reservation=68.17MB thread-reservati | | mem-estimate=0B mem-reservation=0B thread-reservation=0 | | | 03:EXCHANGE [BROADCAST] -| | mem-estimate=0B mem-reservation=0B thread-reservation=0 +| | mem-estimate=551.91KB mem-reservation=0B thread-reservation=0 | | tuple-ids=1 row-size=88B cardinality=unavailable | | in pipelines: 01(GETNEXT) | | @@ -577,7 +577,7 @@ Per-Host Resources: mem-estimate=4.03GB mem-reservation=68.17MB thread-reservati | in pipelines: 01(GETNEXT) | 00:SCAN HDFS [functional_parquet.alltypes, RANDOM] - partitions=24/24 files=24 size=188.92KB + partitions=24/24 files=24 size=188.54KB stored statistics: table: rows=unavailable size=unavailable partitions: 0/24 rows=unavailable @@ -596,17 +596,17 @@ Max Per-Host Resource Reservation: Memory=5.94MB Threads=4 Per-Host Resource Estimates: Memory=44MB F02:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 -| Per-Host Resources: mem-estimate=0B mem-reservation=0B thread-reservation=1 +| Per-Host Resources: mem-estimate=16.00KB mem-reservation=0B thread-reservation=1 PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B thread-reservation=0 | 04:EXCHANGE [UNPARTITIONED] -| mem-estimate=0B mem-reservation=0B thread-reservation=0 +| mem-estimate=16.00KB mem-reservation=0B thread-reservation=0 | tuple-ids=2 row-size=10B cardinality=25 | in pipelines: 03(GETNEXT) | F01:PLAN FRAGMENT [HASH(c_nationkey)] hosts=1 instances=1 -Per-Host Resources: mem-estimate=10.00MB mem-reservation=1.94MB thread-reservation=1 +Per-Host Resources: mem-estimate=10.02MB mem-reservation=1.94MB thread-reservation=1 03:AGGREGATE [FINALIZE] | output: avg:merge(c_acctbal) | group by: c_nationkey @@ -615,7 +615,7 @@ Per-Host Resources: mem-estimate=10.00MB mem-reservation=1.94MB thread-reservati | in pipelines: 03(GETNEXT), 00(OPEN) | 02:EXCHANGE [HASH(c_nationkey)] -| mem-estimate=0B mem-reservation=0B thread-reservation=0 +| mem-estimate=16.00KB mem-reservation=0B thread-reservation=0 | tuple-ids=1 row-size=10B cardinality=25 | in pipelines: 00(GETNEXT) | @@ -642,17 +642,17 @@ Max Per-Host Resource Reservation: Memory=11.88MB Threads=5 Per-Host Resource Estimates: Memory=88MB F02:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 -| Per-Host Resources: mem-estimate=0B mem-reservation=0B thread-reservation=1 +| Per-Host Resources: mem-estimate=16.00KB mem-reservation=0B thread-reservation=1 PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B thread-reservation=0 | 04:EXCHANGE [UNPARTITIONED] -| mem-estimate=0B mem-reservation=0B thread-reservation=0 +| mem-estimate=16.00KB mem-reservation=0B thread-reservation=0 | tuple-ids=2 row-size=10B cardinality=25 | in pipelines: 03(GETNEXT) | F01:PLAN FRAGMENT [HASH(c_nationkey)] hosts=1 instances=2 -Per-Host Resources: mem-estimate=20.00MB mem-reservation=3.88MB thread-reservation=2 +Per-Host Resources: mem-estimate=20.03MB mem-reservation=3.88MB thread-reservation=2 03:AGGREGATE [FINALIZE] | output: avg:merge(c_acctbal) | group by: c_nationkey @@ -661,7 +661,7 @@ Per-Host Resources: mem-estimate=20.00MB mem-reservation=3.88MB thread-reservati | in pipelines: 03(GETNEXT), 00(OPEN) | 02:EXCHANGE [HASH(c_nationkey)] -| mem-estimate=0B mem-reservation=0B thread-reservation=0 +| mem-estimate=16.00KB mem-reservation=0B thread-reservation=0 | tuple-ids=1 row-size=10B cardinality=25 | in pipelines: 00(GETNEXT) | @@ -692,20 +692,20 @@ group by 1, 2 having count(*) = 1 ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=99.00MB Threads=7 -Per-Host Resource Estimates: Memory=227MB +Per-Host Resource Estimates: Memory=267MB F04:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 -| Per-Host Resources: mem-estimate=0B mem-reservation=0B thread-reservation=1 +| Per-Host Resources: mem-estimate=10.11MB mem-reservation=0B thread-reservation=1 PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B thread-reservation=0 | 08:EXCHANGE [UNPARTITIONED] -| mem-estimate=0B mem-reservation=0B thread-reservation=0 +| mem-estimate=10.11MB mem-reservation=0B thread-reservation=0 | tuple-ids=2 row-size=33B cardinality=4690314 | in pipelines: 07(GETNEXT) | F03:PLAN FRAGMENT [HASH(l_orderkey,o_orderstatus)] hosts=3 instances=3 -Per-Host Resources: mem-estimate=34.00MB mem-reservation=34.00MB thread-reservation=1 +Per-Host Resources: mem-estimate=44.11MB mem-reservation=34.00MB thread-reservation=1 07:AGGREGATE [FINALIZE] | output: count:merge(*) | group by: l_orderkey, o_orderstatus @@ -715,12 +715,12 @@ Per-Host Resources: mem-estimate=34.00MB mem-reservation=34.00MB thread-reservat | in pipelines: 07(GETNEXT), 00(OPEN) | 06:EXCHANGE [HASH(l_orderkey,o_orderstatus)] -| mem-estimate=0B mem-reservation=0B thread-reservation=0 +| mem-estimate=10.11MB mem-reservation=0B thread-reservation=0 | tuple-ids=2 row-size=33B cardinality=4690314 | in pipelines: 00(GETNEXT) | F02:PLAN FRAGMENT [HASH(l_orderkey)] hosts=3 instances=3 -Per-Host Resources: mem-estimate=72.12MB mem-reservation=52.00MB thread-reservation=1 runtime-filters-memory=1.00MB +Per-Host Resources: mem-estimate=92.22MB mem-reservation=52.00MB thread-reservation=1 runtime-filters-memory=1.00MB 03:AGGREGATE [STREAMING] | output: count(*) | group by: l_orderkey, o_orderstatus @@ -737,7 +737,7 @@ Per-Host Resources: mem-estimate=72.12MB mem-reservation=52.00MB thread-reservat | in pipelines: 00(GETNEXT), 01(OPEN) | |--05:EXCHANGE [HASH(o_orderkey)] -| | mem-estimate=0B mem-reservation=0B thread-reservation=0 +| | mem-estimate=10.06MB mem-reservation=0B thread-reservation=0 | | tuple-ids=1 row-size=25B cardinality=1500000 | | in pipelines: 01(GETNEXT) | | @@ -754,38 +754,38 @@ Per-Host Resources: mem-estimate=72.12MB mem-reservation=52.00MB thread-reservat | in pipelines: 01(GETNEXT) | 04:EXCHANGE [HASH(l_orderkey)] -| mem-estimate=0B mem-reservation=0B thread-reservation=0 +| mem-estimate=10.04MB mem-reservation=0B thread-reservation=0 | tuple-ids=0 row-size=8B cardinality=6001215 | in pipelines: 00(GETNEXT) | F00:PLAN FRAGMENT [RANDOM] hosts=3 instances=3 Per-Host Resources: mem-estimate=81.00MB mem-reservation=5.00MB thread-reservation=2 runtime-filters-memory=1.00MB 00:SCAN HDFS [tpch_parquet.lineitem, RANDOM] - partitions=1/1 files=3 size=193.71MB + partitions=1/1 files=3 size=193.72MB runtime filters: RF000[bloom] -> l_orderkey stored statistics: - table: rows=6001215 size=193.71MB + table: rows=6001215 size=193.72MB columns: all - extrapolated-rows=disabled max-scan-range-rows=2141802 + extrapolated-rows=disabled max-scan-range-rows=2141530 mem-estimate=80.00MB mem-reservation=4.00MB thread-reservation=1 tuple-ids=0 row-size=8B cardinality=6001215 in pipelines: 00(GETNEXT) ---- PARALLELPLANS Max Per-Host Resource Reservation: Memory=147.00MB Threads=9 -Per-Host Resource Estimates: Memory=363MB +Per-Host Resource Estimates: Memory=414MB F04:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 -| Per-Host Resources: mem-estimate=0B mem-reservation=0B thread-reservation=1 +| Per-Host Resources: mem-estimate=10.22MB mem-reservation=0B thread-reservation=1 PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B thread-reservation=0 | 08:EXCHANGE [UNPARTITIONED] -| mem-estimate=0B mem-reservation=0B thread-reservation=0 +| mem-estimate=10.22MB mem-reservation=0B thread-reservation=0 | tuple-ids=2 row-size=33B cardinality=4690314 | in pipelines: 07(GETNEXT) | F03:PLAN FRAGMENT [HASH(l_orderkey,o_orderstatus)] hosts=3 instances=6 -Per-Host Resources: mem-estimate=34.00MB mem-reservation=34.00MB thread-reservation=2 +Per-Host Resources: mem-estimate=54.43MB mem-reservation=34.00MB thread-reservation=2 07:AGGREGATE [FINALIZE] | output: count:merge(*) | group by: l_orderkey, o_orderstatus @@ -795,12 +795,12 @@ Per-Host Resources: mem-estimate=34.00MB mem-reservation=34.00MB thread-reservat | in pipelines: 07(GETNEXT), 00(OPEN) | 06:EXCHANGE [HASH(l_orderkey,o_orderstatus)] -| mem-estimate=0B mem-reservation=0B thread-reservation=0 +| mem-estimate=10.22MB mem-reservation=0B thread-reservation=0 | tuple-ids=2 row-size=33B cardinality=4690314 | in pipelines: 00(GETNEXT) | F02:PLAN FRAGMENT [HASH(l_orderkey)] hosts=3 instances=6 -Per-Host Resources: mem-estimate=87.00MB mem-reservation=87.00MB thread-reservation=2 runtime-filters-memory=1.00MB +Per-Host Resources: mem-estimate=107.23MB mem-reservation=87.00MB thread-reservation=2 runtime-filters-memory=1.00MB 03:AGGREGATE [STREAMING] | output: count(*) | group by: l_orderkey, o_orderstatus @@ -825,7 +825,7 @@ Per-Host Resources: mem-estimate=87.00MB mem-reservation=87.00MB thread-reservat | | mem-estimate=0B mem-reservation=0B thread-reservation=0 | | | 05:EXCHANGE [HASH(o_orderkey)] -| | mem-estimate=0B mem-reservation=0B thread-reservation=0 +| | mem-estimate=10.11MB mem-reservation=0B thread-reservation=0 | | tuple-ids=1 row-size=25B cardinality=1500000 | | in pipelines: 01(GETNEXT) | | @@ -842,19 +842,19 @@ Per-Host Resources: mem-estimate=87.00MB mem-reservation=87.00MB thread-reservat | in pipelines: 01(GETNEXT) | 04:EXCHANGE [HASH(l_orderkey)] -| mem-estimate=0B mem-reservation=0B thread-reservation=0 +| mem-estimate=10.07MB mem-reservation=0B thread-reservation=0 | tuple-ids=0 row-size=8B cardinality=6001215 | in pipelines: 00(GETNEXT) | F00:PLAN FRAGMENT [RANDOM] hosts=3 instances=6 Per-Host Resources: mem-estimate=162.00MB mem-reservation=10.00MB thread-reservation=2 runtime-filters-memory=1.00MB 00:SCAN HDFS [tpch_parquet.lineitem, RANDOM] - partitions=1/1 files=3 size=193.71MB + partitions=1/1 files=3 size=193.72MB runtime filters: RF000[bloom] -> l_orderkey stored statistics: - table: rows=6001215 size=193.71MB + table: rows=6001215 size=193.72MB columns: all - extrapolated-rows=disabled max-scan-range-rows=2141802 + extrapolated-rows=disabled max-scan-range-rows=2141530 mem-estimate=80.00MB mem-reservation=4.00MB thread-reservation=0 tuple-ids=0 row-size=8B cardinality=6001215 in pipelines: 00(GETNEXT) @@ -864,20 +864,20 @@ select distinct * from tpch_parquet.lineitem ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=108.00MB Threads=4 -Per-Host Resource Estimates: Memory=3.31GB +Per-Host Resource Estimates: Memory=3.33GB F02:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 -| Per-Host Resources: mem-estimate=0B mem-reservation=0B thread-reservation=1 +| Per-Host Resources: mem-estimate=10.78MB mem-reservation=0B thread-reservation=1 PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B thread-reservation=0 | 04:EXCHANGE [UNPARTITIONED] -| mem-estimate=0B mem-reservation=0B thread-reservation=0 +| mem-estimate=10.78MB mem-reservation=0B thread-reservation=0 | tuple-ids=1 row-size=263B cardinality=6001215 | in pipelines: 03(GETNEXT) | 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=34.00MB thread-reservation=1 +Per-Host Resources: mem-estimate=1.63GB mem-reservation=34.00MB thread-reservation=1 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=34.00MB spill-buffer=2.00MB thread-reservation=0 @@ -885,7 +885,7 @@ Per-Host Resources: mem-estimate=1.62GB mem-reservation=34.00MB thread-reservati | in pipelines: 03(GETNEXT), 00(OPEN) | 02:EXCHANGE [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)] -| mem-estimate=0B mem-reservation=0B thread-reservation=0 +| mem-estimate=10.78MB mem-reservation=0B thread-reservation=0 | tuple-ids=1 row-size=263B cardinality=6001215 | in pipelines: 00(GETNEXT) | @@ -898,30 +898,30 @@ Per-Host Resources: mem-estimate=1.69GB mem-reservation=74.00MB thread-reservati | in pipelines: 00(GETNEXT) | 00:SCAN HDFS [tpch_parquet.lineitem, RANDOM] - partitions=1/1 files=3 size=193.71MB + partitions=1/1 files=3 size=193.72MB stored statistics: - table: rows=6001215 size=193.71MB + table: rows=6001215 size=193.72MB columns: all - extrapolated-rows=disabled max-scan-range-rows=2141802 + extrapolated-rows=disabled max-scan-range-rows=2141530 mem-estimate=80.00MB mem-reservation=40.00MB thread-reservation=1 tuple-ids=0 row-size=263B cardinality=6001215 in pipelines: 00(GETNEXT) ---- PARALLELPLANS Max Per-Host Resource Reservation: Memory=216.00MB Threads=5 -Per-Host Resource Estimates: Memory=6.62GB +Per-Host Resource Estimates: Memory=6.65GB F02:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 -| Per-Host Resources: mem-estimate=0B mem-reservation=0B thread-reservation=1 +| Per-Host Resources: mem-estimate=11.56MB mem-reservation=0B thread-reservation=1 PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B thread-reservation=0 | 04:EXCHANGE [UNPARTITIONED] -| mem-estimate=0B mem-reservation=0B thread-reservation=0 +| mem-estimate=11.56MB mem-reservation=0B thread-reservation=0 | tuple-ids=1 row-size=263B cardinality=6001215 | in pipelines: 03(GETNEXT) | 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=68.00MB thread-reservation=2 +Per-Host Resources: mem-estimate=3.25GB mem-reservation=68.00MB thread-reservation=2 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=34.00MB spill-buffer=2.00MB thread-reservation=0 @@ -929,7 +929,7 @@ Per-Host Resources: mem-estimate=3.23GB mem-reservation=68.00MB thread-reservati | in pipelines: 03(GETNEXT), 00(OPEN) | 02:EXCHANGE [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)] -| mem-estimate=0B mem-reservation=0B thread-reservation=0 +| mem-estimate=11.56MB mem-reservation=0B thread-reservation=0 | tuple-ids=1 row-size=263B cardinality=6001215 | in pipelines: 00(GETNEXT) | @@ -942,11 +942,11 @@ Per-Host Resources: mem-estimate=3.39GB mem-reservation=148.00MB thread-reservat | in pipelines: 00(GETNEXT) | 00:SCAN HDFS [tpch_parquet.lineitem, RANDOM] - partitions=1/1 files=3 size=193.71MB + partitions=1/1 files=3 size=193.72MB stored statistics: - table: rows=6001215 size=193.71MB + table: rows=6001215 size=193.72MB columns: all - extrapolated-rows=disabled max-scan-range-rows=2141802 + extrapolated-rows=disabled max-scan-range-rows=2141530 mem-estimate=80.00MB mem-reservation=40.00MB thread-reservation=0 tuple-ids=0 row-size=263B cardinality=6001215 in pipelines: 00(GETNEXT) @@ -962,17 +962,17 @@ 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 thread-reservation=1 +| Per-Host Resources: mem-estimate=83.99KB mem-reservation=0B thread-reservation=1 PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B thread-reservation=0 | 04:EXCHANGE [UNPARTITIONED] -| mem-estimate=0B mem-reservation=0B thread-reservation=0 +| mem-estimate=83.99KB mem-reservation=0B thread-reservation=0 | tuple-ids=1 row-size=24B cardinality=unavailable | in pipelines: 03(GETNEXT) | F01:PLAN FRAGMENT [HASH(string_col)] hosts=3 instances=3 -Per-Host Resources: mem-estimate=128.00MB mem-reservation=34.00MB thread-reservation=1 +Per-Host Resources: mem-estimate=128.08MB mem-reservation=34.00MB thread-reservation=1 03:AGGREGATE [FINALIZE] | output: count:merge(*) | group by: string_col @@ -981,7 +981,7 @@ Per-Host Resources: mem-estimate=128.00MB mem-reservation=34.00MB thread-reserva | in pipelines: 03(GETNEXT), 00(OPEN) | 02:EXCHANGE [HASH(string_col)] -| mem-estimate=0B mem-reservation=0B thread-reservation=0 +| mem-estimate=83.99KB mem-reservation=0B thread-reservation=0 | tuple-ids=1 row-size=24B cardinality=unavailable | in pipelines: 00(GETNEXT) | @@ -1011,17 +1011,17 @@ 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 thread-reservation=1 +| Per-Host Resources: mem-estimate=167.99KB mem-reservation=0B thread-reservation=1 PLAN-ROOT SINK | mem-estimate=0B mem-reservation=0B thread-reservation=0 | 04:EXCHANGE [UNPARTITIONED] -| mem-estimate=0B mem-reservation=0B thread-reservation=0 +| mem-estimate=167.99KB mem-reservation=0B thread-reservation=0 | tuple-ids=1 row-size=24B cardinality=unavailable | in pipelines: 03(GETNEXT) | F01:PLAN FRAGMENT [HASH(string_col)] hosts=3 instances=6 -Per-Host Resources: mem-estimate=256.00MB mem-reservation=68.00MB thread-reservation=2 +Per-Host Resources: mem-estimate=256.33MB mem-reservation=68.00MB thread-reservation=2 03:AGGREGATE [FINALIZE] | output: count:merge(*) | group by: string_col @@ -1030,7 +1030,7 @@ Per-Host Resources: mem-estimate=256.00MB mem-reservation=68.00MB thread-reserva | in pipelines: 03(GETNEXT), 00(OPEN) | 02:EXCHANGE [HASH(string_col)] -| mem-estimate=0B mem-reservation=0B thread-reservation=0 +| mem-estimate=167.99KB mem-reservation=0B thread-reservation=0 | tuple-ids=1 row-size=24B cardinality=unavailable | in pipelines: 00(GETNEXT) |
http://git-wip-us.apache.org/repos/asf/impala/blob/8cbec20e/testdata/workloads/functional-planner/queries/PlannerTest/tpcds-all.test ---------------------------------------------------------------------- diff --git a/testdata/workloads/functional-planner/queries/PlannerTest/tpcds-all.test b/testdata/workloads/functional-planner/queries/PlannerTest/tpcds-all.test index 6cdb497..133613f 100644 --- a/testdata/workloads/functional-planner/queries/PlannerTest/tpcds-all.test +++ b/testdata/workloads/functional-planner/queries/PlannerTest/tpcds-all.test @@ -102,7 +102,7 @@ PLAN-ROOT SINK runtime filters: RF000 -> store_sales.ss_sold_date_sk, RF002 -> store_sales.ss_item_sk ---- PARALLELPLANS Max Per-Host Resource Reservation: Memory=69.62MB Threads=11 -Per-Host Resource Estimates: Memory=166MB +Per-Host Resource Estimates: Memory=168MB PLAN-ROOT SINK | 12:MERGING-EXCHANGE [UNPARTITIONED] @@ -233,7 +233,7 @@ PLAN-ROOT SINK runtime filters: RF000 -> ss_item_sk, RF002 -> ss_promo_sk, RF004 -> ss_cdemo_sk, RF006 -> ss_sold_date_sk ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=54.31MB Threads=12 -Per-Host Resource Estimates: Memory=454MB +Per-Host Resource Estimates: Memory=461MB PLAN-ROOT SINK | 17:MERGING-EXCHANGE [UNPARTITIONED] @@ -297,7 +297,7 @@ PLAN-ROOT SINK runtime filters: RF000 -> ss_item_sk, RF002 -> ss_promo_sk, RF004 -> ss_cdemo_sk, RF006 -> ss_sold_date_sk ---- PARALLELPLANS Max Per-Host Resource Reservation: Memory=108.62MB Threads=13 -Per-Host Resource Estimates: Memory=397MB +Per-Host Resource Estimates: Memory=398MB PLAN-ROOT SINK | 17:MERGING-EXCHANGE [UNPARTITIONED] @@ -500,7 +500,7 @@ PLAN-ROOT SINK runtime filters: RF002 -> store_sales.ss_store_sk ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=47.07MB Threads=13 -Per-Host Resource Estimates: Memory=327MB +Per-Host Resource Estimates: Memory=328MB PLAN-ROOT SINK | 20:MERGING-EXCHANGE [UNPARTITIONED] @@ -763,7 +763,7 @@ PLAN-ROOT SINK runtime filters: RF002 -> ca_address_sk ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=54.13MB Threads=16 -Per-Host Resource Estimates: Memory=358MB +Per-Host Resource Estimates: Memory=360MB PLAN-ROOT SINK | 22:MERGING-EXCHANGE [UNPARTITIONED] @@ -841,7 +841,7 @@ PLAN-ROOT SINK runtime filters: RF000 -> ss_store_sk, RF004 -> ss_customer_sk, RF006 -> ss_sold_date_sk, RF008 -> ss_item_sk ---- PARALLELPLANS Max Per-Host Resource Reservation: Memory=108.27MB Threads=19 -Per-Host Resource Estimates: Memory=299MB +Per-Host Resource Estimates: Memory=303MB PLAN-ROOT SINK | 22:MERGING-EXCHANGE [UNPARTITIONED] @@ -1017,7 +1017,7 @@ PLAN-ROOT SINK runtime filters: RF000 -> ss_item_sk, RF002 -> ss_store_sk, RF004 -> ss_cdemo_sk, RF006 -> ss_sold_date_sk ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=54.26MB Threads=12 -Per-Host Resource Estimates: Memory=454MB +Per-Host Resource Estimates: Memory=462MB PLAN-ROOT SINK | 17:MERGING-EXCHANGE [UNPARTITIONED] @@ -1081,7 +1081,7 @@ PLAN-ROOT SINK runtime filters: RF000 -> ss_item_sk, RF002 -> ss_store_sk, RF004 -> ss_cdemo_sk, RF006 -> ss_sold_date_sk ---- PARALLELPLANS Max Per-Host Resource Reservation: Memory=108.52MB Threads=13 -Per-Host Resource Estimates: Memory=397MB +Per-Host Resource Estimates: Memory=398MB PLAN-ROOT SINK | 17:MERGING-EXCHANGE [UNPARTITIONED] @@ -1254,7 +1254,7 @@ PLAN-ROOT SINK runtime filters: RF000 -> c_customer_sk ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=56.01MB Threads=13 -Per-Host Resource Estimates: Memory=339MB +Per-Host Resource Estimates: Memory=348MB PLAN-ROOT SINK | 18:MERGING-EXCHANGE [UNPARTITIONED] @@ -1321,7 +1321,7 @@ PLAN-ROOT SINK runtime filters: RF000 -> tpcds.store_sales.ss_customer_sk, RF002 -> store_sales.ss_store_sk, RF004 -> store_sales.ss_sold_date_sk, RF006 -> store_sales.ss_hdemo_sk ---- PARALLELPLANS Max Per-Host Resource Reservation: Memory=95.02MB Threads=15 -Per-Host Resource Estimates: Memory=276MB +Per-Host Resource Estimates: Memory=291MB PLAN-ROOT SINK | 18:MERGING-EXCHANGE [UNPARTITIONED] @@ -1838,7 +1838,7 @@ PLAN-ROOT SINK runtime filters: RF002 -> tpcds.store_sales.ss_customer_sk, RF004 -> store_sales.ss_addr_sk, RF006 -> store_sales.ss_store_sk, RF008 -> store_sales.ss_sold_date_sk, RF010 -> store_sales.ss_hdemo_sk ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=130.70MB Threads=17 -Per-Host Resource Estimates: Memory=442MB +Per-Host Resource Estimates: Memory=462MB PLAN-ROOT SINK | 24:MERGING-EXCHANGE [UNPARTITIONED] @@ -1924,7 +1924,7 @@ PLAN-ROOT SINK runtime filters: RF002 -> tpcds.store_sales.ss_customer_sk, RF004 -> store_sales.ss_addr_sk, RF006 -> store_sales.ss_store_sk, RF008 -> store_sales.ss_sold_date_sk, RF010 -> store_sales.ss_hdemo_sk ---- PARALLELPLANS Max Per-Host Resource Reservation: Memory=259.52MB Threads=19 -Per-Host Resource Estimates: Memory=435MB +Per-Host Resource Estimates: Memory=458MB PLAN-ROOT SINK | 24:MERGING-EXCHANGE [UNPARTITIONED] @@ -2136,7 +2136,7 @@ PLAN-ROOT SINK runtime filters: RF000 -> store_sales.ss_sold_date_sk, RF002 -> store_sales.ss_item_sk ---- PARALLELPLANS Max Per-Host Resource Reservation: Memory=67.62MB Threads=9 -Per-Host Resource Estimates: Memory=164MB +Per-Host Resource Estimates: Memory=165MB PLAN-ROOT SINK | 11:MERGING-EXCHANGE [UNPARTITIONED] @@ -2689,7 +2689,7 @@ PLAN-ROOT SINK runtime filters: RF004 -> tpcds.store_sales.ss_store_sk, RF008 -> ss_sold_date_sk ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=106.89MB Threads=20 -Per-Host Resource Estimates: Memory=589MB +Per-Host Resource Estimates: Memory=606MB PLAN-ROOT SINK | 30:MERGING-EXCHANGE [UNPARTITIONED] @@ -2796,7 +2796,7 @@ PLAN-ROOT SINK runtime filters: RF004 -> tpcds.store_sales.ss_store_sk, RF008 -> ss_sold_date_sk ---- PARALLELPLANS Max Per-Host Resource Reservation: Memory=210.03MB Threads=23 -Per-Host Resource Estimates: Memory=470MB +Per-Host Resource Estimates: Memory=491MB PLAN-ROOT SINK | 30:MERGING-EXCHANGE [UNPARTITIONED] @@ -3275,7 +3275,7 @@ PLAN-ROOT SINK runtime filters: RF000 -> tpcds.store_sales.ss_store_sk, RF002 -> tpcds.store_sales.ss_item_sk, RF004 -> tpcds.store_sales.ss_store_sk, RF006 -> ss_sold_date_sk ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=76.51MB Threads=17 -Per-Host Resource Estimates: Memory=495MB +Per-Host Resource Estimates: Memory=502MB PLAN-ROOT SINK | 27:MERGING-EXCHANGE [UNPARTITIONED] @@ -3372,7 +3372,7 @@ PLAN-ROOT SINK runtime filters: RF000 -> tpcds.store_sales.ss_store_sk, RF002 -> tpcds.store_sales.ss_item_sk, RF004 -> tpcds.store_sales.ss_store_sk, RF006 -> ss_sold_date_sk ---- PARALLELPLANS Max Per-Host Resource Reservation: Memory=153.02MB Threads=21 -Per-Host Resource Estimates: Memory=381MB +Per-Host Resource Estimates: Memory=392MB PLAN-ROOT SINK | 27:MERGING-EXCHANGE [UNPARTITIONED] @@ -3601,7 +3601,7 @@ PLAN-ROOT SINK runtime filters: RF002 -> tpcds.store_sales.ss_customer_sk, RF004 -> store_sales.ss_addr_sk, RF006 -> store_sales.ss_store_sk, RF008 -> store_sales.ss_sold_date_sk, RF010 -> store_sales.ss_hdemo_sk ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=136.32MB Threads=16 -Per-Host Resource Estimates: Memory=511MB +Per-Host Resource Estimates: Memory=530MB PLAN-ROOT SINK | 23:MERGING-EXCHANGE [UNPARTITIONED] @@ -3685,7 +3685,7 @@ PLAN-ROOT SINK runtime filters: RF002 -> tpcds.store_sales.ss_customer_sk, RF004 -> store_sales.ss_addr_sk, RF006 -> store_sales.ss_store_sk, RF008 -> store_sales.ss_sold_date_sk, RF010 -> store_sales.ss_hdemo_sk ---- PARALLELPLANS Max Per-Host Resource Reservation: Memory=272.64MB Threads=17 -Per-Host Resource Estimates: Memory=574MB +Per-Host Resource Estimates: Memory=596MB PLAN-ROOT SINK | 23:MERGING-EXCHANGE [UNPARTITIONED] @@ -3879,7 +3879,7 @@ PLAN-ROOT SINK runtime filters: RF000 -> c_customer_sk ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=61.82MB Threads=13 -Per-Host Resource Estimates: Memory=336MB +Per-Host Resource Estimates: Memory=347MB PLAN-ROOT SINK | 18:MERGING-EXCHANGE [UNPARTITIONED] @@ -3945,7 +3945,7 @@ PLAN-ROOT SINK runtime filters: RF000 -> tpcds.store_sales.ss_customer_sk, RF002 -> store_sales.ss_store_sk, RF004 -> store_sales.ss_sold_date_sk, RF006 -> store_sales.ss_hdemo_sk ---- PARALLELPLANS Max Per-Host Resource Reservation: Memory=106.64MB Threads=15 -Per-Host Resource Estimates: Memory=271MB +Per-Host Resource Estimates: Memory=290MB PLAN-ROOT SINK | 18:MERGING-EXCHANGE [UNPARTITIONED] @@ -4118,7 +4118,7 @@ PLAN-ROOT SINK runtime filters: RF000 -> c_customer_sk ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=53.32MB Threads=13 -Per-Host Resource Estimates: Memory=327MB +Per-Host Resource Estimates: Memory=335MB PLAN-ROOT SINK | 18:MERGING-EXCHANGE [UNPARTITIONED] @@ -4184,7 +4184,7 @@ PLAN-ROOT SINK runtime filters: RF000 -> tpcds.store_sales.ss_customer_sk, RF002 -> store_sales.ss_sold_date_sk, RF004 -> store_sales.ss_store_sk, RF006 -> store_sales.ss_hdemo_sk ---- PARALLELPLANS Max Per-Host Resource Reservation: Memory=99.14MB Threads=15 -Per-Host Resource Estimates: Memory=263MB +Per-Host Resource Estimates: Memory=275MB PLAN-ROOT SINK | 18:MERGING-EXCHANGE [UNPARTITIONED] @@ -4707,7 +4707,7 @@ PLAN-ROOT SINK runtime filters: RF002 -> i_item_sk ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=58.81MB Threads=9 -Per-Host Resource Estimates: Memory=253MB +Per-Host Resource Estimates: Memory=255MB PLAN-ROOT SINK | 14:MERGING-EXCHANGE [UNPARTITIONED] @@ -4761,7 +4761,7 @@ PLAN-ROOT SINK runtime filters: RF000 -> ss_sold_date_sk, RF002 -> ss_item_sk ---- PARALLELPLANS Max Per-Host Resource Reservation: Memory=115.75MB Threads=11 -Per-Host Resource Estimates: Memory=200MB +Per-Host Resource Estimates: Memory=203MB PLAN-ROOT SINK | 14:MERGING-EXCHANGE [UNPARTITIONED] @@ -4921,7 +4921,7 @@ PLAN-ROOT SINK runtime filters: RF004 -> s.ss_item_sk, RF006 -> s.ss_sold_date_sk, RF010 -> s.ss_customer_sk ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=89.38MB Threads=19 -Per-Host Resource Estimates: Memory=450MB +Per-Host Resource Estimates: Memory=453MB PLAN-ROOT SINK | 30:MERGING-EXCHANGE [UNPARTITIONED] @@ -5350,7 +5350,7 @@ PLAN-ROOT SINK runtime filters: RF000 -> ss_store_sk, RF002 -> ss_item_sk, RF004 -> ss_sold_date_sk ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=393.21MB Threads=29 -Per-Host Resource Estimates: Memory=1.33GB +Per-Host Resource Estimates: Memory=1.35GB PLAN-ROOT SINK | 54:MERGING-EXCHANGE [UNPARTITIONED] @@ -5536,7 +5536,7 @@ PLAN-ROOT SINK runtime filters: RF000 -> ss_store_sk, RF002 -> ss_item_sk, RF004 -> ss_sold_date_sk ---- PARALLELPLANS Max Per-Host Resource Reservation: Memory=752.42MB Threads=33 -Per-Host Resource Estimates: Memory=1.33GB +Per-Host Resource Estimates: Memory=1.35GB PLAN-ROOT SINK | 54:MERGING-EXCHANGE [UNPARTITIONED] @@ -5918,7 +5918,7 @@ PLAN-ROOT SINK runtime filters: RF010 -> ss_sold_date_sk, RF008 -> ss_item_sk, RF006 -> ss_promo_sk, RF002 -> ss_customer_sk, RF004 -> ss_store_sk ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=121.39MB Threads=30 -Per-Host Resource Estimates: Memory=753MB +Per-Host Resource Estimates: Memory=755MB PLAN-ROOT SINK | 27:SORT @@ -6066,7 +6066,7 @@ PLAN-ROOT SINK runtime filters: RF010 -> ss_sold_date_sk, RF008 -> ss_item_sk, RF006 -> ss_promo_sk, RF002 -> ss_customer_sk, RF004 -> ss_store_sk ---- PARALLELPLANS Max Per-Host Resource Reservation: Memory=236.78MB Threads=32 -Per-Host Resource Estimates: Memory=617MB +Per-Host Resource Estimates: Memory=622MB PLAN-ROOT SINK | 27:SORT http://git-wip-us.apache.org/repos/asf/impala/blob/8cbec20e/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 510b47b..080e84a 100644 --- a/testdata/workloads/functional-planner/queries/PlannerTest/tpch-all.test +++ b/testdata/workloads/functional-planner/queries/PlannerTest/tpch-all.test @@ -212,7 +212,7 @@ PLAN-ROOT SINK runtime filters: RF000 -> tpch.partsupp.ps_partkey, RF008 -> ps_suppkey ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=65.28MB Threads=21 -Per-Host Resource Estimates: Memory=656MB +Per-Host Resource Estimates: Memory=662MB PLAN-ROOT SINK | 30:MERGING-EXCHANGE [UNPARTITIONED] @@ -319,7 +319,7 @@ PLAN-ROOT SINK runtime filters: RF000 -> tpch.partsupp.ps_partkey, RF008 -> ps_suppkey ---- PARALLELPLANS Max Per-Host Resource Reservation: Memory=126.81MB Threads=23 -Per-Host Resource Estimates: Memory=703MB +Per-Host Resource Estimates: Memory=713MB PLAN-ROOT SINK | 30:MERGING-EXCHANGE [UNPARTITIONED] @@ -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=537MB +Per-Host Resource Estimates: Memory=546MB PLAN-ROOT SINK | 11:MERGING-EXCHANGE [UNPARTITIONED] @@ -564,7 +564,7 @@ PLAN-ROOT SINK runtime filters: RF002 -> l_orderkey ---- PARALLELPLANS Max Per-Host Resource Reservation: Memory=82.75MB Threads=9 -Per-Host Resource Estimates: Memory=483MB +Per-Host Resource Estimates: Memory=484MB PLAN-ROOT SINK | 11:MERGING-EXCHANGE [UNPARTITIONED] @@ -667,7 +667,7 @@ PLAN-ROOT SINK runtime filters: RF000 -> l_orderkey ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=42.44MB Threads=7 -Per-Host Resource Estimates: Memory=482MB +Per-Host Resource Estimates: Memory=497MB PLAN-ROOT SINK | 09:MERGING-EXCHANGE [UNPARTITIONED] @@ -704,7 +704,7 @@ PLAN-ROOT SINK runtime filters: RF000 -> l_orderkey ---- PARALLELPLANS Max Per-Host Resource Reservation: Memory=77.38MB Threads=9 -Per-Host Resource Estimates: Memory=430MB +Per-Host Resource Estimates: Memory=450MB 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=660MB +Per-Host Resource Estimates: Memory=668MB PLAN-ROOT SINK | 20:MERGING-EXCHANGE [UNPARTITIONED] @@ -1149,7 +1149,7 @@ PLAN-ROOT SINK runtime filters: RF006 -> l_suppkey, RF008 -> l_orderkey ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=103.95MB Threads=15 -Per-Host Resource Estimates: Memory=689MB +Per-Host Resource Estimates: Memory=723MB PLAN-ROOT SINK | 21:MERGING-EXCHANGE [UNPARTITIONED] @@ -1225,7 +1225,7 @@ PLAN-ROOT SINK runtime filters: RF006 -> l_suppkey, RF008 -> l_orderkey ---- PARALLELPLANS Max Per-Host Resource Reservation: Memory=194.78MB Threads=17 -Per-Host Resource Estimates: Memory=683MB +Per-Host Resource Estimates: Memory=716MB PLAN-ROOT SINK | 21:MERGING-EXCHANGE [UNPARTITIONED] @@ -1432,7 +1432,7 @@ PLAN-ROOT SINK runtime filters: RF004 -> c_nationkey, RF006 -> c_custkey ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=73.34MB Threads=21 -Per-Host Resource Estimates: Memory=751MB +Per-Host Resource Estimates: Memory=759MB PLAN-ROOT SINK | 29:MERGING-EXCHANGE [UNPARTITIONED] @@ -1532,7 +1532,7 @@ PLAN-ROOT SINK 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=715MB +Per-Host Resource Estimates: Memory=726MB PLAN-ROOT SINK | 29:MERGING-EXCHANGE [UNPARTITIONED] @@ -1747,7 +1747,7 @@ PLAN-ROOT SINK 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=864MB +Per-Host Resource Estimates: Memory=896MB PLAN-ROOT SINK | 21:MERGING-EXCHANGE [UNPARTITIONED] @@ -1821,7 +1821,7 @@ PLAN-ROOT SINK 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=862MB +Per-Host Resource Estimates: Memory=884MB 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=701MB 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=231.89MB Threads=13 -Per-Host Resource Estimates: Memory=697MB +Per-Host Resource Estimates: Memory=741MB PLAN-ROOT SINK | 15:MERGING-EXCHANGE [UNPARTITIONED] @@ -2211,7 +2211,7 @@ PLAN-ROOT SINK runtime filters: RF002 -> ps_suppkey ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=43.70MB Threads=15 -Per-Host Resource Estimates: Memory=540MB +Per-Host Resource Estimates: Memory=541MB PLAN-ROOT SINK | 23:MERGING-EXCHANGE [UNPARTITIONED] @@ -2447,7 +2447,7 @@ PLAN-ROOT SINK runtime filters: RF000 -> o_orderkey ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=67.94MB Threads=7 -Per-Host Resource Estimates: Memory=508MB +Per-Host Resource Estimates: Memory=528MB PLAN-ROOT SINK | 09:MERGING-EXCHANGE [UNPARTITIONED] @@ -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=454MB +Per-Host Resource Estimates: Memory=475MB PLAN-ROOT SINK | 09:MERGING-EXCHANGE [UNPARTITIONED] @@ -2573,7 +2573,7 @@ PLAN-ROOT SINK runtime filters: RF000 -> o_custkey ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=41.38MB Threads=7 -Per-Host Resource Estimates: Memory=281MB +Per-Host Resource Estimates: Memory=289MB PLAN-ROOT SINK | 10:MERGING-EXCHANGE [UNPARTITIONED] @@ -2613,7 +2613,7 @@ PLAN-ROOT SINK runtime filters: RF000 -> o_custkey ---- PARALLELPLANS Max Per-Host Resource Reservation: Memory=77.12MB Threads=9 -Per-Host Resource Estimates: Memory=320MB +Per-Host Resource Estimates: Memory=334MB PLAN-ROOT SINK | 10:MERGING-EXCHANGE [UNPARTITIONED] @@ -2692,7 +2692,7 @@ PLAN-ROOT SINK runtime filters: RF000 -> l_partkey ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=22.75MB Threads=6 -Per-Host Resource Estimates: Memory=355MB +Per-Host Resource Estimates: Memory=364MB PLAN-ROOT SINK | 07: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=280MB +Per-Host Resource Estimates: Memory=299MB PLAN-ROOT SINK | 07:AGGREGATE [FINALIZE] @@ -3018,7 +3018,7 @@ PLAN-ROOT SINK runtime filters: RF000 -> ps_partkey ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=54.56MB Threads=9 -Per-Host Resource Estimates: Memory=329MB +Per-Host Resource Estimates: Memory=334MB PLAN-ROOT SINK | 14:MERGING-EXCHANGE [UNPARTITIONED] @@ -3069,7 +3069,7 @@ PLAN-ROOT SINK runtime filters: RF000 -> ps_partkey ---- PARALLELPLANS Max Per-Host Resource Reservation: Memory=101.38MB Threads=11 -Per-Host Resource Estimates: Memory=386MB +Per-Host Resource Estimates: Memory=393MB PLAN-ROOT SINK | 14:MERGING-EXCHANGE [UNPARTITIONED] @@ -3361,7 +3361,7 @@ PLAN-ROOT SINK runtime filters: RF000 -> tpch.lineitem.l_orderkey, RF004 -> l_orderkey ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=191.12MB Threads=11 -Per-Host Resource Estimates: Memory=996MB +Per-Host Resource Estimates: Memory=1.02GB PLAN-ROOT SINK | 17:MERGING-EXCHANGE [UNPARTITIONED] @@ -3425,7 +3425,7 @@ PLAN-ROOT SINK runtime filters: RF000 -> tpch.lineitem.l_orderkey, RF004 -> l_orderkey ---- PARALLELPLANS Max Per-Host Resource Reservation: Memory=336.88MB Threads=13 -Per-Host Resource Estimates: Memory=991MB +Per-Host Resource Estimates: Memory=1.01GB PLAN-ROOT SINK | 17:MERGING-EXCHANGE [UNPARTITIONED] @@ -3709,7 +3709,7 @@ PLAN-ROOT SINK runtime filters: RF000 -> tpch.lineitem.l_suppkey, RF002 -> tpch.lineitem.l_partkey, RF003 -> tpch.lineitem.l_suppkey ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=124.63MB Threads=13 -Per-Host Resource Estimates: Memory=667MB +Per-Host Resource Estimates: Memory=677MB PLAN-ROOT SINK | 18:MERGING-EXCHANGE [UNPARTITIONED] @@ -3777,7 +3777,7 @@ PLAN-ROOT SINK runtime filters: RF000 -> tpch.lineitem.l_suppkey, RF002 -> tpch.lineitem.l_partkey, RF003 -> tpch.lineitem.l_suppkey ---- PARALLELPLANS Max Per-Host Resource Reservation: Memory=247.39MB Threads=15 -Per-Host Resource Estimates: Memory=675MB +Per-Host Resource Estimates: Memory=691MB PLAN-ROOT SINK | 18:MERGING-EXCHANGE [UNPARTITIONED] @@ -3961,7 +3961,7 @@ PLAN-ROOT SINK predicates: l3.l_receiptdate > l3.l_commitdate ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=56.51MB Threads=15 -Per-Host Resource Estimates: Memory=1.05GB +Per-Host Resource Estimates: Memory=1.08GB PLAN-ROOT SINK | 21:MERGING-EXCHANGE [UNPARTITIONED] @@ -4040,7 +4040,7 @@ PLAN-ROOT SINK predicates: l3.l_receiptdate > l3.l_commitdate ---- PARALLELPLANS Max Per-Host Resource Reservation: Memory=109.27MB Threads=17 -Per-Host Resource Estimates: Memory=841MB +Per-Host Resource Estimates: Memory=863MB PLAN-ROOT SINK | 21:MERGING-EXCHANGE [UNPARTITIONED] @@ -4207,7 +4207,7 @@ PLAN-ROOT SINK partitions=1/1 files=1 size=162.56MB ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=41.88MB Threads=10 -Per-Host Resource Estimates: Memory=358MB +Per-Host Resource Estimates: Memory=365MB PLAN-ROOT SINK | 15:MERGING-EXCHANGE [UNPARTITIONED] @@ -4258,7 +4258,7 @@ PLAN-ROOT SINK partitions=1/1 files=1 size=162.56MB ---- PARALLELPLANS Max Per-Host Resource Reservation: Memory=83.75MB Threads=12 -Per-Host Resource Estimates: Memory=402MB +Per-Host Resource Estimates: Memory=414MB PLAN-ROOT SINK | 15:MERGING-EXCHANGE [UNPARTITIONED] http://git-wip-us.apache.org/repos/asf/impala/blob/8cbec20e/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 e06d87a..7717acf 100644 --- a/testdata/workloads/functional-planner/queries/PlannerTest/tpch-nested.test +++ b/testdata/workloads/functional-planner/queries/PlannerTest/tpch-nested.test @@ -34,11 +34,11 @@ 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.98MB + partitions=1/1 files=4 size=288.99MB predicates: l_shipdate <= '1998-09-02' ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=112.00MB Threads=4 -Per-Host Resource Estimates: Memory=886MB +Per-Host Resource Estimates: Memory=916MB PLAN-ROOT SINK | 05:MERGING-EXCHANGE [UNPARTITIONED] @@ -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.98MB + partitions=1/1 files=4 size=288.99MB 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.36KB +| | partitions=1/1 files=1 size=3.44KB | | 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.36KB +| partitions=1/1 files=1 size=3.44KB | predicates: r_name = 'EUROPE', !empty(r.r_nations) | 23:HASH JOIN [INNER JOIN] @@ -186,7 +186,7 @@ PLAN-ROOT SINK runtime filters: RF004 -> s_nationkey ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=114.73MB Threads=12 -Per-Host Resource Estimates: Memory=1.00GB +Per-Host Resource Estimates: Memory=1.01GB PLAN-ROOT SINK | 33:MERGING-EXCHANGE [UNPARTITIONED] @@ -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.36KB +| | partitions=1/1 files=1 size=3.44KB | | 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.36KB +| partitions=1/1 files=1 size=3.44KB | predicates: r_name = 'EUROPE', !empty(r.r_nations) | 23:HASH JOIN [INNER JOIN, BROADCAST] @@ -336,13 +336,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.98MB + partitions=1/1 files=4 size=288.99MB 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' ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=100.00MB Threads=4 -Per-Host Resource Estimates: Memory=872MB +Per-Host Resource Estimates: Memory=882MB PLAN-ROOT SINK | 13:MERGING-EXCHANGE [UNPARTITIONED] @@ -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.98MB + partitions=1/1 files=4 size=288.99MB 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.98MB + partitions=1/1 files=4 size=288.99MB 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=620MB +Per-Host Resource Estimates: Memory=632MB 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.98MB + partitions=1/1 files=4 size=288.99MB 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.36KB +| partitions=1/1 files=1 size=3.44KB | 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.98MB + partitions=1/1 files=4 size=288.99MB 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.26GB +Per-Host Resource Estimates: Memory=1.29GB 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.36KB +| partitions=1/1 files=1 size=3.44KB | 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.98MB + partitions=1/1 files=4 size=288.99MB 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.98MB + partitions=1/1 files=4 size=288.99MB 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.98MB + partitions=1/1 files=4 size=288.99MB 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.36KB +| partitions=1/1 files=1 size=3.44KB | 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.36KB +| partitions=1/1 files=1 size=3.44KB | 12:HASH JOIN [INNER JOIN] | hash predicates: l_suppkey = s_suppkey @@ -760,14 +760,14 @@ PLAN-ROOT SINK | 03:UNNEST [c.c_orders o] | 00:SCAN HDFS [tpch_nested_parquet.customer c] - partitions=1/1 files=4 size=288.98MB + partitions=1/1 files=4 size=288.99MB 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' runtime filters: RF000 -> c_nationkey ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=112.97MB Threads=10 -Per-Host Resource Estimates: Memory=997MB +Per-Host Resource Estimates: Memory=1.00GB PLAN-ROOT SINK | 22:MERGING-EXCHANGE [UNPARTITIONED] @@ -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.36KB +| partitions=1/1 files=1 size=3.44KB | 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.36KB +| partitions=1/1 files=1 size=3.44KB | 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.98MB + partitions=1/1 files=4 size=288.99MB 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.36KB +| partitions=1/1 files=1 size=3.44KB | 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.36KB +| partitions=1/1 files=1 size=3.44KB | predicates: r_name = 'AMERICA', !empty(r.r_nations) | 18:HASH JOIN [INNER JOIN] @@ -939,13 +939,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.98MB + partitions=1/1 files=4 size=288.99MB 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 ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=110.91MB Threads=12 -Per-Host Resource Estimates: Memory=1.01GB +Per-Host Resource Estimates: Memory=1.04GB PLAN-ROOT SINK | 29:MERGING-EXCHANGE [UNPARTITIONED] @@ -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.36KB +| partitions=1/1 files=1 size=3.44KB | 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.36KB +| partitions=1/1 files=1 size=3.44KB | 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.98MB + partitions=1/1 files=4 size=288.99MB 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 @@ -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.36KB +| partitions=1/1 files=1 size=3.44KB | 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.98MB + partitions=1/1 files=4 size=288.99MB predicates: !empty(o.o_lineitems) ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=143.33MB Threads=10 -Per-Host Resource Estimates: Memory=1.09GB +Per-Host Resource Estimates: Memory=1.12GB 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.36KB +| partitions=1/1 files=1 size=3.44KB | 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.98MB + partitions=1/1 files=4 size=288.99MB 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.36KB +| partitions=1/1 files=1 size=3.44KB | 01:SUBPLAN | @@ -1253,14 +1253,14 @@ PLAN-ROOT SINK | 03:UNNEST [c.c_orders o] | 00:SCAN HDFS [tpch_nested_parquet.customer c] - partitions=1/1 files=4 size=288.98MB + partitions=1/1 files=4 size=288.99MB 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' runtime filters: RF000 -> c_nationkey ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=94.95MB Threads=6 -Per-Host Resource Estimates: Memory=995MB +Per-Host Resource Estimates: Memory=1006MB PLAN-ROOT SINK | 16:MERGING-EXCHANGE [UNPARTITIONED] @@ -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.36KB +| partitions=1/1 files=1 size=3.44KB | 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.98MB + partitions=1/1 files=4 size=288.99MB 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.36KB +| | partitions=1/1 files=1 size=3.44KB | | 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.36KB +| partitions=1/1 files=1 size=3.44KB | predicates: n_name = 'GERMANY' | 01:SUBPLAN @@ -1406,7 +1406,7 @@ PLAN-ROOT SINK runtime filters: RF000 -> s_nationkey ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=111.91MB Threads=11 -Per-Host Resource Estimates: Memory=744MB +Per-Host Resource Estimates: Memory=746MB PLAN-ROOT SINK | 25:MERGING-EXCHANGE [UNPARTITIONED] @@ -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.36KB +| | partitions=1/1 files=1 size=3.44KB | | 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.36KB +| partitions=1/1 files=1 size=3.44KB | predicates: n_name = 'GERMANY' | 01:SUBPLAN @@ -1534,12 +1534,12 @@ 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.98MB + partitions=1/1 files=4 size=288.99MB 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 Max Per-Host Resource Reservation: Memory=104.00MB Threads=4 -Per-Host Resource Estimates: Memory=718MB +Per-Host Resource Estimates: Memory=748MB PLAN-ROOT SINK | 09:MERGING-EXCHANGE [UNPARTITIONED] @@ -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.98MB + partitions=1/1 files=4 size=288.99MB 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,11 +1617,11 @@ PLAN-ROOT SINK | 03:UNNEST [c.c_orders] | 00:SCAN HDFS [tpch_nested_parquet.customer c] - partitions=1/1 files=4 size=288.98MB + partitions=1/1 files=4 size=288.99MB predicates on c_orders: (NOT o_comment LIKE '%special%requests%') ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=96.94MB Threads=5 -Per-Host Resource Estimates: Memory=546MB +Per-Host Resource Estimates: Memory=548MB PLAN-ROOT SINK | 12:MERGING-EXCHANGE [UNPARTITIONED] @@ -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.98MB + partitions=1/1 files=4 size=288.99MB predicates on c_orders: (NOT o_comment LIKE '%special%requests%') ==== # TPCH-Q14 @@ -1693,7 +1693,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.98MB + partitions=1/1 files=4 size=288.99MB predicates: l_shipdate < '1995-10-01', l_shipdate >= '1995-09-01' runtime filters: RF000 -> l_partkey ---- DISTRIBUTEDPLAN @@ -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.98MB + partitions=1/1 files=4 size=288.99MB predicates: l_shipdate < '1995-10-01', l_shipdate >= '1995-09-01' runtime filters: RF000 -> l_partkey ==== @@ -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.98MB +| partitions=1/1 files=4 size=288.99MB | predicates: l_shipdate < '1996-04-01', l_shipdate >= '1996-01-01' | 06:HASH JOIN [INNER JOIN] @@ -1789,12 +1789,12 @@ 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.98MB + partitions=1/1 files=4 size=288.99MB predicates: l_shipdate < '1996-04-01', l_shipdate >= '1996-01-01' runtime filters: RF000 -> l.l_suppkey ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=186.88MB Threads=10 -Per-Host Resource Estimates: Memory=1.45GB +Per-Host Resource Estimates: Memory=1.47GB PLAN-ROOT SINK | 17:MERGING-EXCHANGE [UNPARTITIONED] @@ -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.98MB +| partitions=1/1 files=4 size=288.99MB | 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.98MB + partitions=1/1 files=4 size=288.99MB predicates: l_shipdate < '1996-04-01', l_shipdate >= '1996-01-01' runtime filters: RF000 -> l.l_suppkey ==== @@ -1915,7 +1915,7 @@ PLAN-ROOT SINK predicates: NOT s_comment LIKE '%Customer%Complaints%', !empty(s.s_partsupps) ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=31.81MB Threads=7 -Per-Host Resource Estimates: Memory=286MB +Per-Host Resource Estimates: Memory=288MB PLAN-ROOT SINK | 15:MERGING-EXCHANGE [UNPARTITIONED] @@ -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.98MB +| partitions=1/1 files=4 size=288.99MB | 04:HASH JOIN [INNER JOIN] | hash predicates: l_partkey = p_partkey @@ -2012,11 +2012,11 @@ 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.98MB + partitions=1/1 files=4 size=288.99MB runtime filters: RF000 -> l.l_partkey, RF002 -> l_partkey ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=154.94MB Threads=8 -Per-Host Resource Estimates: Memory=865MB +Per-Host Resource Estimates: Memory=875MB PLAN-ROOT SINK | 12:AGGREGATE [FINALIZE] @@ -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.98MB +| partitions=1/1 files=4 size=288.99MB | 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.98MB + partitions=1/1 files=4 size=288.99MB 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.98MB + partitions=1/1 files=4 size=288.99MB 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.98MB + partitions=1/1 files=4 size=288.99MB predicates: !empty(c.c_orders) ==== # TPCH-Q19 @@ -2203,7 +2203,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.98MB + partitions=1/1 files=4 size=288.99MB predicates: l_shipmode IN ('AIR', 'AIR REG'), l_shipinstruct = 'DELIVER IN PERSON' runtime filters: RF000 -> l_partkey ---- DISTRIBUTEDPLAN @@ -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.98MB + partitions=1/1 files=4 size=288.99MB 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.36KB +| | partitions=1/1 files=1 size=3.44KB | | predicates: n_name = 'CANADA' | | | 01:SUBPLAN @@ -2318,12 +2318,12 @@ 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.98MB + partitions=1/1 files=4 size=288.99MB predicates: l_shipdate < '1995-01-01', l_shipdate >= '1994-01-01' runtime filters: RF000 -> l.l_partkey, RF001 -> l.l_suppkey ---- DISTRIBUTEDPLAN Max Per-Host Resource Reservation: Memory=164.33MB Threads=11 -Per-Host Resource Estimates: Memory=1.04GB +Per-Host Resource Estimates: Memory=1.07GB PLAN-ROOT SINK | 21:MERGING-EXCHANGE [UNPARTITIONED] @@ -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.36KB +| | partitions=1/1 files=1 size=3.44KB | | 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.98MB + partitions=1/1 files=4 size=288.99MB 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.36KB +| partitions=1/1 files=1 size=3.44KB | 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.98MB + partitions=1/1 files=4 size=288.99MB 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.36KB +| partitions=1/1 files=1 size=3.44KB | 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.98MB + partitions=1/1 files=4 size=288.99MB predicates: !empty(c.c_orders) predicates on o: !empty(o.o_lineitems), o_orderstatus = 'F' predicates on l1: l1.l_receiptdate > l1.l_commitdate @@ -2636,11 +2636,11 @@ PLAN-ROOT SINK | | output: avg(c_acctbal) | | | 01:SCAN HDFS [tpch_nested_parquet.customer c] -| partitions=1/1 files=4 size=288.98MB +| partitions=1/1 files=4 size=288.99MB | predicates: c_acctbal > 0.00, 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.98MB + partitions=1/1 files=4 size=288.99MB 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 @@ -2685,10 +2685,10 @@ PLAN-ROOT SINK | | output: avg(c_acctbal) | | | 01:SCAN HDFS [tpch_nested_parquet.customer c] -| partitions=1/1 files=4 size=288.98MB +| partitions=1/1 files=4 size=288.99MB | predicates: c_acctbal > 0.00, 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.98MB + partitions=1/1 files=4 size=288.99MB predicates: substr(c_phone, 1, 2) IN ('13', '31', '23', '29', '30', '18', '17') ====
