drill-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ramana Inukonda Nagaraj (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (DRILL-989) TPCH 20 returning 0 rows
Date Wed, 25 Jun 2014 22:32:24 GMT

    [ https://issues.apache.org/jira/browse/DRILL-989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14044130#comment-14044130
] 

Ramana Inukonda Nagaraj commented on DRILL-989:
-----------------------------------------------

Plan:
{code}
00-00    Screen
00-01      Project(s_name=[$0], s_address=[$1])
00-02        SelectionVectorRemover
00-03          Sort(sort0=[$0], dir0=[ASC])
00-04            Project(s_name=[$0], s_address=[$1])
00-05              HashJoin(condition=[=($2, $3)], joinType=[inner])
00-07                Project($f3=[$2], $f4=[$3], $f8=[$0])
00-09                  HashJoin(condition=[=($1, $5)], joinType=[inner])
00-12                    Project(s_suppkey=[$3], s_nationkey=[$2], s_name=[$1], s_address=[$0])
00-15                      Scan(groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:/drill/testdata/tpch-multi/supplier]],
selectionRoot=/drill/testdata/tpch-multi/supplier, columns=[SchemaPath [`s_suppkey`], SchemaPath
[`s_nationkey`], SchemaPath [`s_name`], SchemaPath [`s_address`]]]])
00-11                    SelectionVectorRemover
00-14                      Filter(condition=[=(CAST($0):CHAR(5) CHARACTER SET "ISO-8859-1"
COLLATE "ISO-8859-1$en_US$primary", 'KENYA')])
00-17                        Project(n_name=[$1], n_nationkey=[$0])
00-20                          Scan(groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath
[path=maprfs:/drill/testdata/tpch-multi/nation]], selectionRoot=/drill/testdata/tpch-multi/nation,
columns=[SchemaPath [`n_name`], SchemaPath [`n_nationkey`]]]])
00-06                StreamAgg(group=[{0}])
00-08                  Project(ps_suppkey=[$2])
00-10                    SelectionVectorRemover
00-13                      Filter(condition=[AND(true, >($1, CAST(*(0.5, $5)):ANY))])
00-16                        HashJoin(condition=[AND(=($0, $3), =($2, $4))], joinType=[left])
00-19                          Project($f1=[$0], $f2=[$1], $f3=[$2])
00-22                            HashJoin(condition=[=($3, $4)], joinType=[inner])
00-25                              Project($f1=[$0], $f2=[$2], $f3=[$1], $f4=[$0])
00-28                                Scan(groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath
[path=maprfs:/drill/testdata/tpch-multi/partsupp]], selectionRoot=/drill/testdata/tpch-multi/partsupp,
columns=[SchemaPath [`ps_partkey`], SchemaPath [`ps_availqty`], SchemaPath [`ps_suppkey`]]]])
00-24                              HashAgg(group=[{0}])
00-27                                Project(p_partkey=[$1])
00-31                                  SelectionVectorRemover
00-34                                    Filter(condition=[LIKE($0, 'antique%')])
00-37                                      Scan(groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath
[path=maprfs:/drill/testdata/tpch-multi/part]], selectionRoot=/drill/testdata/tpch-multi/part,
columns=[SchemaPath [`p_name`], SchemaPath [`p_partkey`]]]])
00-18                          Project($f0=[$0], $f10=[$1], $f20=[$2])
00-21                            HashAgg(group=[{0, 1}], agg#0=[SUM($2)])
00-23                              Project($f0=[$4], $f1=[$5], l_quantity=[$3])
00-26                                HashJoin(condition=[AND(=($0, $4), =($1, $5))], joinType=[inner])
00-30                                  SelectionVectorRemover
00-33                                    Filter(condition=[AND(>=($2, 1993-01-01), <($2,
+(1993-01-01, 12)))])
00-36                                      Project(l_partkey=[$2], l_suppkey=[$1], l_shipdate=[$3],
l_quantity=[$0])
00-40                                        Scan(groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath
[path=maprfs:/drill/testdata/tpch-multi/lineitem]], selectionRoot=/drill/testdata/tpch-multi/lineitem,
columns=[SchemaPath [`l_partkey`], SchemaPath [`l_suppkey`], SchemaPath [`l_shipdate`], SchemaPath
[`l_quantity`]]]])
00-29                                  HashAgg(group=[{0, 1}])
00-32                                    Project($f0=[$0], $f1=[$1])
00-35                                      HashJoin(condition=[=($2, $3)], joinType=[inner])
00-39                                        Project($f1=[$0], $f3=[$1], $f4=[$0])
00-42                                          Scan(groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath
[path=maprfs:/drill/testdata/tpch-multi/partsupp]], selectionRoot=/drill/testdata/tpch-multi/partsupp,
columns=[SchemaPath [`ps_partkey`], SchemaPath [`ps_suppkey`]]]])
00-38                                        HashAgg(group=[{0}])
00-41                                          Project(p_partkey=[$1])
00-43                                            SelectionVectorRemover
00-44                                              Filter(condition=[LIKE($0, 'antique%')])
00-45                                                Scan(groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath
[path=maprfs:/drill/testdata/tpch-multi/part]], selectionRoot=/drill/testdata/tpch-multi/part,
columns=[SchemaPath [`p_name`], SchemaPath [`p_partkey`]]]])
{code}

