You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@impala.apache.org by ta...@apache.org on 2018/08/07 17:18:21 UTC
[2/5] impala git commit: IMPALA-7354: planner test resource estimates
for more workloads
http://git-wip-us.apache.org/repos/asf/impala/blob/a8d7a50b/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 31f0738..6cdb497 100644
--- a/testdata/workloads/functional-planner/queries/PlannerTest/tpcds-all.test
+++ b/testdata/workloads/functional-planner/queries/PlannerTest/tpcds-all.test
@@ -23,6 +23,8 @@ order by
brand_id
limit 100
---- PLAN
+Max Per-Host Resource Reservation: Memory=29.88MB Threads=4
+Per-Host Resource Estimates: Memory=214MB
PLAN-ROOT SINK
|
06:TOP-N [LIMIT=100]
@@ -49,9 +51,11 @@ PLAN-ROOT SINK
| predicates: item.i_manufact_id = 436
|
01:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
runtime filters: RF000 -> store_sales.ss_sold_date_sk, RF002 -> store_sales.ss_item_sk
---- DISTRIBUTEDPLAN
+Max Per-Host Resource Reservation: Memory=34.81MB Threads=9
+Per-Host Resource Estimates: Memory=235MB
PLAN-ROOT SINK
|
12:MERGING-EXCHANGE [UNPARTITIONED]
@@ -94,9 +98,11 @@ PLAN-ROOT SINK
| predicates: item.i_manufact_id = 436
|
01:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
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
PLAN-ROOT SINK
|
12:MERGING-EXCHANGE [UNPARTITIONED]
@@ -147,7 +153,7 @@ PLAN-ROOT SINK
| predicates: item.i_manufact_id = 436
|
01:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
runtime filters: RF000 -> store_sales.ss_sold_date_sk, RF002 -> store_sales.ss_item_sk
====
# TPCDS-Q7
@@ -180,6 +186,8 @@ order by
i_item_id
limit 100
---- PLAN
+Max Per-Host Resource Reservation: Memory=50.38MB Threads=6
+Per-Host Resource Estimates: Memory=434MB
PLAN-ROOT SINK
|
10:TOP-N [LIMIT=100]
@@ -221,9 +229,11 @@ PLAN-ROOT SINK
| predicates: d_year = 1998
|
00:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
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
PLAN-ROOT SINK
|
17:MERGING-EXCHANGE [UNPARTITIONED]
@@ -283,9 +293,11 @@ PLAN-ROOT SINK
| predicates: d_year = 1998
|
00:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
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
PLAN-ROOT SINK
|
17:MERGING-EXCHANGE [UNPARTITIONED]
@@ -361,7 +373,7 @@ PLAN-ROOT SINK
| predicates: d_year = 1998
|
00:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
runtime filters: RF000 -> ss_item_sk, RF002 -> ss_promo_sk, RF004 -> ss_cdemo_sk, RF006 -> ss_sold_date_sk
====
# TPCDS-Q8
@@ -434,6 +446,8 @@ order by
s_store_name
limit 100
---- PLAN
+Max Per-Host Resource Reservation: Memory=33.32MB Threads=6
+Per-Host Resource Estimates: Memory=281MB
PLAN-ROOT SINK
|
11:TOP-N [LIMIT=100]
@@ -482,9 +496,11 @@ PLAN-ROOT SINK
| runtime filters: RF000 -> substr(store.s_zip, 1, 2)
|
00:SCAN HDFS [tpcds.store_sales]
- partitions=90/1824 files=90 size=9.71MB
+ partitions=90/1824 files=90 size=10.32MB
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
PLAN-ROOT SINK
|
20:MERGING-EXCHANGE [UNPARTITIONED]
@@ -557,9 +573,11 @@ PLAN-ROOT SINK
| runtime filters: RF000 -> substr(store.s_zip, 1, 2)
|
00:SCAN HDFS [tpcds.store_sales]
- partitions=90/1824 files=90 size=9.71MB
+ partitions=90/1824 files=90 size=10.32MB
runtime filters: RF002 -> store_sales.ss_store_sk
---- PARALLELPLANS
+Max Per-Host Resource Reservation: Memory=94.14MB Threads=15
+Per-Host Resource Estimates: Memory=285MB
PLAN-ROOT SINK
|
20:MERGING-EXCHANGE [UNPARTITIONED]
@@ -648,7 +666,7 @@ PLAN-ROOT SINK
| runtime filters: RF000 -> substr(store.s_zip, 1, 2)
|
00:SCAN HDFS [tpcds.store_sales]
- partitions=90/1824 files=90 size=9.71MB
+ partitions=90/1824 files=90 size=10.32MB
runtime filters: RF002 -> store_sales.ss_store_sk
====
# TPCDS-Q19
@@ -689,6 +707,8 @@ order by
i_manufact
limit 100
---- PLAN
+Max Per-Host Resource Reservation: Memory=43.32MB Threads=7
+Per-Host Resource Estimates: Memory=331MB
PLAN-ROOT SINK
|
12:TOP-N [LIMIT=100]
@@ -731,7 +751,7 @@ PLAN-ROOT SINK
| | | predicates: i_manager_id = 7
| | |
| | 01:SCAN HDFS [tpcds.store_sales]
-| | partitions=30/1824 files=30 size=9.93MB
+| | partitions=30/1824 files=30 size=10.55MB
| | runtime filters: RF000 -> ss_store_sk, RF006 -> ss_sold_date_sk, RF008 -> ss_item_sk
| |
| 03:SCAN HDFS [tpcds.customer]
@@ -742,6 +762,8 @@ PLAN-ROOT SINK
partitions=1/1 files=1 size=5.25MB
runtime filters: RF002 -> ca_address_sk
---- DISTRIBUTEDPLAN
+Max Per-Host Resource Reservation: Memory=54.13MB Threads=16
+Per-Host Resource Estimates: Memory=358MB
PLAN-ROOT SINK
|
22:MERGING-EXCHANGE [UNPARTITIONED]
@@ -815,9 +837,11 @@ PLAN-ROOT SINK
| predicates: i_manager_id = 7
|
01:SCAN HDFS [tpcds.store_sales]
- partitions=30/1824 files=30 size=9.93MB
+ partitions=30/1824 files=30 size=10.55MB
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
PLAN-ROOT SINK
|
22:MERGING-EXCHANGE [UNPARTITIONED]
@@ -911,7 +935,7 @@ PLAN-ROOT SINK
| predicates: i_manager_id = 7
|
01:SCAN HDFS [tpcds.store_sales]
- partitions=30/1824 files=30 size=9.93MB
+ partitions=30/1824 files=30 size=10.55MB
runtime filters: RF000 -> ss_store_sk, RF004 -> ss_customer_sk, RF006 -> ss_sold_date_sk, RF008 -> ss_item_sk
====
# TPCDS-Q27
@@ -946,6 +970,8 @@ order by
s_state
limit 100
---- PLAN
+Max Per-Host Resource Reservation: Memory=50.32MB Threads=6
+Per-Host Resource Estimates: Memory=434MB
PLAN-ROOT SINK
|
10:TOP-N [LIMIT=100]
@@ -987,9 +1013,11 @@ PLAN-ROOT SINK
| predicates: d_year = 1998
|
00:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
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
PLAN-ROOT SINK
|
17:MERGING-EXCHANGE [UNPARTITIONED]
@@ -1049,9 +1077,11 @@ PLAN-ROOT SINK
| predicates: d_year = 1998
|
00:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
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
PLAN-ROOT SINK
|
17:MERGING-EXCHANGE [UNPARTITIONED]
@@ -1127,7 +1157,7 @@ PLAN-ROOT SINK
| predicates: d_year = 1998
|
00:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
runtime filters: RF000 -> ss_item_sk, RF002 -> ss_store_sk, RF004 -> ss_cdemo_sk, RF006 -> ss_sold_date_sk
====
# TPCDS-Q34
@@ -1175,6 +1205,8 @@ order by
c_preferred_cust_flag desc
limit 100000
---- PLAN
+Max Per-Host Resource Reservation: Memory=34.07MB Threads=6
+Per-Host Resource Estimates: Memory=298MB
PLAN-ROOT SINK
|
10:TOP-N [LIMIT=100000]
@@ -1214,13 +1246,15 @@ PLAN-ROOT SINK
| | predicates: household_demographics.hd_vehicle_count > 0, household_demographics.hd_buy_potential IN ('>10000', 'unknown'), (CASE WHEN household_demographics.hd_vehicle_count > 0 THEN household_demographics.hd_dep_count / household_demographics.hd_vehicle_count ELSE NULL END) > 1.2
| |
| 00:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF002 -> store_sales.ss_store_sk, RF004 -> store_sales.ss_sold_date_sk, RF006 -> store_sales.ss_hdemo_sk
|
08:SCAN HDFS [tpcds.customer]
partitions=1/1 files=1 size=12.60MB
runtime filters: RF000 -> c_customer_sk
---- DISTRIBUTEDPLAN
+Max Per-Host Resource Reservation: Memory=56.01MB Threads=13
+Per-Host Resource Estimates: Memory=339MB
PLAN-ROOT SINK
|
18:MERGING-EXCHANGE [UNPARTITIONED]
@@ -1283,9 +1317,11 @@ PLAN-ROOT SINK
| predicates: household_demographics.hd_vehicle_count > 0, household_demographics.hd_buy_potential IN ('>10000', 'unknown'), (CASE WHEN household_demographics.hd_vehicle_count > 0 THEN household_demographics.hd_dep_count / household_demographics.hd_vehicle_count ELSE NULL END) > 1.2
|
00:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
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
PLAN-ROOT SINK
|
18:MERGING-EXCHANGE [UNPARTITIONED]
@@ -1364,7 +1400,7 @@ PLAN-ROOT SINK
| predicates: household_demographics.hd_vehicle_count > 0, household_demographics.hd_buy_potential IN ('>10000', 'unknown'), (CASE WHEN household_demographics.hd_vehicle_count > 0 THEN household_demographics.hd_dep_count / household_demographics.hd_vehicle_count ELSE NULL END) > 1.2
|
00:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
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
====
# TPCDS-Q42
@@ -1394,6 +1430,8 @@ order by
item.i_category
limit 100
---- PLAN
+Max Per-Host Resource Reservation: Memory=29.88MB Threads=4
+Per-Host Resource Estimates: Memory=214MB
PLAN-ROOT SINK
|
06:TOP-N [LIMIT=100]
@@ -1420,9 +1458,11 @@ PLAN-ROOT SINK
| predicates: item.i_manager_id = 1
|
01:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
runtime filters: RF000 -> store_sales.ss_sold_date_sk, RF002 -> store_sales.ss_item_sk
---- DISTRIBUTEDPLAN
+Max Per-Host Resource Reservation: Memory=33.81MB Threads=8
+Per-Host Resource Estimates: Memory=234MB
PLAN-ROOT SINK
|
11:MERGING-EXCHANGE [UNPARTITIONED]
@@ -1463,9 +1503,11 @@ PLAN-ROOT SINK
| predicates: item.i_manager_id = 1
|
01:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
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
PLAN-ROOT SINK
|
11:MERGING-EXCHANGE [UNPARTITIONED]
@@ -1514,7 +1556,7 @@ PLAN-ROOT SINK
| predicates: item.i_manager_id = 1
|
01:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
runtime filters: RF000 -> store_sales.ss_sold_date_sk, RF002 -> store_sales.ss_item_sk
====
# TPCDS-Q43
@@ -1552,6 +1594,8 @@ order by
sat_sales
limit 100
---- PLAN
+Max Per-Host Resource Reservation: Memory=21.88MB Threads=4
+Per-Host Resource Estimates: Memory=214MB
PLAN-ROOT SINK
|
06:TOP-N [LIMIT=100]
@@ -1578,9 +1622,11 @@ PLAN-ROOT SINK
| predicates: d_year = 1998
|
01:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
runtime filters: RF000 -> ss_store_sk, RF002 -> ss_sold_date_sk
---- DISTRIBUTEDPLAN
+Max Per-Host Resource Reservation: Memory=25.82MB Threads=8
+Per-Host Resource Estimates: Memory=234MB
PLAN-ROOT SINK
|
11:MERGING-EXCHANGE [UNPARTITIONED]
@@ -1621,9 +1667,11 @@ PLAN-ROOT SINK
| predicates: d_year = 1998
|
01:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
runtime filters: RF000 -> ss_store_sk, RF002 -> ss_sold_date_sk
---- PARALLELPLANS
+Max Per-Host Resource Reservation: Memory=51.64MB Threads=9
+Per-Host Resource Estimates: Memory=164MB
PLAN-ROOT SINK
|
11:MERGING-EXCHANGE [UNPARTITIONED]
@@ -1672,7 +1720,7 @@ PLAN-ROOT SINK
| predicates: d_year = 1998
|
01:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
runtime filters: RF000 -> ss_store_sk, RF002 -> ss_sold_date_sk
====
# TPCDS-Q46
@@ -1727,6 +1775,8 @@ order by
ss_ticket_number
limit 100
---- PLAN
+Max Per-Host Resource Reservation: Memory=84.06MB Threads=8
+Per-Host Resource Estimates: Memory=378MB
PLAN-ROOT SINK
|
14:TOP-N [LIMIT=100]
@@ -1784,9 +1834,11 @@ PLAN-ROOT SINK
| predicates: (household_demographics.hd_dep_count = 5 OR household_demographics.hd_vehicle_count = 3)
|
00:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
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
PLAN-ROOT SINK
|
24:MERGING-EXCHANGE [UNPARTITIONED]
@@ -1868,9 +1920,11 @@ PLAN-ROOT SINK
| predicates: (household_demographics.hd_dep_count = 5 OR household_demographics.hd_vehicle_count = 3)
|
00:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
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
PLAN-ROOT SINK
|
24:MERGING-EXCHANGE [UNPARTITIONED]
@@ -1976,7 +2030,7 @@ PLAN-ROOT SINK
| predicates: (household_demographics.hd_dep_count = 5 OR household_demographics.hd_vehicle_count = 3)
|
00:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
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
====
# TPCDS-Q52
@@ -2005,6 +2059,8 @@ order by
brand_id
limit 100
---- PLAN
+Max Per-Host Resource Reservation: Memory=29.88MB Threads=4
+Per-Host Resource Estimates: Memory=214MB
PLAN-ROOT SINK
|
06:TOP-N [LIMIT=100]
@@ -2031,9 +2087,11 @@ PLAN-ROOT SINK
| predicates: item.i_manager_id = 1
|
01:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
runtime filters: RF000 -> store_sales.ss_sold_date_sk, RF002 -> store_sales.ss_item_sk
---- DISTRIBUTEDPLAN
+Max Per-Host Resource Reservation: Memory=33.81MB Threads=8
+Per-Host Resource Estimates: Memory=234MB
PLAN-ROOT SINK
|
11:MERGING-EXCHANGE [UNPARTITIONED]
@@ -2074,9 +2132,11 @@ PLAN-ROOT SINK
| predicates: item.i_manager_id = 1
|
01:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
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
PLAN-ROOT SINK
|
11:MERGING-EXCHANGE [UNPARTITIONED]
@@ -2125,7 +2185,7 @@ PLAN-ROOT SINK
| predicates: item.i_manager_id = 1
|
01:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
runtime filters: RF000 -> store_sales.ss_sold_date_sk, RF002 -> store_sales.ss_item_sk
====
# TPCDS-Q53
@@ -2160,6 +2220,8 @@ order by
i_manufact_id
limit 100
---- PLAN
+Max Per-Host Resource Reservation: Memory=32.82MB Threads=5
+Per-Host Resource Estimates: Memory=249MB
PLAN-ROOT SINK
|
08:TOP-N [LIMIT=100]
@@ -2193,9 +2255,11 @@ PLAN-ROOT SINK
| predicates: ((i_category IN ('Books', 'Children', 'Electronics') AND i_class IN ('personal', 'portable', 'reference', 'self-help') AND i_brand IN ('scholaramalgamalg #14', 'scholaramalgamalg #7', 'exportiunivamalg #9', 'scholaramalgamalg #9')) OR (i_category IN ('Women', 'Music', 'Men') AND i_class IN ('accessories', 'classical', 'fragrances', 'pants') AND i_brand IN ('amalgimporto #1', 'edu packscholar #1', 'exportiimporto #1', 'importoamalg #1')))
|
01:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
runtime filters: RF000 -> ss_store_sk, RF002 -> ss_sold_date_sk, RF004 -> ss_item_sk
---- DISTRIBUTEDPLAN
+Max Per-Host Resource Reservation: Memory=36.76MB Threads=10
+Per-Host Resource Estimates: Memory=269MB
PLAN-ROOT SINK
|
14:MERGING-EXCHANGE [UNPARTITIONED]
@@ -2245,9 +2309,11 @@ PLAN-ROOT SINK
| predicates: ((i_category IN ('Books', 'Children', 'Electronics') AND i_class IN ('personal', 'portable', 'reference', 'self-help') AND i_brand IN ('scholaramalgamalg #14', 'scholaramalgamalg #7', 'exportiunivamalg #9', 'scholaramalgamalg #9')) OR (i_category IN ('Women', 'Music', 'Men') AND i_class IN ('accessories', 'classical', 'fragrances', 'pants') AND i_brand IN ('amalgimporto #1', 'edu packscholar #1', 'exportiimporto #1', 'importoamalg #1')))
|
01:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
runtime filters: RF000 -> ss_store_sk, RF002 -> ss_sold_date_sk, RF004 -> ss_item_sk
---- PARALLELPLANS
+Max Per-Host Resource Reservation: Memory=73.52MB Threads=11
+Per-Host Resource Estimates: Memory=202MB
PLAN-ROOT SINK
|
14:MERGING-EXCHANGE [UNPARTITIONED]
@@ -2309,7 +2375,7 @@ PLAN-ROOT SINK
| predicates: ((i_category IN ('Books', 'Children', 'Electronics') AND i_class IN ('personal', 'portable', 'reference', 'self-help') AND i_brand IN ('scholaramalgamalg #14', 'scholaramalgamalg #7', 'exportiunivamalg #9', 'scholaramalgamalg #9')) OR (i_category IN ('Women', 'Music', 'Men') AND i_class IN ('accessories', 'classical', 'fragrances', 'pants') AND i_brand IN ('amalgimporto #1', 'edu packscholar #1', 'exportiimporto #1', 'importoamalg #1')))
|
01:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
runtime filters: RF000 -> ss_store_sk, RF002 -> ss_sold_date_sk, RF004 -> ss_item_sk
====
# TPCDS-Q55
@@ -2335,6 +2401,8 @@ order by
i_brand_id
limit 100
---- PLAN
+Max Per-Host Resource Reservation: Memory=29.88MB Threads=4
+Per-Host Resource Estimates: Memory=214MB
PLAN-ROOT SINK
|
06:TOP-N [LIMIT=100]
@@ -2361,9 +2429,11 @@ PLAN-ROOT SINK
| predicates: i_manager_id = 36
|
01:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
runtime filters: RF000 -> ss_sold_date_sk, RF002 -> ss_item_sk
---- DISTRIBUTEDPLAN
+Max Per-Host Resource Reservation: Memory=33.81MB Threads=8
+Per-Host Resource Estimates: Memory=234MB
PLAN-ROOT SINK
|
11:MERGING-EXCHANGE [UNPARTITIONED]
@@ -2404,9 +2474,11 @@ PLAN-ROOT SINK
| predicates: i_manager_id = 36
|
01:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
runtime filters: RF000 -> ss_sold_date_sk, RF002 -> ss_item_sk
---- PARALLELPLANS
+Max Per-Host Resource Reservation: Memory=67.62MB Threads=9
+Per-Host Resource Estimates: Memory=164MB
PLAN-ROOT SINK
|
11:MERGING-EXCHANGE [UNPARTITIONED]
@@ -2455,7 +2527,7 @@ PLAN-ROOT SINK
| predicates: i_manager_id = 36
|
01:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
runtime filters: RF000 -> ss_sold_date_sk, RF002 -> ss_item_sk
====
# TPCDS-Q59
@@ -2541,6 +2613,8 @@ order by
d_week_seq1
limit 100
---- PLAN
+Max Per-Host Resource Reservation: Memory=74.27MB Threads=9
+Per-Host Resource Estimates: Memory=537MB
PLAN-ROOT SINK
|
17:TOP-N [LIMIT=100]
@@ -2578,7 +2652,7 @@ PLAN-ROOT SINK
| | runtime filters: RF012 -> tpcds.date_dim.d_week_seq
| |
| 08:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF010 -> tpcds.store_sales.ss_store_sk, RF014 -> ss_sold_date_sk
|
07:HASH JOIN [INNER JOIN]
@@ -2611,9 +2685,11 @@ PLAN-ROOT SINK
| runtime filters: RF000 -> tpcds.date_dim.d_week_seq, RF006 -> tpcds.date_dim.d_week_seq
|
00:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
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
PLAN-ROOT SINK
|
30:MERGING-EXCHANGE [UNPARTITIONED]
@@ -2669,7 +2745,7 @@ PLAN-ROOT SINK
| | runtime filters: RF012 -> tpcds.date_dim.d_week_seq
| |
| 08:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF010 -> tpcds.store_sales.ss_store_sk, RF014 -> ss_sold_date_sk
|
28:EXCHANGE [HASH(d_week_seq,s_store_id)]
@@ -2716,9 +2792,11 @@ PLAN-ROOT SINK
| runtime filters: RF000 -> tpcds.date_dim.d_week_seq, RF006 -> tpcds.date_dim.d_week_seq
|
00:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
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
PLAN-ROOT SINK
|
30:MERGING-EXCHANGE [UNPARTITIONED]
@@ -2790,7 +2868,7 @@ PLAN-ROOT SINK
| | runtime filters: RF012 -> tpcds.date_dim.d_week_seq
| |
| 08:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF010 -> tpcds.store_sales.ss_store_sk, RF014 -> ss_sold_date_sk
|
28:EXCHANGE [HASH(d_week_seq,s_store_id)]
@@ -2849,7 +2927,7 @@ PLAN-ROOT SINK
| runtime filters: RF000 -> tpcds.date_dim.d_week_seq, RF006 -> tpcds.date_dim.d_week_seq
|
00:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
runtime filters: RF004 -> tpcds.store_sales.ss_store_sk, RF008 -> ss_sold_date_sk
====
# TPCDS-Q63
@@ -2889,6 +2967,8 @@ order by
sum_sales
limit 100
---- PLAN
+Max Per-Host Resource Reservation: Memory=29.32MB Threads=5
+Per-Host Resource Estimates: Memory=253MB
PLAN-ROOT SINK
|
11:TOP-N [LIMIT=100]
@@ -2932,9 +3012,11 @@ PLAN-ROOT SINK
| predicates: ((i_category IN ('Books', 'Children', 'Electronics') AND i_class IN ('personal', 'portable', 'refernece', 'self-help') AND i_brand IN ('scholaramalgamalg #14', 'scholaramalgamalg #7', 'exportiunivamalg #9', 'scholaramalgamalg #9')) OR (i_category IN ('Women', 'Music', 'Men') AND i_class IN ('accessories', 'classical', 'fragrances', 'pants') AND i_brand IN ('amalgimporto #1', 'edu packscholar #1', 'exportiimporto #1', 'importoamalg #1')))
|
01:SCAN HDFS [tpcds.store_sales]
- partitions=364/1824 files=364 size=62.92MB
+ partitions=364/1824 files=364 size=66.85MB
runtime filters: RF000 -> ss_store_sk, RF002 -> ss_sold_date_sk, RF004 -> ss_item_sk
---- DISTRIBUTEDPLAN
+Max Per-Host Resource Reservation: Memory=39.26MB Threads=10
+Per-Host Resource Estimates: Memory=279MB
PLAN-ROOT SINK
|
17:MERGING-EXCHANGE [UNPARTITIONED]
@@ -2994,9 +3076,11 @@ PLAN-ROOT SINK
| predicates: ((i_category IN ('Books', 'Children', 'Electronics') AND i_class IN ('personal', 'portable', 'refernece', 'self-help') AND i_brand IN ('scholaramalgamalg #14', 'scholaramalgamalg #7', 'exportiunivamalg #9', 'scholaramalgamalg #9')) OR (i_category IN ('Women', 'Music', 'Men') AND i_class IN ('accessories', 'classical', 'fragrances', 'pants') AND i_brand IN ('amalgimporto #1', 'edu packscholar #1', 'exportiimporto #1', 'importoamalg #1')))
|
01:SCAN HDFS [tpcds.store_sales]
- partitions=364/1824 files=364 size=62.92MB
+ partitions=364/1824 files=364 size=66.85MB
runtime filters: RF000 -> ss_store_sk, RF002 -> ss_sold_date_sk, RF004 -> ss_item_sk
---- PARALLELPLANS
+Max Per-Host Resource Reservation: Memory=78.52MB Threads=11
+Per-Host Resource Estimates: Memory=222MB
PLAN-ROOT SINK
|
17:MERGING-EXCHANGE [UNPARTITIONED]
@@ -3068,7 +3152,7 @@ PLAN-ROOT SINK
| predicates: ((i_category IN ('Books', 'Children', 'Electronics') AND i_class IN ('personal', 'portable', 'refernece', 'self-help') AND i_brand IN ('scholaramalgamalg #14', 'scholaramalgamalg #7', 'exportiunivamalg #9', 'scholaramalgamalg #9')) OR (i_category IN ('Women', 'Music', 'Men') AND i_class IN ('accessories', 'classical', 'fragrances', 'pants') AND i_brand IN ('amalgimporto #1', 'edu packscholar #1', 'exportiimporto #1', 'importoamalg #1')))
|
01:SCAN HDFS [tpcds.store_sales]
- partitions=364/1824 files=364 size=62.92MB
+ partitions=364/1824 files=364 size=66.85MB
runtime filters: RF000 -> ss_store_sk, RF002 -> ss_sold_date_sk, RF004 -> ss_item_sk
====
# TPCDS-Q65
@@ -3127,6 +3211,8 @@ order by
i_item_desc
limit 100
---- PLAN
+Max Per-Host Resource Reservation: Memory=55.57MB Threads=7
+Per-Host Resource Estimates: Memory=432MB
PLAN-ROOT SINK
|
14:TOP-N [LIMIT=100]
@@ -3154,7 +3240,7 @@ PLAN-ROOT SINK
| | predicates: d_month_seq <= 1223, d_month_seq >= 1212
| |
| 02:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF008 -> ss_sold_date_sk
|
12:HASH JOIN [INNER JOIN]
@@ -3185,9 +3271,11 @@ PLAN-ROOT SINK
| predicates: d_month_seq <= 1223, d_month_seq >= 1212
|
07:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
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
PLAN-ROOT SINK
|
27:MERGING-EXCHANGE [UNPARTITIONED]
@@ -3235,7 +3323,7 @@ PLAN-ROOT SINK
| | predicates: d_month_seq <= 1223, d_month_seq >= 1212
| |
| 02:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF008 -> ss_sold_date_sk
|
12:HASH JOIN [INNER JOIN, PARTITIONED]
@@ -3280,9 +3368,11 @@ PLAN-ROOT SINK
| predicates: d_month_seq <= 1223, d_month_seq >= 1212
|
07:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
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
PLAN-ROOT SINK
|
27:MERGING-EXCHANGE [UNPARTITIONED]
@@ -3338,7 +3428,7 @@ PLAN-ROOT SINK
| | predicates: d_month_seq <= 1223, d_month_seq >= 1212
| |
| 02:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF008 -> ss_sold_date_sk
|
12:HASH JOIN [INNER JOIN, PARTITIONED]
@@ -3395,7 +3485,7 @@ PLAN-ROOT SINK
| predicates: d_month_seq <= 1223, d_month_seq >= 1212
|
07:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
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
====
# TPCDS-Q68
@@ -3448,6 +3538,8 @@ order by
ss_ticket_number
limit 100
---- PLAN
+Max Per-Host Resource Reservation: Memory=84.06MB Threads=8
+Per-Host Resource Estimates: Memory=378MB
PLAN-ROOT SINK
|
14:TOP-N [LIMIT=100]
@@ -3505,9 +3597,11 @@ PLAN-ROOT SINK
| predicates: (household_demographics.hd_dep_count = 5 OR household_demographics.hd_vehicle_count = 3)
|
00:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
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
PLAN-ROOT SINK
|
23:MERGING-EXCHANGE [UNPARTITIONED]
@@ -3587,9 +3681,11 @@ PLAN-ROOT SINK
| predicates: (household_demographics.hd_dep_count = 5 OR household_demographics.hd_vehicle_count = 3)
|
00:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
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
PLAN-ROOT SINK
|
23:MERGING-EXCHANGE [UNPARTITIONED]
@@ -3693,7 +3789,7 @@ PLAN-ROOT SINK
| predicates: (household_demographics.hd_dep_count = 5 OR household_demographics.hd_vehicle_count = 3)
|
00:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
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
====
# TPCDS-Q73
@@ -3735,6 +3831,8 @@ order by
cnt desc
limit 1000
---- PLAN
+Max Per-Host Resource Reservation: Memory=34.07MB Threads=6
+Per-Host Resource Estimates: Memory=298MB
PLAN-ROOT SINK
|
10:TOP-N [LIMIT=1000]
@@ -3773,13 +3871,15 @@ PLAN-ROOT SINK
| | predicates: household_demographics.hd_vehicle_count > 0, household_demographics.hd_buy_potential IN ('>10000', 'unknown'), CASE WHEN household_demographics.hd_vehicle_count > 0 THEN household_demographics.hd_dep_count / household_demographics.hd_vehicle_count ELSE NULL END > 1
| |
| 00:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF002 -> store_sales.ss_store_sk, RF004 -> store_sales.ss_sold_date_sk, RF006 -> store_sales.ss_hdemo_sk
|
08:SCAN HDFS [tpcds.customer]
partitions=1/1 files=1 size=12.60MB
runtime filters: RF000 -> c_customer_sk
---- DISTRIBUTEDPLAN
+Max Per-Host Resource Reservation: Memory=61.82MB Threads=13
+Per-Host Resource Estimates: Memory=336MB
PLAN-ROOT SINK
|
18:MERGING-EXCHANGE [UNPARTITIONED]
@@ -3841,9 +3941,11 @@ PLAN-ROOT SINK
| predicates: household_demographics.hd_vehicle_count > 0, household_demographics.hd_buy_potential IN ('>10000', 'unknown'), CASE WHEN household_demographics.hd_vehicle_count > 0 THEN household_demographics.hd_dep_count / household_demographics.hd_vehicle_count ELSE NULL END > 1
|
00:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
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
PLAN-ROOT SINK
|
18:MERGING-EXCHANGE [UNPARTITIONED]
@@ -3921,7 +4023,7 @@ PLAN-ROOT SINK
| predicates: household_demographics.hd_vehicle_count > 0, household_demographics.hd_buy_potential IN ('>10000', 'unknown'), CASE WHEN household_demographics.hd_vehicle_count > 0 THEN household_demographics.hd_dep_count / household_demographics.hd_vehicle_count ELSE NULL END > 1
|
00:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
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
====
# TPCDS-Q79
@@ -3968,6 +4070,8 @@ order by
profit
limit 100
---- PLAN
+Max Per-Host Resource Reservation: Memory=34.07MB Threads=6
+Per-Host Resource Estimates: Memory=298MB
PLAN-ROOT SINK
|
10:TOP-N [LIMIT=100]
@@ -4006,13 +4110,15 @@ PLAN-ROOT SINK
| | predicates: (household_demographics.hd_dep_count = 8 OR household_demographics.hd_vehicle_count > 0)
| |
| 00:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF002 -> store_sales.ss_sold_date_sk, RF004 -> store_sales.ss_store_sk, RF006 -> store_sales.ss_hdemo_sk
|
08:SCAN HDFS [tpcds.customer]
partitions=1/1 files=1 size=12.60MB
runtime filters: RF000 -> c_customer_sk
---- DISTRIBUTEDPLAN
+Max Per-Host Resource Reservation: Memory=53.32MB Threads=13
+Per-Host Resource Estimates: Memory=327MB
PLAN-ROOT SINK
|
18:MERGING-EXCHANGE [UNPARTITIONED]
@@ -4074,9 +4180,11 @@ PLAN-ROOT SINK
| predicates: (household_demographics.hd_dep_count = 8 OR household_demographics.hd_vehicle_count > 0)
|
00:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
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
PLAN-ROOT SINK
|
18:MERGING-EXCHANGE [UNPARTITIONED]
@@ -4154,7 +4262,7 @@ PLAN-ROOT SINK
| predicates: (household_demographics.hd_dep_count = 8 OR household_demographics.hd_vehicle_count > 0)
|
00:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
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
====
# TPCDS-Q89
@@ -4184,6 +4292,8 @@ where case when (avg_monthly_sales <> 0) then (abs(sum_sales - avg_monthly_sales
order by sum_sales - avg_monthly_sales, s_store_name
limit 100) tmp2
---- PLAN
+Max Per-Host Resource Reservation: Memory=36.82MB Threads=5
+Per-Host Resource Estimates: Memory=253MB
PLAN-ROOT SINK
|
11:TOP-N [LIMIT=100]
@@ -4227,9 +4337,11 @@ PLAN-ROOT SINK
| predicates: ((i_category IN ('Children', 'Music', 'Home') AND i_class IN ('toddlers', 'pop', 'lighting')) OR (i_category IN ('Jewelry', 'Books', 'Sports') AND i_class IN ('costume', 'travel', 'football')))
|
01:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
runtime filters: RF000 -> ss_store_sk, RF002 -> ss_sold_date_sk, RF004 -> ss_item_sk
---- DISTRIBUTEDPLAN
+Max Per-Host Resource Reservation: Memory=54.70MB Threads=10
+Per-Host Resource Estimates: Memory=285MB
PLAN-ROOT SINK
|
17:MERGING-EXCHANGE [UNPARTITIONED]
@@ -4289,9 +4401,11 @@ PLAN-ROOT SINK
| predicates: ((i_category IN ('Children', 'Music', 'Home') AND i_class IN ('toddlers', 'pop', 'lighting')) OR (i_category IN ('Jewelry', 'Books', 'Sports') AND i_class IN ('costume', 'travel', 'football')))
|
01:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
runtime filters: RF000 -> ss_store_sk, RF002 -> ss_sold_date_sk, RF004 -> ss_item_sk
---- PARALLELPLANS
+Max Per-Host Resource Reservation: Memory=109.39MB Threads=11
+Per-Host Resource Estimates: Memory=234MB
PLAN-ROOT SINK
|
17:MERGING-EXCHANGE [UNPARTITIONED]
@@ -4363,7 +4477,7 @@ PLAN-ROOT SINK
| predicates: ((i_category IN ('Children', 'Music', 'Home') AND i_class IN ('toddlers', 'pop', 'lighting')) OR (i_category IN ('Jewelry', 'Books', 'Sports') AND i_class IN ('costume', 'travel', 'football')))
|
01:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
runtime filters: RF000 -> ss_store_sk, RF002 -> ss_sold_date_sk, RF004 -> ss_item_sk
====
# TPCDS-Q96
@@ -4382,6 +4496,8 @@ WHERE
AND hd.hd_dep_count = 5
AND s.s_store_name = 'ese'
---- PLAN
+Max Per-Host Resource Reservation: Memory=25.07MB Threads=5
+Per-Host Resource Estimates: Memory=233MB
PLAN-ROOT SINK
|
07:AGGREGATE [FINALIZE]
@@ -4412,9 +4528,11 @@ PLAN-ROOT SINK
| predicates: td.t_hour = 8, td.t_minute >= 30
|
00:SCAN HDFS [tpcds.store_sales ss]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
runtime filters: RF000 -> ss.ss_store_sk, RF002 -> ss.ss_hdemo_sk, RF004 -> ss.ss_sold_time_sk
---- DISTRIBUTEDPLAN
+Max Per-Host Resource Reservation: Memory=25.07MB Threads=9
+Per-Host Resource Estimates: Memory=253MB
PLAN-ROOT SINK
|
12:AGGREGATE [FINALIZE]
@@ -4456,9 +4574,11 @@ PLAN-ROOT SINK
| predicates: td.t_hour = 8, td.t_minute >= 30
|
00:SCAN HDFS [tpcds.store_sales ss]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
runtime filters: RF000 -> ss.ss_store_sk, RF002 -> ss.ss_hdemo_sk, RF004 -> ss.ss_sold_time_sk
---- PARALLELPLANS
+Max Per-Host Resource Reservation: Memory=50.14MB Threads=9
+Per-Host Resource Estimates: Memory=176MB
PLAN-ROOT SINK
|
12:AGGREGATE [FINALIZE]
@@ -4512,7 +4632,7 @@ PLAN-ROOT SINK
| predicates: td.t_hour = 8, td.t_minute >= 30
|
00:SCAN HDFS [tpcds.store_sales ss]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
runtime filters: RF000 -> ss.ss_store_sk, RF002 -> ss.ss_hdemo_sk, RF004 -> ss.ss_sold_time_sk
====
# TPCDS-Q98
@@ -4547,6 +4667,8 @@ order by
revenueratio
limit 1000
---- PLAN
+Max Per-Host Resource Reservation: Memory=26.50MB Threads=4
+Per-Host Resource Estimates: Memory=218MB
PLAN-ROOT SINK
|
08:TOP-N [LIMIT=1000]
@@ -4576,7 +4698,7 @@ PLAN-ROOT SINK
| runtime filters: RF002 <- ss_item_sk
|
|--00:SCAN HDFS [tpcds.store_sales]
-| partitions=31/1824 files=31 size=3.43MB
+| partitions=31/1824 files=31 size=3.64MB
| runtime filters: RF000 -> ss_sold_date_sk
|
01:SCAN HDFS [tpcds.item]
@@ -4584,6 +4706,8 @@ PLAN-ROOT SINK
predicates: i_category IN ('Jewelry', 'Sports', 'Books')
runtime filters: RF002 -> i_item_sk
---- DISTRIBUTEDPLAN
+Max Per-Host Resource Reservation: Memory=58.81MB Threads=9
+Per-Host Resource Estimates: Memory=253MB
PLAN-ROOT SINK
|
14:MERGING-EXCHANGE [UNPARTITIONED]
@@ -4633,9 +4757,11 @@ PLAN-ROOT SINK
09:EXCHANGE [HASH(ss_item_sk)]
|
00:SCAN HDFS [tpcds.store_sales]
- partitions=31/1824 files=31 size=3.43MB
+ partitions=31/1824 files=31 size=3.64MB
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
PLAN-ROOT SINK
|
14:MERGING-EXCHANGE [UNPARTITIONED]
@@ -4693,7 +4819,7 @@ PLAN-ROOT SINK
09:EXCHANGE [HASH(ss_item_sk)]
|
00:SCAN HDFS [tpcds.store_sales]
- partitions=31/1824 files=31 size=3.43MB
+ partitions=31/1824 files=31 size=3.64MB
runtime filters: RF000 -> ss_sold_date_sk, RF002 -> ss_item_sk
====
# TPCD-Q6
@@ -4723,6 +4849,8 @@ select * from (
having count(*) >= 10
order by cnt limit 100) as t
---- PLAN
+Max Per-Host Resource Reservation: Memory=74.56MB Threads=8
+Per-Host Resource Estimates: Memory=403MB
PLAN-ROOT SINK
|
16:TOP-N [LIMIT=100]
@@ -4789,9 +4917,11 @@ PLAN-ROOT SINK
| runtime filters: RF008 -> c.c_current_addr_sk
|
02:SCAN HDFS [tpcds.store_sales s]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
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
PLAN-ROOT SINK
|
30:MERGING-EXCHANGE [UNPARTITIONED]
@@ -4894,9 +5024,11 @@ PLAN-ROOT SINK
| runtime filters: RF008 -> c.c_current_addr_sk
|
02:SCAN HDFS [tpcds.store_sales s]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
runtime filters: RF004 -> s.ss_item_sk, RF006 -> s.ss_sold_date_sk, RF010 -> s.ss_customer_sk
---- PARALLELPLANS
+Max Per-Host Resource Reservation: Memory=178.75MB Threads=22
+Per-Host Resource Estimates: Memory=435MB
PLAN-ROOT SINK
|
30:MERGING-EXCHANGE [UNPARTITIONED]
@@ -5023,7 +5155,7 @@ PLAN-ROOT SINK
| runtime filters: RF008 -> c.c_current_addr_sk
|
02:SCAN HDFS [tpcds.store_sales s]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
runtime filters: RF004 -> s.ss_item_sk, RF006 -> s.ss_sold_date_sk, RF010 -> s.ss_customer_sk
====
# TPCDS-Q47
@@ -5077,6 +5209,8 @@ with v1 as (
limit 100
) as v3
---- PLAN
+Max Per-Host Resource Reservation: Memory=171.25MB Threads=13
+Per-Host Resource Estimates: Memory=765MB
PLAN-ROOT SINK
|
35:TOP-N [LIMIT=100]
@@ -5121,7 +5255,7 @@ PLAN-ROOT SINK
| | predicates: (d_year = 2000 OR (d_year = 1999 AND d_moy = 12) OR (d_year = 2001 AND d_moy = 1))
| |
| 24:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF012 -> ss_store_sk, RF014 -> ss_item_sk, RF016 -> ss_sold_date_sk
|
33:HASH JOIN [INNER JOIN]
@@ -5173,7 +5307,7 @@ PLAN-ROOT SINK
| | predicates: (d_year = 2000 OR (d_year = 1999 AND d_moy = 12) OR (d_year = 2001 AND d_moy = 1))
| |
| 01:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF006 -> ss_store_sk, RF008 -> ss_item_sk, RF010 -> ss_sold_date_sk
|
22:ANALYTIC
@@ -5212,9 +5346,11 @@ PLAN-ROOT SINK
| predicates: (d_year = 2000 OR (d_year = 1999 AND d_moy = 12) OR (d_year = 2001 AND d_moy = 1))
|
14:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
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
PLAN-ROOT SINK
|
54:MERGING-EXCHANGE [UNPARTITIONED]
@@ -5277,7 +5413,7 @@ PLAN-ROOT SINK
| | predicates: (d_year = 2000 OR (d_year = 1999 AND d_moy = 12) OR (d_year = 2001 AND d_moy = 1))
| |
| 24:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF012 -> ss_store_sk, RF014 -> ss_item_sk, RF016 -> ss_sold_date_sk
|
52:EXCHANGE [HASH(rank(),s_store_name,i_category,s_company_name,i_brand)]
@@ -5345,7 +5481,7 @@ PLAN-ROOT SINK
| | predicates: (d_year = 2000 OR (d_year = 1999 AND d_moy = 12) OR (d_year = 2001 AND d_moy = 1))
| |
| 01:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF006 -> ss_store_sk, RF008 -> ss_item_sk, RF010 -> ss_sold_date_sk
|
22:ANALYTIC
@@ -5396,9 +5532,11 @@ PLAN-ROOT SINK
| predicates: (d_year = 2000 OR (d_year = 1999 AND d_moy = 12) OR (d_year = 2001 AND d_moy = 1))
|
14:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
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
PLAN-ROOT SINK
|
54:MERGING-EXCHANGE [UNPARTITIONED]
@@ -5477,7 +5615,7 @@ PLAN-ROOT SINK
| | predicates: (d_year = 2000 OR (d_year = 1999 AND d_moy = 12) OR (d_year = 2001 AND d_moy = 1))
| |
| 24:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF012 -> ss_store_sk, RF014 -> ss_item_sk, RF016 -> ss_sold_date_sk
|
52:EXCHANGE [HASH(rank(),s_store_name,i_category,s_company_name,i_brand)]
@@ -5561,7 +5699,7 @@ PLAN-ROOT SINK
| | predicates: (d_year = 2000 OR (d_year = 1999 AND d_moy = 12) OR (d_year = 2001 AND d_moy = 1))
| |
| 01:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF006 -> ss_store_sk, RF008 -> ss_item_sk, RF010 -> ss_sold_date_sk
|
22:ANALYTIC
@@ -5624,7 +5762,7 @@ PLAN-ROOT SINK
| predicates: (d_year = 2000 OR (d_year = 1999 AND d_moy = 12) OR (d_year = 2001 AND d_moy = 1))
|
14:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
runtime filters: RF000 -> ss_store_sk, RF002 -> ss_item_sk, RF004 -> ss_sold_date_sk
====
# TPCDS-Q66
@@ -5669,6 +5807,8 @@ from
and d_moy = 11) all_sales
order by promotions, total
---- PLAN
+Max Per-Host Resource Reservation: Memory=111.39MB Threads=14
+Per-Host Resource Estimates: Memory=703MB
PLAN-ROOT SINK
|
27:SORT
@@ -5719,7 +5859,7 @@ PLAN-ROOT SINK
| | predicates: d_year = 2000, d_moy = 11
| |
| 14:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF020 -> ss_sold_date_sk, RF018 -> ss_item_sk, RF014 -> ss_customer_sk
|
13:AGGREGATE [FINALIZE]
@@ -5774,9 +5914,11 @@ PLAN-ROOT SINK
| predicates: d_year = 2000, d_moy = 11
|
00:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
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
PLAN-ROOT SINK
|
27:SORT
@@ -5846,7 +5988,7 @@ PLAN-ROOT SINK
| | predicates: d_year = 2000, d_moy = 11
| |
| 14:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF020 -> ss_sold_date_sk, RF018 -> ss_item_sk, RF014 -> ss_customer_sk
|
36:AGGREGATE [FINALIZE]
@@ -5920,9 +6062,11 @@ PLAN-ROOT SINK
| predicates: d_year = 2000, d_moy = 11
|
00:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
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
PLAN-ROOT SINK
|
27:SORT
@@ -6016,7 +6160,7 @@ PLAN-ROOT SINK
| | predicates: d_year = 2000, d_moy = 11
| |
| 14:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF020 -> ss_sold_date_sk, RF018 -> ss_item_sk, RF014 -> ss_customer_sk
|
36:AGGREGATE [FINALIZE]
@@ -6114,7 +6258,7 @@ PLAN-ROOT SINK
| predicates: d_year = 2000, d_moy = 11
|
00:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
runtime filters: RF010 -> ss_sold_date_sk, RF008 -> ss_item_sk, RF006 -> ss_promo_sk, RF002 -> ss_customer_sk, RF004 -> ss_store_sk
====
# TPCDS-Q88
@@ -6209,6 +6353,8 @@ from
(household_demographics.hd_dep_count = 2 and household_demographics.hd_vehicle_count<=2+2))
and store.s_store_name = 'ese') s8
---- PLAN
+Max Per-Host Resource Reservation: Memory=186.56MB Threads=33
+Per-Host Resource Estimates: Memory=1.81GB
PLAN-ROOT SINK
|
70:NESTED LOOP JOIN [CROSS JOIN]
@@ -6239,7 +6385,7 @@ PLAN-ROOT SINK
| | predicates: time_dim.t_hour = 12, time_dim.t_minute < 30
| |
| 56:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF046 -> ss_sold_time_sk
|
69:NESTED LOOP JOIN [CROSS JOIN]
@@ -6270,7 +6416,7 @@ PLAN-ROOT SINK
| | predicates: time_dim.t_hour = 11, time_dim.t_minute >= 30
| |
| 48:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF040 -> ss_sold_time_sk
|
68:NESTED LOOP JOIN [CROSS JOIN]
@@ -6301,7 +6447,7 @@ PLAN-ROOT SINK
| | predicates: time_dim.t_hour = 11, time_dim.t_minute < 30
| |
| 40:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF034 -> ss_sold_time_sk
|
67:NESTED LOOP JOIN [CROSS JOIN]
@@ -6332,7 +6478,7 @@ PLAN-ROOT SINK
| | predicates: time_dim.t_hour = 10, time_dim.t_minute >= 30
| |
| 32:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF028 -> ss_sold_time_sk
|
66:NESTED LOOP JOIN [CROSS JOIN]
@@ -6363,7 +6509,7 @@ PLAN-ROOT SINK
| | predicates: time_dim.t_hour = 10, time_dim.t_minute < 30
| |
| 24:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF022 -> ss_sold_time_sk
|
65:NESTED LOOP JOIN [CROSS JOIN]
@@ -6394,7 +6540,7 @@ PLAN-ROOT SINK
| | predicates: time_dim.t_hour = 9, time_dim.t_minute >= 30
| |
| 16:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF016 -> ss_sold_time_sk
|
64:NESTED LOOP JOIN [CROSS JOIN]
@@ -6426,7 +6572,7 @@ PLAN-ROOT SINK
| | predicates: time_dim.t_hour = 9, time_dim.t_minute < 30
| |
| 08:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF010 -> ss_sold_time_sk, RF008 -> ss_hdemo_sk
|
07:AGGREGATE [FINALIZE]
@@ -6456,9 +6602,11 @@ PLAN-ROOT SINK
| predicates: time_dim.t_hour = 8, time_dim.t_minute >= 30
|
00:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
runtime filters: RF004 -> ss_sold_time_sk, RF002 -> ss_hdemo_sk
---- DISTRIBUTEDPLAN
+Max Per-Host Resource Reservation: Memory=186.56MB Threads=72
+Per-Host Resource Estimates: Memory=1.96GB
PLAN-ROOT SINK
|
70:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]
@@ -6502,7 +6650,7 @@ PLAN-ROOT SINK
| | predicates: time_dim.t_hour = 12, time_dim.t_minute < 30
| |
| 56:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF046 -> ss_sold_time_sk
|
69:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]
@@ -6546,7 +6694,7 @@ PLAN-ROOT SINK
| | predicates: time_dim.t_hour = 11, time_dim.t_minute >= 30
| |
| 48:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF040 -> ss_sold_time_sk
|
68:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]
@@ -6590,7 +6738,7 @@ PLAN-ROOT SINK
| | predicates: time_dim.t_hour = 11, time_dim.t_minute < 30
| |
| 40:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF034 -> ss_sold_time_sk
|
67:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]
@@ -6634,7 +6782,7 @@ PLAN-ROOT SINK
| | predicates: time_dim.t_hour = 10, time_dim.t_minute >= 30
| |
| 32:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF028 -> ss_sold_time_sk
|
66:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]
@@ -6678,7 +6826,7 @@ PLAN-ROOT SINK
| | predicates: time_dim.t_hour = 10, time_dim.t_minute < 30
| |
| 24:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF022 -> ss_sold_time_sk
|
65:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]
@@ -6722,7 +6870,7 @@ PLAN-ROOT SINK
| | predicates: time_dim.t_hour = 9, time_dim.t_minute >= 30
| |
| 16:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF016 -> ss_sold_time_sk
|
64:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]
@@ -6767,7 +6915,7 @@ PLAN-ROOT SINK
| | predicates: time_dim.t_hour = 9, time_dim.t_minute < 30
| |
| 08:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF010 -> ss_sold_time_sk, RF008 -> ss_hdemo_sk
|
75:AGGREGATE [FINALIZE]
@@ -6808,9 +6956,11 @@ PLAN-ROOT SINK
| predicates: time_dim.t_hour = 8, time_dim.t_minute >= 30
|
00:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
runtime filters: RF004 -> ss_sold_time_sk, RF002 -> ss_hdemo_sk
---- PARALLELPLANS
+Max Per-Host Resource Reservation: Memory=373.12MB Threads=72
+Per-Host Resource Estimates: Memory=1.34GB
PLAN-ROOT SINK
|
70:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]
@@ -6870,7 +7020,7 @@ PLAN-ROOT SINK
| | predicates: time_dim.t_hour = 12, time_dim.t_minute < 30
| |
| 56:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF046 -> ss_sold_time_sk
|
69:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]
@@ -6930,7 +7080,7 @@ PLAN-ROOT SINK
| | predicates: time_dim.t_hour = 11, time_dim.t_minute >= 30
| |
| 48:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF040 -> ss_sold_time_sk
|
68:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]
@@ -6990,7 +7140,7 @@ PLAN-ROOT SINK
| | predicates: time_dim.t_hour = 11, time_dim.t_minute < 30
| |
| 40:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF034 -> ss_sold_time_sk
|
67:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]
@@ -7050,7 +7200,7 @@ PLAN-ROOT SINK
| | predicates: time_dim.t_hour = 10, time_dim.t_minute >= 30
| |
| 32:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF028 -> ss_sold_time_sk
|
66:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]
@@ -7110,7 +7260,7 @@ PLAN-ROOT SINK
| | predicates: time_dim.t_hour = 10, time_dim.t_minute < 30
| |
| 24:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF022 -> ss_sold_time_sk
|
65:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]
@@ -7170,7 +7320,7 @@ PLAN-ROOT SINK
| | predicates: time_dim.t_hour = 9, time_dim.t_minute >= 30
| |
| 16:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF016 -> ss_sold_time_sk
|
64:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]
@@ -7231,7 +7381,7 @@ PLAN-ROOT SINK
| | predicates: time_dim.t_hour = 9, time_dim.t_minute < 30
| |
| 08:SCAN HDFS [tpcds.store_sales]
-| partitions=1824/1824 files=1824 size=326.32MB
+| partitions=1824/1824 files=1824 size=346.60MB
| runtime filters: RF010 -> ss_sold_time_sk, RF008 -> ss_hdemo_sk
|
75:AGGREGATE [FINALIZE]
@@ -7284,6 +7434,6 @@ PLAN-ROOT SINK
| predicates: time_dim.t_hour = 8, time_dim.t_minute >= 30
|
00:SCAN HDFS [tpcds.store_sales]
- partitions=1824/1824 files=1824 size=326.32MB
+ partitions=1824/1824 files=1824 size=346.60MB
runtime filters: RF004 -> ss_sold_time_sk, RF002 -> ss_hdemo_sk
====
http://git-wip-us.apache.org/repos/asf/impala/blob/a8d7a50b/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 d4a7d55..510b47b 100644
--- a/testdata/workloads/functional-planner/queries/PlannerTest/tpch-all.test
+++ b/testdata/workloads/functional-planner/queries/PlannerTest/tpch-all.test
@@ -22,6 +22,8 @@ order by
l_returnflag,
l_linestatus
---- PLAN
+Max Per-Host Resource Reservation: Memory=13.94MB Threads=2
+Per-Host Resource Estimates: Memory=274MB
PLAN-ROOT SINK
|
02:SORT
@@ -35,6 +37,8 @@ PLAN-ROOT SINK
partitions=1/1 files=1 size=718.94MB
predicates: l_shipdate <= '1998-09-02'
---- DISTRIBUTEDPLAN
+Max Per-Host Resource Reservation: Memory=23.94MB Threads=4
+Per-Host Resource Estimates: Memory=296MB
PLAN-ROOT SINK
|
05:MERGING-EXCHANGE [UNPARTITIONED]
@@ -57,6 +61,8 @@ PLAN-ROOT SINK
partitions=1/1 files=1 size=718.94MB
predicates: l_shipdate <= '1998-09-02'
---- PARALLELPLANS
+Max Per-Host Resource Reservation: Memory=47.88MB Threads=5
+Per-Host Resource Estimates: Memory=240MB
PLAN-ROOT SINK
|
05:MERGING-EXCHANGE [UNPARTITIONED]
@@ -126,6 +132,8 @@ order by
p_partkey
limit 100
---- PLAN
+Max Per-Host Resource Reservation: Memory=50.39MB Threads=10
+Per-Host Resource Estimates: Memory=628MB
PLAN-ROOT SINK
|
18:TOP-N [LIMIT=100]
@@ -203,6 +211,8 @@ PLAN-ROOT SINK
partitions=1/1 files=1 size=112.71MB
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
PLAN-ROOT SINK
|
30:MERGING-EXCHANGE [UNPARTITIONED]
@@ -308,6 +318,8 @@ PLAN-ROOT SINK
partitions=1/1 files=1 size=112.71MB
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
PLAN-ROOT SINK
|
30:MERGING-EXCHANGE [UNPARTITIONED]
@@ -471,6 +483,8 @@ order by
o_orderdate
limit 10
---- PLAN
+Max Per-Host Resource Reservation: Memory=36.44MB Threads=4
+Per-Host Resource Estimates: Memory=516MB
PLAN-ROOT SINK
|
06:TOP-N [LIMIT=10]
@@ -502,6 +516,8 @@ PLAN-ROOT SINK
predicates: l_shipdate > '1995-03-15'
runtime filters: RF002 -> l_orderkey
---- DISTRIBUTEDPLAN
+Max Per-Host Resource Reservation: Memory=41.38MB Threads=8
+Per-Host Resource Estimates: Memory=537MB
PLAN-ROOT SINK
|
11:MERGING-EXCHANGE [UNPARTITIONED]
@@ -547,6 +563,8 @@ PLAN-ROOT SINK
predicates: l_shipdate > '1995-03-15'
runtime filters: RF002 -> l_orderkey
---- PARALLELPLANS
+Max Per-Host Resource Reservation: Memory=82.75MB Threads=9
+Per-Host Resource Estimates: Memory=483MB
PLAN-ROOT SINK
|
11:MERGING-EXCHANGE [UNPARTITIONED]
@@ -624,6 +642,8 @@ group by
order by
o_orderpriority
---- PLAN
+Max Per-Host Resource Reservation: Memory=34.00MB Threads=3
+Per-Host Resource Estimates: Memory=458MB
PLAN-ROOT SINK
|
04:SORT
@@ -646,6 +666,8 @@ PLAN-ROOT SINK
predicates: l_commitdate < l_receiptdate
runtime filters: RF000 -> l_orderkey
---- DISTRIBUTEDPLAN
+Max Per-Host Resource Reservation: Memory=42.44MB Threads=7
+Per-Host Resource Estimates: Memory=482MB
PLAN-ROOT SINK
|
09:MERGING-EXCHANGE [UNPARTITIONED]
@@ -681,6 +703,8 @@ PLAN-ROOT SINK
predicates: l_commitdate < l_receiptdate
runtime filters: RF000 -> l_orderkey
---- PARALLELPLANS
+Max Per-Host Resource Reservation: Memory=77.38MB Threads=9
+Per-Host Resource Estimates: Memory=430MB
PLAN-ROOT SINK
|
09:MERGING-EXCHANGE [UNPARTITIONED]
@@ -747,6 +771,8 @@ group by
order by
revenue desc
---- PLAN
+Max Per-Host Resource Reservation: Memory=49.20MB Threads=7
+Per-Host Resource Estimates: Memory=623MB
PLAN-ROOT SINK
|
12:SORT
@@ -801,6 +827,8 @@ PLAN-ROOT SINK
partitions=1/1 files=1 size=718.94MB
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
PLAN-ROOT SINK
|
20:MERGING-EXCHANGE [UNPARTITIONED]
@@ -874,6 +902,8 @@ PLAN-ROOT SINK
partitions=1/1 files=1 size=718.94MB
runtime filters: RF005 -> l_suppkey, RF010 -> l_orderkey
---- PARALLELPLANS
+Max Per-Host Resource Reservation: Memory=140.28MB Threads=15
+Per-Host Resource Estimates: Memory=632MB
PLAN-ROOT SINK
|
20:MERGING-EXCHANGE [UNPARTITIONED]
@@ -979,6 +1009,8 @@ where
and l_discount between 0.05 and 0.07
and l_quantity < 24
---- PLAN
+Max Per-Host Resource Reservation: Memory=8.00MB Threads=2
+Per-Host Resource Estimates: Memory=274MB
PLAN-ROOT SINK
|
01:AGGREGATE [FINALIZE]
@@ -988,6 +1020,8 @@ PLAN-ROOT SINK
partitions=1/1 files=1 size=718.94MB
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=8.00MB Threads=3
+Per-Host Resource Estimates: Memory=284MB
PLAN-ROOT SINK
|
03:AGGREGATE [FINALIZE]
@@ -1002,6 +1036,8 @@ PLAN-ROOT SINK
partitions=1/1 files=1 size=718.94MB
predicates: l_discount <= 0.07, l_discount >= 0.05, l_quantity < 24, l_shipdate < '1995-01-01', l_shipdate >= '1994-01-01'
---- PARALLELPLANS
+Max Per-Host Resource Reservation: Memory=16.00MB Threads=3
+Per-Host Resource Estimates: Memory=206MB
PLAN-ROOT SINK
|
03:AGGREGATE [FINALIZE]
@@ -1057,6 +1093,8 @@ order by
cust_nation,
l_year
---- PLAN
+Max Per-Host Resource Reservation: Memory=89.69MB Threads=7
+Per-Host Resource Estimates: Memory=648MB
PLAN-ROOT SINK
|
12:SORT
@@ -1110,6 +1148,8 @@ PLAN-ROOT SINK
predicates: l_shipdate <= '1996-12-31', l_shipdate >= '1995-01-01'
runtime filters: RF006 -> l_suppkey, RF008 -> l_orderkey
---- DISTRIBUTEDPLAN
+Max Per-Host Resource Reservation: Memory=103.95MB Threads=15
+Per-Host Resource Estimates: Memory=689MB
PLAN-ROOT SINK
|
21:MERGING-EXCHANGE [UNPARTITIONED]
@@ -1184,6 +1224,8 @@ PLAN-ROOT SINK
predicates: l_shipdate <= '1996-12-31', l_shipdate >= '1995-01-01'
runtime filters: RF006 -> l_suppkey, RF008 -> l_orderkey
---- PARALLELPLANS
+Max Per-Host Resource Reservation: Memory=194.78MB Threads=17
+Per-Host Resource Estimates: Memory=683MB
PLAN-ROOT SINK
|
21:MERGING-EXCHANGE [UNPARTITIONED]
@@ -1318,6 +1360,8 @@ group by
order by
o_year
---- PLAN
+Max Per-Host Resource Reservation: Memory=50.71MB Threads=9
+Per-Host Resource Estimates: Memory=713MB
PLAN-ROOT SINK
|
16:SORT
@@ -1387,6 +1431,8 @@ PLAN-ROOT SINK
partitions=1/1 files=1 size=23.08MB
runtime filters: RF004 -> c_nationkey, RF006 -> c_custkey
---- DISTRIBUTEDPLAN
+Max Per-Host Resource Reservation: Memory=73.34MB Threads=21
+Per-Host Resource Estimates: Memory=751MB
PLAN-ROOT SINK
|
29:MERGING-EXCHANGE [UNPARTITIONED]
@@ -1485,6 +1531,8 @@ PLAN-ROOT SINK
partitions=1/1 files=1 size=718.94MB
runtime filters: RF008 -> l_suppkey, RF010 -> l_orderkey, RF012 -> l_partkey
---- PARALLELPLANS
+Max Per-Host Resource Reservation: Memory=142.92MB Threads=25
+Per-Host Resource Estimates: Memory=715MB
PLAN-ROOT SINK
|
29:MERGING-EXCHANGE [UNPARTITIONED]
@@ -1645,6 +1693,8 @@ order by
nation,
o_year desc
---- PLAN
+Max Per-Host Resource Reservation: Memory=114.76MB Threads=7
+Per-Host Resource Estimates: Memory=844MB
PLAN-ROOT SINK
|
12:SORT
@@ -1696,6 +1746,8 @@ PLAN-ROOT SINK
partitions=1/1 files=1 size=718.94MB
runtime filters: RF002 -> l_partkey, RF003 -> l_suppkey, RF006 -> l_suppkey, RF008 -> l_orderkey, RF010 -> l_partkey
---- DISTRIBUTEDPLAN
+Max Per-Host Resource Reservation: Memory=140.70MB Threads=15
+Per-Host Resource Estimates: Memory=864MB
PLAN-ROOT SINK
|
21:MERGING-EXCHANGE [UNPARTITIONED]
@@ -1768,6 +1820,8 @@ PLAN-ROOT SINK
partitions=1/1 files=1 size=718.94MB
runtime filters: RF002 -> l_partkey, RF003 -> l_suppkey, RF006 -> l_suppkey, RF008 -> l_orderkey, RF010 -> l_partkey
---- PARALLELPLANS
+Max Per-Host Resource Reservation: Memory=247.39MB Threads=17
+Per-Host Resource Estimates: Memory=862MB
PLAN-ROOT SINK
|
21:MERGING-EXCHANGE [UNPARTITIONED]
@@ -1896,6 +1950,8 @@ order by
revenue desc
limit 20
---- PLAN
+Max Per-Host Resource Reservation: Memory=63.94MB Threads=5
+Per-Host Resource Estimates: Memory=549MB
PLAN-ROOT SINK
|
08:TOP-N [LIMIT=20]
@@ -1933,6 +1989,8 @@ PLAN-ROOT SINK
partitions=1/1 files=1 size=23.08MB
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
PLAN-ROOT SINK
|
15:MERGING-EXCHANGE [UNPARTITIONED]
@@ -1989,6 +2047,8 @@ PLAN-ROOT SINK
predicates: l_returnflag = 'R'
runtime filters: RF004 -> l_orderkey
---- PARALLELPLANS
+Max Per-Host Resource Reservation: Memory=231.89MB Threads=13
+Per-Host Resource Estimates: Memory=697MB
PLAN-ROOT SINK
|
15:MERGING-EXCHANGE [UNPARTITIONED]
@@ -2093,6 +2153,8 @@ where
order by
value desc
---- PLAN
+Max Per-Host Resource Reservation: Memory=31.77MB Threads=7
+Per-Host Resource Estimates: Memory=492MB
PLAN-ROOT SINK
|
13:SORT
@@ -2148,6 +2210,8 @@ PLAN-ROOT SINK
partitions=1/1 files=1 size=112.71MB
runtime filters: RF002 -> ps_suppkey
---- DISTRIBUTEDPLAN
+Max Per-Host Resource Reservation: Memory=43.70MB Threads=15
+Per-Host Resource Estimates: Memory=540MB
PLAN-ROOT SINK
|
23:MERGING-EXCHANGE [UNPARTITIONED]
@@ -2227,6 +2291,8 @@ PLAN-ROOT SINK
partitions=1/1 files=1 size=112.71MB
runtime filters: RF002 -> ps_suppkey
---- PARALLELPLANS
+Max Per-Host Resource Reservation: Memory=87.41MB Threads=16
+Per-Host Resource Estimates: Memory=590MB
PLAN-ROOT SINK
|
23:MERGING-EXCHANGE [UNPARTITIONED]
@@ -2357,6 +2423,8 @@ group by
order by
l_shipmode
---- PLAN
+Max Per-Host Resource Reservation: Memory=51.00MB Threads=3
+Per-Host Resource Estimates: Memory=477MB
PLAN-ROOT SINK
|
04:SORT
@@ -2378,6 +2446,8 @@ PLAN-ROOT SINK
partitions=1/1 files=1 size=162.56MB
runtime filters: RF000 -> o_orderkey
---- DISTRIBUTEDPLAN
+Max Per-Host Resource Reservation: Memory=67.94MB Threads=7
+Per-Host Resource Estimates: Memory=508MB
PLAN-ROOT SINK
|
09:MERGING-EXCHANGE [UNPARTITIONED]
@@ -2412,6 +2482,8 @@ PLAN-ROOT SINK
predicates: l_shipmode IN ('MAIL', 'SHIP'), l_commitdate < l_receiptdate, l_receiptdate < '1995-01-01', l_receiptdate >= '1994-01-01', l_shipdate < l_commitdate
runtime filters: RF000 -> l_orderkey
---- PARALLELPLANS
+Max Per-Host Resource Reservation: Memory=101.88MB Threads=9
+Per-Host Resource Estimates: Memory=454MB
PLAN-ROOT SINK
|
09:MERGING-EXCHANGE [UNPARTITIONED]
@@ -2473,6 +2545,8 @@ order by
custdist desc,
c_count desc
---- PLAN
+Max Per-Host Resource Reservation: Memory=19.88MB Threads=3
+Per-Host Resource Estimates: Memory=244MB
PLAN-ROOT SINK
|
05:SORT
@@ -2498,6 +2572,8 @@ PLAN-ROOT SINK
predicates: NOT o_comment LIKE '%special%requests%'
runtime filters: RF000 -> o_custkey
---- DISTRIBUTEDPLAN
+Max Per-Host Resource Reservation: Memory=41.38MB Threads=7
+Per-Host Resource Estimates: Memory=281MB
PLAN-ROOT SINK
|
10:MERGING-EXCHANGE [UNPARTITIONED]
@@ -2536,6 +2612,8 @@ PLAN-ROOT SINK
predicates: NOT o_comment LIKE '%special%requests%'
runtime filters: RF000 -> o_custkey
---- PARALLELPLANS
+Max Per-Host Resource Reservation: Memory=77.12MB Threads=9
+Per-Host Resource Estimates: Memory=320MB
PLAN-ROOT SINK
|
10:MERGING-EXCHANGE [UNPARTITIONED]
@@ -2594,6 +2672,8 @@ where
and l_shipdate >= '1995-09-01'
and l_shipdate < '1995-10-01'
---- PLAN
+Max Per-Host Resource Reservation: Memory=34.00MB Threads=3
+Per-Host Resource Estimates: Memory=346MB
PLAN-ROOT SINK
|
03:AGGREGATE [FINALIZE]
@@ -2611,6 +2691,8 @@ PLAN-ROOT SINK
predicates: l_shipdate < '1995-10-01', l_shipdate >= '1995-09-01'
runtime filters: RF000 -> l_partkey
---- DISTRIBUTEDPLAN
+Max Per-Host Resource Reservation: Memory=22.75MB Threads=6
+Per-Host Resource Estimates: Memory=355MB
PLAN-ROOT SINK
|
07:AGGREGATE [FINALIZE]
@@ -2637,6 +2719,8 @@ PLAN-ROOT SINK
predicates: l_shipdate < '1995-10-01', l_shipdate >= '1995-09-01'
runtime filters: RF000 -> l_partkey
---- PARALLELPLANS
+Max Per-Host Resource Reservation: Memory=41.75MB Threads=7
+Per-Host Resource Estimates: Memory=280MB
PLAN-ROOT SINK
|
07:AGGREGATE [FINALIZE]
@@ -2700,6 +2784,8 @@ where
order by
s_suppkey
---- PLAN
+Max Per-Host Resource Reservation: Memory=22.88MB Threads=4
+Per-Host Resource Estimates: Memory=581MB
PLAN-ROOT SINK
|
08:SORT
@@ -2735,6 +2821,8 @@ PLAN-ROOT SINK
partitions=1/1 files=1 size=1.33MB
runtime filters: RF000 -> s_suppkey
---- DISTRIBUTEDPLAN
+Max Per-Host Resource Reservation: Memory=44.69MB Threads=10
+Per-Host Resource Estimates: Memory=639MB
PLAN-ROOT SINK
|
17:MERGING-EXCHANGE [UNPARTITIONED]
@@ -2794,6 +2882,8 @@ PLAN-ROOT SINK
predicates: l_shipdate < '1996-04-01', l_shipdate >= '1996-01-01'
runtime filters: RF000 -> tpch.lineitem.l_suppkey
---- PARALLELPLANS
+Max Per-Host Resource Reservation: Memory=87.50MB Threads=12
+Per-Host Resource Estimates: Memory=530MB
PLAN-ROOT SINK
|
17:MERGING-EXCHANGE [UNPARTITIONED]
@@ -2894,6 +2984,8 @@ order by
p_type,
p_size
---- PLAN
+Max Per-Host Resource Reservation: Memory=23.06MB Threads=4
+Per-Host Resource Estimates: Memory=277MB
PLAN-ROOT SINK
|
07:SORT
@@ -2925,6 +3017,8 @@ PLAN-ROOT SINK
partitions=1/1 files=1 size=112.71MB
runtime filters: RF000 -> ps_partkey
---- DISTRIBUTEDPLAN
+Max Per-Host Resource Reservation: Memory=54.56MB Threads=9
+Per-Host Resource Estimates: Memory=329MB
PLAN-ROOT SINK
|
14:MERGING-EXCHANGE [UNPARTITIONED]
@@ -2974,6 +3068,8 @@ PLAN-ROOT SINK
partitions=1/1 files=1 size=112.71MB
runtime filters: RF000 -> ps_partkey
---- PARALLELPLANS
+Max Per-Host Resource Reservation: Memory=101.38MB Threads=11
+Per-Host Resource Estimates: Memory=386MB
PLAN-ROOT SINK
|
14:MERGING-EXCHANGE [UNPARTITIONED]
@@ -3051,6 +3147,8 @@ where
l_partkey = p_partkey
)
---- PLAN
+Max Per-Host Resource Reservation: Memory=32.69MB Threads=4
+Per-Host Resource Estimates: Memory=606MB
PLAN-ROOT SINK
|
06:AGGREGATE [FINALIZE]
@@ -3081,6 +3179,8 @@ PLAN-ROOT SINK
partitions=1/1 files=1 size=718.94MB
runtime filters: RF000 -> tpch.lineitem.l_partkey
---- DISTRIBUTEDPLAN
+Max Per-Host Resource Reservation: Memory=38.75MB Threads=8
+Per-Host Resource Estimates: Memory=639MB
PLAN-ROOT SINK
|
12:AGGREGATE [FINALIZE]
@@ -3126,6 +3226,8 @@ PLAN-ROOT SINK
partitions=1/1 files=1 size=718.94MB
runtime filters: RF000 -> tpch.lineitem.l_partkey
---- PARALLELPLANS
+Max Per-Host Resource Reservation: Memory=75.62MB Threads=9
+Per-Host Resource Estimates: Memory=500MB
PLAN-ROOT SINK
|
12:AGGREGATE [FINALIZE]
@@ -3216,6 +3318,8 @@ order by
o_orderdate
limit 100
---- PLAN
+Max Per-Host Resource Reservation: Memory=92.25MB Threads=5
+Per-Host Resource Estimates: Memory=868MB
PLAN-ROOT SINK
|
09:TOP-N [LIMIT=100]
@@ -3256,6 +3360,8 @@ PLAN-ROOT SINK
partitions=1/1 files=1 size=718.94MB
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
PLAN-ROOT SINK
|
17:MERGING-EXCHANGE [UNPARTITIONED]
@@ -3318,6 +3424,8 @@ PLAN-ROOT SINK
partitions=1/1 files=1 size=718.94MB
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
PLAN-ROOT SINK
|
17:MERGING-EXCHANGE [UNPARTITIONED]
@@ -3430,6 +3538,8 @@ where
)
)
---- PLAN
+Max Per-Host Resource Reservation: Memory=19.88MB Threads=3
+Per-Host Resource Estimates: Memory=332MB
PLAN-ROOT SINK
|
03:AGGREGATE [FINALIZE]
@@ -3449,6 +3559,8 @@ PLAN-ROOT SINK
predicates: l_shipmode IN ('AIR', 'AIR REG'), l_shipinstruct = 'DELIVER IN PERSON'
runtime filters: RF000 -> l_partkey
---- DISTRIBUTEDPLAN
+Max Per-Host Resource Reservation: Memory=19.88MB Threads=5
+Per-Host Resource Estimates: Memory=352MB
PLAN-ROOT SINK
|
06:AGGREGATE [FINALIZE]
@@ -3475,6 +3587,8 @@ PLAN-ROOT SINK
predicates: l_shipmode IN ('AIR', 'AIR REG'), l_shipinstruct = 'DELIVER IN PERSON'
runtime filters: RF000 -> l_partkey
---- PARALLELPLANS
+Max Per-Host Resource Reservation: Memory=39.75MB Threads=5
+Per-Host Resource Estimates: Memory=278MB
PLAN-ROOT SINK
|
06:AGGREGATE [FINALIZE]
@@ -3545,6 +3659,8 @@ where
order by
s_name
---- PLAN
+Max Per-Host Resource Reservation: Memory=71.75MB Threads=6
+Per-Host Resource Estimates: Memory=612MB
PLAN-ROOT SINK
|
10:SORT
@@ -3592,6 +3708,8 @@ PLAN-ROOT SINK
predicates: l_shipdate < '1995-01-01', l_shipdate >= '1994-01-01'
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
PLAN-ROOT SINK
|
18:MERGING-EXCHANGE [UNPARTITIONED]
@@ -3658,6 +3776,8 @@ PLAN-ROOT SINK
predicates: l_shipdate < '1995-01-01', l_shipdate >= '1994-01-01'
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
PLAN-ROOT SINK
|
18:MERGING-EXCHANGE [UNPARTITIONED]
@@ -3783,6 +3903,8 @@ order by
s_name
limit 100
---- PLAN
+Max Per-Host Resource Reservation: Memory=58.88MB Threads=7
+Per-Host Resource Estimates: Memory=1.03GB
PLAN-ROOT SINK
|
12:TOP-N [LIMIT=100]
@@ -3838,6 +3960,8 @@ PLAN-ROOT SINK
partitions=1/1 files=1 size=718.94MB
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
PLAN-ROOT SINK
|
21:MERGING-EXCHANGE [UNPARTITIONED]
@@ -3915,6 +4039,8 @@ PLAN-ROOT SINK
partitions=1/1 files=1 size=718.94MB
predicates: l3.l_receiptdate > l3.l_commitdate
---- PARALLELPLANS
+Max Per-Host Resource Reservation: Memory=109.27MB Threads=17
+Per-Host Resource Estimates: Memory=841MB
PLAN-ROOT SINK
|
21:MERGING-EXCHANGE [UNPARTITIONED]
@@ -4049,6 +4175,8 @@ group by
order by
cntrycode
---- PLAN
+Max Per-Host Resource Reservation: Memory=24.00MB Threads=4
+Per-Host Resource Estimates: Memory=314MB
PLAN-ROOT SINK
|
07:SORT
@@ -4078,6 +4206,8 @@ PLAN-ROOT SINK
03:SCAN HDFS [tpch.orders]
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
PLAN-ROOT SINK
|
15:MERGING-EXCHANGE [UNPARTITIONED]
@@ -4127,6 +4257,8 @@ PLAN-ROOT SINK
03:SCAN HDFS [tpch.orders]
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
PLAN-ROOT SINK
|
15:MERGING-EXCHANGE [UNPARTITIONED]
http://git-wip-us.apache.org/repos/asf/impala/blob/a8d7a50b/testdata/workloads/functional-planner/queries/PlannerTest/tpch-kudu.test
----------------------------------------------------------------------
diff --git a/testdata/workloads/functional-planner/queries/PlannerTest/tpch-kudu.test b/testdata/workloads/functional-planner/queries/PlannerTest/tpch-kudu.test
index 9c4da19..3de3714 100644
--- a/testdata/workloads/functional-planner/queries/PlannerTest/tpch-kudu.test
+++ b/testdata/workloads/functional-planner/queries/PlannerTest/tpch-kudu.test
@@ -21,6 +21,8 @@ order by
l_returnflag,
l_linestatus
---- PLAN
+Max Per-Host Resource Reservation: Memory=13.94MB Threads=2
+Per-Host Resource Estimates: Memory=22MB
PLAN-ROOT SINK
|
02:SORT
@@ -79,6 +81,8 @@ order by
p_partkey
limit 100
---- PLAN
+Max Per-Host Resource Reservation: Memory=18.31MB Threads=10
+Per-Host Resource Estimates: Memory=24MB
PLAN-ROOT SINK
|
18:TOP-N [LIMIT=100]
@@ -173,6 +177,8 @@ order by
o_orderdate
limit 10
---- PLAN
+Max Per-Host Resource Reservation: Memory=12.38MB Threads=4
+Per-Host Resource Estimates: Memory=20MB
PLAN-ROOT SINK
|
06:TOP-N [LIMIT=10]
@@ -224,6 +230,8 @@ group by
order by
o_orderpriority
---- PLAN
+Max Per-Host Resource Reservation: Memory=13.94MB Threads=3
+Per-Host Resource Estimates: Memory=22MB
PLAN-ROOT SINK
|
04:SORT
@@ -270,6 +278,8 @@ group by
order by
revenue desc
---- PLAN
+Max Per-Host Resource Reservation: Memory=15.38MB Threads=7
+Per-Host Resource Estimates: Memory=23MB
PLAN-ROOT SINK
|
12:SORT
@@ -329,6 +339,8 @@ where
and l_discount between 0.05 and 0.07
and l_quantity < 24
---- PLAN
+Max Per-Host Resource Reservation: Memory=0B Threads=2
+Per-Host Resource Estimates: Memory=10MB
PLAN-ROOT SINK
|
01:AGGREGATE [FINALIZE]
@@ -377,6 +389,8 @@ order by
cust_nation,
l_year
---- PLAN
+Max Per-Host Resource Reservation: Memory=76.69MB Threads=7
+Per-Host Resource Estimates: Memory=83MB
PLAN-ROOT SINK
|
12:SORT
@@ -463,6 +477,8 @@ group by
order by
o_year
---- PLAN
+Max Per-Host Resource Reservation: Memory=12.56MB Threads=9
+Per-Host Resource Estimates: Memory=18MB
PLAN-ROOT SINK
|
16:SORT
@@ -557,6 +573,8 @@ order by
nation,
o_year desc
---- PLAN
+Max Per-Host Resource Reservation: Memory=79.50MB Threads=7
+Per-Host Resource Estimates: Memory=104MB
PLAN-ROOT SINK
|
12:SORT
@@ -637,6 +655,8 @@ order by
revenue desc
limit 20
---- PLAN
+Max Per-Host Resource Reservation: Memory=44.44MB Threads=5
+Per-Host Resource Estimates: Memory=61MB
PLAN-ROOT SINK
|
08:TOP-N [LIMIT=20]
@@ -705,6 +725,8 @@ where
order by
value desc
---- PLAN
+Max Per-Host Resource Reservation: Memory=9.69MB Threads=7
+Per-Host Resource Estimates: Memory=28MB
PLAN-ROOT SINK
|
13:SORT
@@ -784,6 +806,8 @@ group by
order by
l_shipmode
---- PLAN
+Max Per-Host Resource Reservation: Memory=35.94MB Threads=3
+Per-Host Resource Estimates: Memory=46MB
PLAN-ROOT SINK
|
04:SORT
@@ -826,6 +850,8 @@ order by
custdist desc,
c_count desc
---- PLAN
+Max Per-Host Resource Reservation: Memory=10.75MB Threads=3
+Per-Host Resource Estimates: Memory=20MB
PLAN-ROOT SINK
|
05:SORT
@@ -864,6 +890,8 @@ where
and l_shipdate >= '1995-09-01'
and l_shipdate < '1995-10-01'
---- PLAN
+Max Per-Host Resource Reservation: Memory=17.00MB Threads=3
+Per-Host Resource Estimates: Memory=27MB
PLAN-ROOT SINK
|
03:AGGREGATE [FINALIZE]
@@ -911,6 +939,8 @@ where
order by
s_suppkey
---- PLAN
+Max Per-Host Resource Reservation: Memory=15.88MB Threads=4
+Per-Host Resource Estimates: Memory=32MB
PLAN-ROOT SINK
|
08:SORT
@@ -975,6 +1005,8 @@ order by
p_type,
p_size
---- PLAN
+Max Per-Host Resource Reservation: Memory=16.75MB Threads=4
+Per-Host Resource Estimates: Memory=22MB
PLAN-ROOT SINK
|
07:SORT
@@ -1023,6 +1055,8 @@ where
l_partkey = p_partkey
)
---- PLAN
+Max Per-Host Resource Reservation: Memory=8.62MB Threads=4
+Per-Host Resource Estimates: Memory=22MB
PLAN-ROOT SINK
|
06:AGGREGATE [FINALIZE]
@@ -1086,6 +1120,8 @@ order by
o_orderdate
limit 100
---- PLAN
+Max Per-Host Resource Reservation: Memory=81.25MB Threads=5
+Per-Host Resource Estimates: Memory=155MB
PLAN-ROOT SINK
|
09:TOP-N [LIMIT=100]
@@ -1159,6 +1195,8 @@ where
)
)
---- PLAN
+Max Per-Host Resource Reservation: Memory=2.88MB Threads=3
+Per-Host Resource Estimates: Memory=13MB
PLAN-ROOT SINK
|
03:AGGREGATE [FINALIZE]
@@ -1214,6 +1252,8 @@ where
order by
s_name
---- PLAN
+Max Per-Host Resource Reservation: Memory=50.81MB Threads=6
+Per-Host Resource Estimates: Memory=51MB
PLAN-ROOT SINK
|
10:SORT
@@ -1298,6 +1338,8 @@ order by
s_name
limit 100
---- PLAN
+Max Per-Host Resource Reservation: Memory=10.56MB Threads=7
+Per-Host Resource Estimates: Memory=12MB
PLAN-ROOT SINK
|
12:TOP-N [LIMIT=100]
@@ -1383,6 +1425,8 @@ group by
order by
cntrycode
---- PLAN
+Max Per-Host Resource Reservation: Memory=13.94MB Threads=4
+Per-Host Resource Estimates: Memory=22MB
PLAN-ROOT SINK
|
07:SORT