You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@drill.apache.org by "Sean Hsuan-Yi Chu (JIRA)" <ji...@apache.org> on 2015/04/09 00:04:12 UTC
[jira] [Commented] (DRILL-2714) Exchange should be removed if Drill
scans a local system table
[ https://issues.apache.org/jira/browse/DRILL-2714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14486163#comment-14486163 ]
Sean Hsuan-Yi Chu commented on DRILL-2714:
------------------------------------------
Review Board:
https://reviews.apache.org/r/32944/#review79431
> Exchange should be removed if Drill scans a local system 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
> Attachments: ErrorMessage.txt
>
>
> 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)