-
Notifications
You must be signed in to change notification settings - Fork 1.8k
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
[BugFix] Fix iceberg position delete bug in orc format #34682
Conversation
Signed-off-by: Smith Cruise <[email protected]>
@@ -1161,7 +1161,7 @@ ColumnPtr OrcChunkReader::get_row_delete_filter(const std::set<int64_t>& deleted | |||
ColumnPtr filter_column = BooleanColumn::create(num_rows, 1); | |||
auto& filter = static_cast<BooleanColumn*>(filter_column.get())->get_data(); | |||
auto iter = deleted_pos.lower_bound(start_pos); | |||
auto end = deleted_pos.upper_bound(start_pos + num_rows); | |||
auto end = deleted_pos.upper_bound(start_pos + num_rows - 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.
Is it posible that the start_pos
and num_rows
are 0 ?
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.
before call get_row_delete_filter()
, we will call _orc_reader->read_next()
first. If num_rows is 0, read_next()
function will return EOF directly, the code can't go here.
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.
before call
get_row_delete_filter()
, we will call_orc_reader->read_next()
first. If num_rows is 0,read_next()
function will return EOF directly, the code can't go here.
OK
[FE Incremental Coverage Report]✅ pass : 0 / 0 (0%) |
[BE Incremental Coverage Report]❌ fail : 14 / 21 (66.67%) file detail
|
@Mergifyio backport branch-3.2 |
@Mergifyio backport branch-3.1 |
@Mergifyio backport branch-3.0 |
✅ Backports have been created
|
✅ Backports have been created
|
✅ Backports have been created
|
Signed-off-by: Smith Cruise <[email protected]> (cherry picked from commit fa39811)
Signed-off-by: Smith Cruise <[email protected]> (cherry picked from commit fa39811) # Conflicts: # be/src/exec/hdfs_scanner.h # be/src/exec/hdfs_scanner_parquet.cpp # be/src/formats/parquet/group_reader.cpp
Signed-off-by: Smith Cruise <[email protected]> (cherry picked from commit fa39811) # Conflicts: # be/src/exec/hdfs_scanner.h # be/src/exec/hdfs_scanner_orc.cpp # be/src/exec/hdfs_scanner_parquet.cpp # be/src/formats/parquet/group_reader.cpp
Signed-off-by: Smith Cruise <[email protected]> (cherry picked from commit fa39811)
Fixes orc iceberg position delete bug and extract iceberg v2 stats
What type of PR is this:
Does this PR entail a change in behavior?
If yes, please specify the type of change:
Checklist:
Bugfix cherry-pick branch check: