Plan does not match, expected [ - node(OutputNode) - node(JoinNode) JoinMatcher{type=INNER, equiCriteria=[L_NATIONKEY = R_NATIONKEY], distributionType=Optional.empty, dynamicFilter=Optional.empty} - node(FilterNode) FilterMatcher{predicate=true} - node(TableScanNode) TableScanMatcher{expectedTableName=nation} bind L_NATIONKEY -> Column nation:nationkey - anyTree - node(TableScanNode) TableScanMatcher{expectedTableName=nation} bind R_NATIONKEY -> Column nation:nationkey ] but found [ Output[columnNames = [nationkey, name, regionkey, comment, nationkey2, nationkey, name, regionkey, comment]] │ Layout: [nationkey:bigint, name:varchar(25), regionkey:bigint, comment:varchar(152), expr:bigint, nationkey:bigint, name_2:varchar(25), regionkey_3:bigint, comment_4:varchar(152)] │ nationkey2 := expr │ name := name_2 │ regionkey := regionkey_3 │ comment := comment_4 └─ InnerJoin[criteria = ("nationkey" = "nationkey_1"), distribution = REPLICATED] │ Layout: [nationkey:bigint, regionkey:bigint, name:varchar(25), comment:varchar(152), expr:bigint, name_2:varchar(25), regionkey_3:bigint, comment_4:varchar(152)] │ Distribution: REPLICATED │ dynamicFilterAssignments = {nationkey_1 -> #df_303} ├─ ScanFilterProject[table = test_catalog:tiny:nation, dynamicFilters = {"nationkey" = #df_303}] │ Layout: [nationkey:bigint, regionkey:bigint, name:varchar(25), comment:varchar(152), expr:bigint] │ expr := ("nationkey" + BIGINT '1') │ nationkey := tpch:nationkey │ regionkey := tpch:regionkey │ name := tpch:name │ comment := tpch:comment └─ LocalExchange[partitioning = SINGLE] │ Layout: [nationkey_1:bigint, name_2:varchar(25), regionkey_3:bigint, comment_4:varchar(152)] └─ TableScan[table = test_catalog:tiny:nation] Layout: [nationkey_1:bigint, name_2:varchar(25), regionkey_3:bigint, comment_4:varchar(152)] name_2 := tpch:name comment_4 := tpch:comment nationkey_1 := tpch:nationkey regionkey_3 := tpch:regionkey ]

Plan does not match, expected [ - node(OutputNode) - node(JoinNode) JoinMatcher{type=INNER, equiCriteria=[L_NATIONKEY = R_NATIONKEY], distributionType=Optional.empty, dynamicFilter=Optional.empty} - node(TableScanNode) TableScanMatcher{expectedTableName=nation} bind L_NATIONKEY -> Column nation:nationkey - anyTree - node(TableScanNode) TableScanMatcher{expectedTableName=nation} bind R_NATIONKEY -> Column nation:nationkey ] but found [ Output[columnNames = [nationkey, name, regionkey, comment, nationkey2, nationkey, name, regionkey, comment]] │ Layout: [nationkey:bigint, name:varchar(25), regionkey:bigint, comment:varchar(152), expr:bigint, nationkey:bigint, name_2:varchar(25), regionkey_3:bigint, comment_4:varchar(152)] │ nationkey2 := expr │ name := name_2 │ regionkey := regionkey_3 │ comment := comment_4 └─ InnerJoin[criteria = ("nationkey" = "nationkey_1"), distribution = REPLICATED] │ Layout: [nationkey:bigint, regionkey:bigint, name:varchar(25), comment:varchar(152), expr:bigint, name_2:varchar(25), regionkey_3:bigint, comment_4:varchar(152)] │ Distribution: REPLICATED ├─ ScanProject[table = test_catalog:tiny:nation] │ Layout: [nationkey:bigint, regionkey:bigint, name:varchar(25), comment:varchar(152), expr:bigint] │ expr := ("nationkey" + BIGINT '1') │ nationkey := tpch:nationkey │ regionkey := tpch:regionkey │ name := tpch:name │ comment := tpch:comment └─ LocalExchange[partitioning = SINGLE] │ Layout: [nationkey_1:bigint, name_2:varchar(25), regionkey_3:bigint, comment_4:varchar(152)] └─ TableScan[table = test_catalog:tiny:nation] Layout: [nationkey_1:bigint, name_2:varchar(25), regionkey_3:bigint, comment_4:varchar(152)] name_2 := tpch:name comment_4 := tpch:comment nationkey_1 := tpch:nationkey regionkey_3 := tpch:regionkey ]

Plan does not match, expected [ - node(OutputNode) - node(JoinNode) JoinMatcher{type=INNER, equiCriteria=[L_NATIONKEY = R_NATIONKEY], distributionType=Optional.empty, dynamicFilter=Optional.empty} - node(FilterNode) FilterMatcher{predicate=true} - node(TableScanNode) TableScanMatcher{expectedTableName=nation} bind L_NATIONKEY -> Column nation:nationkey - anyTree - node(TableScanNode) TableScanMatcher{expectedTableName=nation} bind R_NATIONKEY -> Column nation:nationkey ] but found [ Output[columnNames = [nationkey, name, regionkey, comment, nationkey2, nationkey, name, regionkey, comment]] │ Layout: [nationkey:bigint, name:varchar(25), regionkey:bigint, comment:varchar(152), expr:bigint, nationkey:bigint, name_2:varchar(25), regionkey_3:bigint, comment_4:varchar(152)] │ nationkey2 := expr │ name := name_2 │ regionkey := regionkey_3 │ comment := comment_4 └─ InnerJoin[criteria = ("nationkey" = "nationkey_1"), distribution = REPLICATED] │ Layout: [nationkey:bigint, regionkey:bigint, name:varchar(25), comment:varchar(152), expr:bigint, name_2:varchar(25), regionkey_3:bigint, comment_4:varchar(152)] │ Distribution: REPLICATED │ dynamicFilterAssignments = {nationkey_1 -> #df_303} ├─ ScanFilterProject[table = test_catalog:tiny:nation, dynamicFilters = {"nationkey" = #df_303}] │ Layout: [nationkey:bigint, regionkey:bigint, name:varchar(25), comment:varchar(152), expr:bigint] │ expr := ("nationkey" + BIGINT '1') │ nationkey := tpch:nationkey │ regionkey := tpch:regionkey │ name := tpch:name │ comment := tpch:comment └─ LocalExchange[partitioning = SINGLE] │ Layout: [nationkey_1:bigint, name_2:varchar(25), regionkey_3:bigint, comment_4:varchar(152)] └─ TableScan[table = test_catalog:tiny:nation] Layout: [nationkey_1:bigint, name_2:varchar(25), regionkey_3:bigint, comment_4:varchar(152)] name_2 := tpch:name comment_4 := tpch:comment nationkey_1 := tpch:nationkey regionkey_3 := tpch:regionkey ]