This is an automated email from the ASF dual-hosted git repository.
dataroaring 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 438010a214 [fix](merge-on-write) process error of delete bitmap
calculation (#23285)
438010a214 is described below
commit 438010a21403094d9e923a077dfb58517942dcbe
Author: zhannngchen <[email protected]>
AuthorDate: Tue Aug 22 10:53:50 2023 +0800
[fix](merge-on-write) process error of delete bitmap calculation (#23285)
---
be/src/olap/tablet.cpp | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/be/src/olap/tablet.cpp b/be/src/olap/tablet.cpp
index dd3ae58136..ad5aa2c82e 100644
--- a/be/src/olap/tablet.cpp
+++ b/be/src/olap/tablet.cpp
@@ -3262,8 +3262,8 @@ Status Tablet::update_delete_bitmap_without_lock(const
RowsetSharedPtr& rowset)
auto token =
StorageEngine::instance()->calc_delete_bitmap_executor()->create_token();
RETURN_IF_ERROR(calc_delete_bitmap(rowset, segments, specified_rowsets,
delete_bitmap,
cur_version - 1, token.get()));
- token->wait();
- token->get_delete_bitmap(delete_bitmap);
+ RETURN_IF_ERROR(token->wait());
+ RETURN_IF_ERROR(token->get_delete_bitmap(delete_bitmap));
size_t total_rows = std::accumulate(
segments.begin(), segments.end(), 0,
[](size_t sum, const segment_v2::SegmentSharedPtr& s) { return sum
+= s->num_rows(); });
@@ -3363,8 +3363,8 @@ Status Tablet::update_delete_bitmap(const
RowsetSharedPtr& rowset,
auto token =
StorageEngine::instance()->calc_delete_bitmap_executor()->create_token();
RETURN_IF_ERROR(calc_delete_bitmap(rowset, segments, specified_rowsets,
delete_bitmap,
cur_version - 1, token.get(),
rowset_writer));
- token->wait();
- token->get_delete_bitmap(delete_bitmap);
+ RETURN_IF_ERROR(token->wait());
+ RETURN_IF_ERROR(token->get_delete_bitmap(delete_bitmap));
size_t total_rows = std::accumulate(
segments.begin(), segments.end(), 0,
[](size_t sum, const segment_v2::SegmentSharedPtr& s) { return sum
+= s->num_rows(); });
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
