Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[core] [bug] Partition should not be filtered when manifest file predicate and file itself all min/max is null #3421

Merged
merged 5 commits into from
May 29, 2024

Conversation

leaves12138
Copy link
Contributor

Purpose

Linked issue: close #xxx

Tests

API and Format

Documentation

@leaves12138 leaves12138 changed the title [core] [bug] Fix partition should not be filtered when predicate and file all values is null [core] [bug] Fix partition should not be filtered when manifest file predicate and file itself all min/max is null May 29, 2024
yejunhao added 2 commits May 29, 2024 09:53
@leaves12138 leaves12138 changed the title [core] [bug] Fix partition should not be filtered when manifest file predicate and file itself all min/max is null [core] [bug] Partition should not be filtered when manifest file predicate and file itself all min/max is null May 29, 2024
Copy link
Contributor

@JingsongLi JingsongLi left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

See PredicateBuilder.equalPartition too.

@JingsongLi
Copy link
Contributor

See RowDataToObjectArrayConverter.createEqualPredicate.

@JingsongLi
Copy link
Contributor

See SnapshotReaderImpl.withPartitionFilter.

yejunhao added 2 commits May 29, 2024 11:31
@leaves12138
Copy link
Contributor Author

FileStoreLookupFunction.createSpecificPartFilter

@leaves12138
Copy link
Contributor Author

PredicateBuilder.partition(Map<String, String> map, RowType rowType)

Object maxValue = stats.max();

min[i] = minValue == null ? builder.isNull(i) : builder.greaterOrEqual(i, minValue);
max[i] = maxValue == null ? builder.isNull(i) : builder.lessOrEqual(i, maxValue);
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Seems wrong logic here.
Collector should not collect null values.

Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I see, if it is null, all values are null.

@JingsongLi
Copy link
Contributor

+1

@JingsongLi JingsongLi merged commit 1a3959b into apache:master May 29, 2024
9 checks passed
leaves12138 added a commit to leaves12138/incubator-paimon that referenced this pull request May 30, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants