This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 5c9e0d906a5 [Fix](segment iterator) fix wrong segment cache remove
(#29333)
5c9e0d906a5 is described below
commit 5c9e0d906a572a12098ea368598d894699192aa5
Author: airborne12 <airborn...@gmail.com>
AuthorDate: Sat Dec 30 08:36:15 2023 +0800
[Fix](segment iterator) fix wrong segment cache remove (#29333)
---
be/src/olap/rowset/segment_v2/segment_iterator.cpp | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/be/src/olap/rowset/segment_v2/segment_iterator.cpp
b/be/src/olap/rowset/segment_v2/segment_iterator.cpp
index 6bc01ea0d4b..5c30423bb53 100644
--- a/be/src/olap/rowset/segment_v2/segment_iterator.cpp
+++ b/be/src/olap/rowset/segment_v2/segment_iterator.cpp
@@ -2074,7 +2074,8 @@ Status
SegmentIterator::_read_columns_by_rowids(std::vector<ColumnId>& read_colu
Status SegmentIterator::next_batch(vectorized::Block* block) {
auto status = [&]() { RETURN_IF_CATCH_EXCEPTION({ return
_next_batch_internal(block); }); }();
- if (!status.ok()) {
+ // if rows read by batch is 0, will return end of file, we should not
remove segment cache in this situation.
+ if (!status.ok() && !status.is<END_OF_FILE>()) {
_segment->remove_from_segment_cache();
}
return status;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
