You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@drill.apache.org by "Sean Hsuan-Yi Chu (JIRA)" <ji...@apache.org> on 2015/04/07 23:20:12 UTC
[jira] [Created] (DRILL-2714) Exchange should be removed if Drill
scans a local table
Sean Hsuan-Yi Chu created DRILL-2714:
----------------------------------------
Summary: Exchange should be removed if Drill scans a local table
Key: DRILL-2714
URL: https://issues.apache.org/jira/browse/DRILL-2714
Project: Apache Drill
Issue Type: Bug
Components: Query Planning & Optimization
Reporter: Sean Hsuan-Yi Chu
Assignee: Sean Hsuan-Yi Chu
For the query:
"select t1.name, t1.kind, t2.n_nationkey from (select * from sys.options) t1 join (select * from cp.`tpch/nation.parquet`) t2 on t1.name = t2.n_name;" (TestStarQueries.testSelStarJoinSchemaWithSchemaLess)
If broadcast_join is disabled, the following plan will be generated:
{code}
text json
00-00 Screen
00-01 ProjectAllowDup(name=[$0], kind=[$1], n_nationkey=[$2])
00-02 Project(name=[$0], kind=[$1], n_nationkey=[ITEM($7, 'n_nationkey')])
00-03 HashJoin(condition=[=($0, $8)], joinType=[inner])
00-04 Project(T0¦¦*=[$0], $f1=[ITEM($0, 'n_name')])
00-06 Project(T0¦¦*=[$0])
00-08 Scan(groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=/tpch/nation.parquet]], selectionRoot=/tpch/nation.parquet, numFiles=1, columns=[`*`]]])
00-05 Project(name=[$0], kind=[$1], type=[$2], num_val=[$3], string_val=[$4], bool_val=[$5], float_val=[$6])
00-07 HashToRandomExchange(dist0=[[$0]])
01-01 UnorderedMuxExchange
02-01 Project(name=[$0], kind=[$1], type=[$2], num_val=[$3], string_val=[$4], bool_val=[$5], float_val=[$6], E_X_P_R_H_A_S_H_F_I_E_L_D=[castINT(hash64($0))])
02-02 Scan(groupscan=[SystemTableScan [table=OPTION, distributed=false]])
{code}
The exchange on the SystemTableScan does not get removed. This will result in error (see the attachment).
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)