This is an automated email from the ASF dual-hosted git repository.
kxiao 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 de98324ea7 [fix](inverted index change) make mutex for
ALTER_INVERTED_INDEX task and STORAGE_MEDIUM_MIGRATE task (#22995)
de98324ea7 is described below
commit de98324ea773a630bb83e6a0a1e6b815e2447a58
Author: YueW <45946325+tany...@users.noreply.github.com>
AuthorDate: Fri Aug 18 08:35:30 2023 +0800
[fix](inverted index change) make mutex for ALTER_INVERTED_INDEX task and
STORAGE_MEDIUM_MIGRATE task (#22995)
---
be/src/olap/task/index_builder.cpp | 6 ++++++
1 file changed, 6 insertions(+)
diff --git a/be/src/olap/task/index_builder.cpp
b/be/src/olap/task/index_builder.cpp
index 67e39104c6..147d9c7b93 100644
--- a/be/src/olap/task/index_builder.cpp
+++ b/be/src/olap/task/index_builder.cpp
@@ -398,6 +398,12 @@ Status IndexBuilder::do_build_inverted_index() {
"failed to obtain build inverted index lock. tablet={}",
_tablet->tablet_id());
}
+ std::shared_lock migration_rlock(_tablet->get_migration_lock(),
std::try_to_lock);
+ if (!migration_rlock.owns_lock()) {
+ return Status::Error<ErrorCode::TRY_LOCK_FAILED>("got migration_rlock
failed. tablet={}",
+ _tablet->full_name());
+ }
+
_input_rowsets =
_tablet->pick_candidate_rowsets_to_build_inverted_index(_alter_index_ids,
_is_drop_op);
if (_input_rowsets.empty()) {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
