Skip to content

[GLUTEN-8811][VL]Fallback bucket scan when enable partial cluster distribution #32500

[GLUTEN-8811][VL]Fallback bucket scan when enable partial cluster distribution

[GLUTEN-8811][VL]Fallback bucket scan when enable partial cluster distribution #32500

Triggered via pull request February 25, 2025 14:20
@jinchengchenghhjinchengchenghh
synchronize #8820
Status Success
Total duration 24s
Artifacts

dev_cron.yml

on: pull_request_target
Process
9s
Process
Fit to window
Zoom out
Zoom in

Annotations

2 errors
VeloxIcebergSuite.iceberg bucketed join with partition fallback by partial cluster: org/apache/gluten/execution/VeloxIcebergSuite#L1
assertion failed: FallBack false check error: VeloxColumnarToRow +- ^(1852) ProjectExecTransformer [id#48583, name#48584, name#48587, p#48588] +- ^(1852) ShuffledHashJoinExecTransformer [id#48583, p#48585], [id#48586, p#48588], Inner, BuildRight :- ^(1852) FilterExecTransformer (isnotnull(id#48583) AND isnotnull(p#48585)) : +- ^(1852) IcebergIcebergScanTransformer[id#48583, name#48584, p#48585] spark_catalog.default.p_str_tb [filters=id IS NOT NULL, p IS NOT NULL] RuntimeFilters: [] NativeFilters: [isnotnull(id#48583),isnotnull(p#48585)] +- ^(1852) FilterExecTransformer (isnotnull(id#48586) AND isnotnull(p#48588)) +- ^(1852) IcebergIcebergScanTransformer[id#48586, name#48587, p#48588] spark_catalog.default.p_int_tb [filters=id IS NOT NULL, p IS NOT NULL] RuntimeFilters: [] NativeFilters: [isnotnull(id#48586),isnotnull(p#48588)]
VeloxIcebergSuite.iceberg bucketed join with partition fallback by partial cluster: org/apache/gluten/execution/VeloxIcebergSuite#L1
assertion failed: FallBack false check error: VeloxColumnarToRow +- ^(1967) ProjectExecTransformer [id#56122, name#56123, name#56126, p#56127] +- ^(1967) ShuffledHashJoinExecTransformer [id#56122, p#56124], [id#56125, p#56127], Inner, BuildRight :- ^(1967) IcebergIcebergScanTransformer[id#56122, name#56123, p#56124] spark_catalog.default.p_str_tb (branch=null) [filters=id IS NOT NULL, p IS NOT NULL, groupedBy=id_bucket, p] RuntimeFilters: [] NativeFilters: [] +- ^(1967) IcebergIcebergScanTransformer[id#56125, name#56126, p#56127] spark_catalog.default.p_int_tb (branch=null) [filters=id IS NOT NULL, p IS NOT NULL, groupedBy=id_bucket, p] RuntimeFilters: [] NativeFilters: []