> TPCH 20 returning 0 rows
> ------------------------
>
>                 Key: DRILL-989
>                 URL: https://issues.apache.org/jira/browse/DRILL-989
>             Project: Apache Drill
>          Issue Type: Bug
>          Components: Execution - Flow
>            Reporter: Ramana Inukonda Nagaraj
>
> TPCH 20 returns 0 rows, successfully executes though.
> Text version of physical plan:
> {code}
> 00-00    Screen
> 00-01      Project(s_name=[$0], s_address=[$1])
> 00-02        SingleMergeExchange(sort0=[0 ASC])
> 01-01          SelectionVectorRemover
> 01-02            Sort(sort0=[$0], dir0=[ASC])
> 01-03              HashToRandomExchange(dist0=[[$0]])
> 02-01                Project(s_name=[$0], s_address=[$1])
> 02-02                  HashJoin(condition=[=($2, $3)], joinType=[inner])
> 02-04                    HashToRandomExchange(dist0=[[$2]])
> 03-01                      Project($f3=[$2], $f4=[$3], $f8=[$0])
> 03-02                        HashJoin(condition=[=($1, $5)], joinType=[inner])
> 03-04                          Project(s_suppkey=[$3], s_nationkey=[$2], s_name=[$1],
s_address=[$0])
> 03-05                            Scan(groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath
[path=maprfs:/drill/testdata/tpch-multi/supplier]], selectionRoot=/drill/testdata/tpch-multi/supplier,
columns=[SchemaPath [`s_suppkey`], SchemaPath [`s_nationkey`], SchemaPath [`s_name`], SchemaPath
[`s_address`]]]])
> 03-03                          BroadcastExchange
> 06-01                            SelectionVectorRemover
> 06-02                              Filter(condition=[=(CAST($0):CHAR(5) CHARACTER SET
"ISO-8859-1" COLLATE "ISO-8859-1$en_US$primary", 'KENYA')])
> 06-03                                Project(n_name=[$1], n_nationkey=[$0])
> 06-04                                  Scan(groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath
[path=maprfs:/drill/testdata/tpch-multi/nation]], selectionRoot=/drill/testdata/tpch-multi/nation,
columns=[SchemaPath [`n_name`], SchemaPath [`n_nationkey`]]]])
> 02-03                    StreamAgg(group=[{0}])
> 02-05                      Project(ps_suppkey=[$2])
> 02-06                        SelectionVectorRemover
> 02-07                          Filter(condition=[AND(true, >($1, CAST(*(0.5, $5)):ANY))])
> 02-08                            HashJoin(condition=[AND(=($0, $3), =($2, $4))], joinType=[left])
> 02-10                              HashToRandomExchange(dist0=[[$0]], dist1=[[$2]])
> 04-01                                Project($f1=[$0], $f2=[$1], $f3=[$2])
> 04-02                                  HashJoin(condition=[=($3, $4)], joinType=[inner])
> 04-04                                    Project($f1=[$0], $f2=[$2], $f3=[$1], $f4=[$0])
> 04-05                                      Scan(groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath
[path=maprfs:/drill/testdata/tpch-multi/partsupp]], selectionRoot=/drill/testdata/tpch-multi/partsupp,
columns=[SchemaPath [`ps_partkey`], SchemaPath [`ps_availqty`], SchemaPath [`ps_suppkey`]]]])
> 04-03                                    BroadcastExchange
> 07-01                                      HashAgg(group=[{0}])
> 07-02                                        HashToRandomExchange(dist0=[[$0]])
> 09-01                                          Project(p_partkey=[$1])
> 09-02                                            SelectionVectorRemover
> 09-03                                              Filter(condition=[LIKE($0, 'antique%')])
> 09-04                                                Scan(groupscan=[ParquetGroupScan
[entries=[ReadEntryWithPath [path=maprfs:/drill/testdata/tpch-multi/part]], selectionRoot=/drill/testdata/tpch-multi/part,
columns=[SchemaPath [`p_name`], SchemaPath [`p_partkey`]]]])
> 02-09                              Project($f0=[$0], $f10=[$1], $f20=[$2])
> 02-11                                HashAgg(group=[{0, 1}], agg#0=[SUM($2)])
> 02-12                                  HashToRandomExchange(dist0=[[$0]])
> 05-01                                    Project($f0=[$4], $f1=[$5], l_quantity=[$3])
> 05-02                                      HashJoin(condition=[AND(=($0, $4), =($1, $5))],
joinType=[inner])
> 05-04                                        SelectionVectorRemover
> 05-05                                          Filter(condition=[AND(>=($2, 1993-01-01),
<($2, +(1993-01-01, 12)))])
> 05-06                                            Project(l_partkey=[$2], l_suppkey=[$1],
l_shipdate=[$3], l_quantity=[$0])
> 05-07                                              Scan(groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath
[path=maprfs:/drill/testdata/tpch-multi/lineitem]], selectionRoot=/drill/testdata/tpch-multi/lineitem,
columns=[SchemaPath [`l_partkey`], SchemaPath [`l_suppkey`], SchemaPath [`l_shipdate`], SchemaPath
[`l_quantity`]]]])
> 05-03                                        BroadcastExchange
> 08-01                                          HashAgg(group=[{0, 1}])
> 08-02                                            HashToRandomExchange(dist0=[[$0]])
> 10-01                                              Project($f0=[$0], $f1=[$1])
> 10-02                                                HashJoin(condition=[=($2, $3)],
joinType=[inner])
> 10-04                                                  Project($f1=[$0], $f3=[$1], $f4=[$0])
> 10-05                                                    Scan(groupscan=[ParquetGroupScan
[entries=[ReadEntryWithPath [path=maprfs:/drill/testdata/tpch-multi/partsupp]], selectionRoot=/drill/testdata/tpch-multi/partsupp,
columns=[SchemaPath [`ps_partkey`], SchemaPath [`ps_suppkey`]]]])
> 10-03                                                  BroadcastExchange
> 11-01                                                    HashAgg(group=[{0}])
> 11-02                                                      HashToRandomExchange(dist0=[[$0]])
> 12-01                                                        Project(p_partkey=[$1])
> 12-02                                                          SelectionVectorRemover
> 12-03                                                            Filter(condition=[LIKE($0,
'antique%')])
> 12-04                                                              Scan(groupscan=[ParquetGroupScan
[entries=[ReadEntryWithPath [path=maprfs:/drill/testdata/tpch-multi/part]], selectionRoot=/drill/testdata/tpch-multi/part,
columns=[SchemaPath [`p_name`], SchemaPath [`p_partkey`]]]])
> {code}



--
This message was sent by Atlassian JIRA
(v6.2#6252)

Mime
View raw message