You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@impala.apache.org by bi...@apache.org on 2018/10/25 23:18:10 UTC
[2/4] impala git commit: IMPALA-7351: Add estimates to Exchange node
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')
====