Only log null spooling stats in FTE mode #32575
dekimirAnnotations
2 errors
|
TestPredicatePushdownWithoutDynamicFilter.testDoesNotCreatePredicateFromInferredPredicate:
io/trino/sql/planner/TestPredicatePushdownWithoutDynamicFilter#L183
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
]
|
|
TestPredicatePushdown.testDoesNotCreatePredicateFromInferredPredicate:
io/trino/sql/planner/TestPredicatePushdown#L1
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
]
|