This is an automated email from the ASF dual-hosted git repository.
zhangchen 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 a6311e2f95 fix erase (#22235)
a6311e2f95 is described below
commit a6311e2f951c77ef7fd2df790fda0e3a5d2a700e
Author: bobhan1 <[email protected]>
AuthorDate: Wed Jul 26 17:06:37 2023 +0800
fix erase (#22235)
---
be/src/runtime/tablets_channel.cpp | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/be/src/runtime/tablets_channel.cpp
b/be/src/runtime/tablets_channel.cpp
index 2d007d7e54..6d94b00007 100644
--- a/be/src/runtime/tablets_channel.cpp
+++ b/be/src/runtime/tablets_channel.cpp
@@ -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
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
