drill-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Sudheesh Katkam (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (DRILL-2714) Exchange should be removed if Drill scans a local system table
Date Tue, 07 Apr 2015 21:40:12 GMT

     [ https://issues.apache.org/jira/browse/DRILL-2714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Sudheesh Katkam updated DRILL-2714:
-----------------------------------
    Summary: Exchange should be removed if Drill scans a local system table  (was: Exchange
should be removed if Drill scans a local table)

> 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)

Mime
View raw message