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

[fix](migrate) migrate check old tablet had deleted (#29909)

Browse Source
This commit is contained in:
yujun
2024-01-12 21:12:01 +08:00
committed by yiguolei
parent e3a1138da7
commit c599cf311d
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
be/src/olap/task/engine_storage_migration_task.cpp
View File

@ -125,6 +125,10 @@ Status EngineStorageMigrationTask::_check_running_txns_until_timeout(
// to avoid invalid loops, the lock is guaranteed to be acquired here
{
std::unique_lock<std::shared_mutex> wlock(_tablet->get_migration_lock());
if (_tablet->tablet_state() == TABLET_SHUTDOWN) {
return Status::Error<ErrorCode::INTERNAL_ERROR, false>("tablet {} has deleted",
_tablet->tablet_id());
}
res = _check_running_txns();
if (res.ok()) {
// transfer the lock to the caller
@ -160,6 +164,10 @@ Status EngineStorageMigrationTask::_gen_and_write_header_to_hdr_file(
}
Status EngineStorageMigrationTask::_reload_tablet(const std::string& full_path) {
if (_tablet->tablet_state() == TABLET_SHUTDOWN) {
return Status::Error<ErrorCode::INTERNAL_ERROR, false>("tablet {} has deleted",
_tablet->tablet_id());
}
// need hold migration lock and push lock outside
int64_t tablet_id = _tablet->tablet_id();
int32_t schema_hash = _tablet->schema_hash();