Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
-
None
Description
TPCH 20 returns 0 rows, successfully executes though.
Text version of physical plan:
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`]]]])