The GitHub Actions job "CI" on fluss.git/feat/fix-partition-pruning-types has 
failed.
Run started by GitHub user fresh-borzoni (triggered by fresh-borzoni).

Head commit for run:
5b6aee74579674704811da3ad56c1f7518af5057 / Anton Borisov 
<[email protected]>
[flink][spark] Fix partition pruning for non-string partition keys

Partition predicate pushdown stringified literals and partition values
before evaluation, so range comparisons fell back to string lexicographic
order. An INT partition column with values 2 and 10 under WHERE pt > 2
lex-compared "10" < "2" and incorrectly dropped partition 10.

Add PartitionUtils.toPartitionRow and PartitionUtils.partitionRowType in
fluss-common. Use them from SparkPartitionPredicate and
FlinkSourceEnumerator; drop the stringify step in FlinkTableSource and
delete StringifyPredicateVisitor.

Regression tests added with an INT partition column and a range predicate
in SparkLogTableReadTest and FlinkTableSourceITCase.

Closes #3292.

Report URL: https://github.com/apache/fluss/actions/runs/25896295660

With regards,
GitHub Actions via GitBox

Reply via email to