-
Notifications
You must be signed in to change notification settings - Fork 1.3k
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
Simplify parquet filter predicate test, fix Page Filtering Incorrectly Handles Pages with Different Row Counts #4743
Simplify parquet filter predicate test, fix Page Filtering Incorrectly Handles Pages with Different Row Counts #4743
Conversation
|
||
let mut set = tokio::task::JoinSet::new(); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I reverted the JoinSet change as the test now runs in under 2 seconds, and it made debugging test failures difficult as the stack trace pointed to where the JoinHandle is unwrapped, not the case that actually failed. It also made the failures non-deterministic, which was also annoying
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
cc @waynexia
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Looks good to me. It also takes me some time to figure out which sub-case fails. If the time is greatly shortened, I agree we need not pay for the parallel
@@ -251,7 +251,7 @@ fn prune_pages_in_one_row_group( | |||
let mut sum_row = *row_vec.first().unwrap(); | |||
let mut selected = *values.first().unwrap(); | |||
trace!("Pruned to to {:?} using {:?}", values, pruning_stats); | |||
for (i, &f) in values.iter().skip(1).enumerate() { | |||
for (i, &f) in values.iter().enumerate().skip(1) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This is the cause of #4744
36dcfd0
to
6654e44
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thank you @tustvold
|
||
let mut set = tokio::task::JoinSet::new(); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
cc @waynexia
.with_filter( | ||
conjunction(vec![ | ||
col("request_bytes").gt(lit(2000000000)), | ||
col("client_addr").eq(lit("58.242.143.99")), |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Is the case of a pruning on a non equality predicate on a non dictionary encoded column covered elsewhere?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks for this 👍
Suffered covid these days , sorry for the late respond.
I'm looking into the other test failures, I'm hoping the tests are wrong |
// vec.push(RowSelector::skip(894)); | ||
// vec.push(RowSelector::select(339)); | ||
// vec.push(RowSelector::skip(3330)); | ||
// `month = 1` or `month = 2` from the page index should create below RowSelection |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
These tests were just wrong, I have fixed them using apache/arrow-rs#3405 to verify that they are correct
Benchmark runs are scheduled for baseline = 3abbffb and contender = 40bf559. 40bf559 is a master commit associated with this PR. Results will be available as each benchmark for each run completes. |
Which issue does this PR close?
Closes #4744
Rationale for this change
What changes are included in this PR?
Are these changes tested?
Are there any user-facing changes?