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

[Fix](inverted index) remove IndexReader::indexExists, use fs interface (#20970)

Browse Source
This commit is contained in:
airborne12
2023-06-20 15:22:25 +08:00
committed by GitHub
parent f4d3f4ae19
commit ccba11d7ea
1 changed files with 15 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
be/src/olap/rowset/segment_v2/inverted_index_writer.cpp
View File

@ -133,13 +133,21 @@ public:
_directory + "/" + _segment_file_name, _index_meta->index_id());
// LOG(INFO) << "inverted index path: " << index_path;
if (lucene::index::IndexReader::indexExists(index_path.c_str())) {
create = false;
if (lucene::index::IndexReader::isLocked(index_path.c_str())) {
LOG(WARNING) << ("Lucene Index was locked... unlocking it.\n");
lucene::index::IndexReader::unlock(index_path.c_str());
}
bool exists = false;
auto st = _fs->exists(index_path.c_str(), &exists);
if (!st.ok()) {
LOG(ERROR) << "index_path:"
<< " exists error:" << st;
return st;
}
if (exists) {
LOG(ERROR) << "try to init a directory:" << index_path << " already exists";
return Status::InternalError("init_fulltext_index a directory already exists");
//st = _fs->delete_directory(index_path.c_str());
//if (!st.ok()) {
// LOG(ERROR) << "delete directory:" << index_path << " error:" << st;
// return st;
//}
}
_char_string_reader = std::make_unique<lucene::util::SStringReader<char>>();