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)