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

[fix](regression) fix group commit regression test (#26519)

Browse Source
This commit is contained in:
meiyi
2023-11-07 18:17:45 +08:00
committed by GitHub
parent ef95e962c7
commit a404ff5ab9
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
be/src/runtime/stream_load/new_load_stream_mgr.h
View File

@ -45,12 +45,14 @@ public:
{
std::lock_guard<std::mutex> l(_lock);
if (auto iter = _stream_map.find(id); iter != _stream_map.end()) {
return Status::InternalError("id already exist");
std::stringstream ss;
ss << "id: " << id << " already exist";
return Status::InternalError(ss.str());
}
_stream_map.emplace(id, stream);
}
VLOG_NOTICE << "put stream load pipe: " << id;
LOG(INFO) << "put stream load pipe: " << id;
return Status::OK();
}
@ -61,6 +63,7 @@ public:
return iter->second;
}
}
LOG(INFO) << "stream load pipe does not exist: " << id;
return nullptr;
}
@ -68,7 +71,7 @@ public:
std::lock_guard<std::mutex> l(_lock);
if (auto iter = _stream_map.find(id); iter != _stream_map.end()) {
_stream_map.erase(iter);
VLOG_NOTICE << "remove stream load pipe: " << id;
LOG(INFO) << "remove stream load pipe: " << id;
}
}