database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

fix erase (#22235)

Browse Source
This commit is contained in:
bobhan1
2023-07-26 17:06:37 +08:00
committed by GitHub
parent 9451382428
commit a6311e2f95
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
be/src/runtime/tablets_channel.cpp
View File

@ -196,7 +196,7 @@ Status TabletsChannel::close(
}
// 3. build rowset
for (auto it = need_wait_writers.begin(); it != need_wait_writers.end(); it++) {
for (auto it = need_wait_writers.begin(); it != need_wait_writers.end();) {
Status st = (*it)->build_rowset();
if (!st.ok()) {
_add_error_tablet(tablet_errors, (*it)->tablet_id(), st);
@ -210,16 +210,18 @@ Status TabletsChannel::close(
it = need_wait_writers.erase(it);
continue;
}
it++;
}
// 4. wait for delete bitmap calculation complete if necessary
for (auto it = need_wait_writers.begin(); it != need_wait_writers.end(); it++) {
for (auto it = need_wait_writers.begin(); it != need_wait_writers.end();) {
Status st = (*it)->wait_calc_delete_bitmap();
if (!st.ok()) {
_add_error_tablet(tablet_errors, (*it)->tablet_id(), st);
it = need_wait_writers.erase(it);
continue;
}
it++;
}
// 5. commit all writers