milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

#599 Build index log is incorrect

pull/600/head
groot 2019-11-28 17:56:04 +08:00
parent 07d5395d8d
commit bdf531524b
3 changed files with 18 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
CHANGELOG.md
View File

@ -35,6 +35,7 @@ Please mark all change in change log and use the ticket from JIRA.
- \#545 - Avoid dead circle of build index thread when error occurs - \#545 - Avoid dead circle of build index thread when error occurs
- \#552 - Server down during building index_type: IVF_PQ using GPU-edition - \#552 - Server down during building index_type: IVF_PQ using GPU-edition
- \#561 - Milvus server should report exception/error message or terminate on mysql metadata backend error - \#561 - Milvus server should report exception/error message or terminate on mysql metadata backend error
- \#599 - Build index log is incorrect
## Feature ## Feature
- \#12 - Pure CPU version for Milvus - \#12 - Pure CPU version for Milvus

19
core/src/db/meta/MySQLMetaImpl.cpp
View File

@ -1615,32 +1615,31 @@ MySQLMetaImpl::FilesByType(const std::string& table_id, const std::vector<int>&
} }
} }
std::string msg = "Get table files by type. "; std::string msg = "Get table files by type.";
for (int file_type : file_types) { for (int file_type : file_types) {
switch (file_type) { switch (file_type) {
case (int)TableFileSchema::RAW: case (int)TableFileSchema::RAW:
msg = msg + "raw files:" + std::to_string(raw_count); msg = msg + " raw files:" + std::to_string(raw_count);
break; break;
case (int)TableFileSchema::NEW: case (int)TableFileSchema::NEW:
msg = msg + "new files:" + std::to_string(raw_count); msg = msg + " new files:" + std::to_string(new_count);
break; break;
case (int)TableFileSchema::NEW_MERGE: case (int)TableFileSchema::NEW_MERGE:
msg = msg + "new_merge files:" + std::to_string(raw_count); msg = msg + " new_merge files:" + std::to_string(new_merge_count);
break; break;
case (int)TableFileSchema::NEW_INDEX: case (int)TableFileSchema::NEW_INDEX:
msg = msg + "new_index files:" + std::to_string(raw_count); msg = msg + " new_index files:" + std::to_string(new_index_count);
break; break;
case (int)TableFileSchema::TO_INDEX: case (int)TableFileSchema::TO_INDEX:
msg = msg + "to_index files:" + std::to_string(raw_count); msg = msg + " to_index files:" + std::to_string(to_index_count);
break; break;
case (int)TableFileSchema::INDEX: case (int)TableFileSchema::INDEX:
msg = msg + "index files:" + std::to_string(raw_count); msg = msg + " index files:" + std::to_string(index_count);
break; break;
case (int)TableFileSchema::BACKUP: case (int)TableFileSchema::BACKUP:
msg = msg + "backup files:" + std::to_string(raw_count); msg = msg + " backup files:" + std::to_string(backup_count);
break;
default:
break; break;
default:break;
} }
} }
ENGINE_LOG_DEBUG << msg; ENGINE_LOG_DEBUG << msg;

16
core/src/db/meta/SqliteMetaImpl.cpp
View File

@ -1157,29 +1157,29 @@ SqliteMetaImpl::FilesByType(const std::string& table_id,
table_files.emplace_back(file_schema); table_files.emplace_back(file_schema);
} }
std::string msg = "Get table files by type. "; std::string msg = "Get table files by type.";
for (int file_type : file_types) { for (int file_type : file_types) {
switch (file_type) { switch (file_type) {
case (int)TableFileSchema::RAW: case (int)TableFileSchema::RAW:
msg = msg + "raw files:" + std::to_string(raw_count); msg = msg + " raw files:" + std::to_string(raw_count);
break; break;
case (int)TableFileSchema::NEW: case (int)TableFileSchema::NEW:
msg = msg + "new files:" + std::to_string(raw_count); msg = msg + " new files:" + std::to_string(new_count);
break; break;
case (int)TableFileSchema::NEW_MERGE: case (int)TableFileSchema::NEW_MERGE:
msg = msg + "new_merge files:" + std::to_string(raw_count); msg = msg + " new_merge files:" + std::to_string(new_merge_count);
break; break;
case (int)TableFileSchema::NEW_INDEX: case (int)TableFileSchema::NEW_INDEX:
msg = msg + "new_index files:" + std::to_string(raw_count); msg = msg + " new_index files:" + std::to_string(new_index_count);
break; break;
case (int)TableFileSchema::TO_INDEX: case (int)TableFileSchema::TO_INDEX:
msg = msg + "to_index files:" + std::to_string(raw_count); msg = msg + " to_index files:" + std::to_string(to_index_count);
break; break;
case (int)TableFileSchema::INDEX: case (int)TableFileSchema::INDEX:
msg = msg + "index files:" + std::to_string(raw_count); msg = msg + " index files:" + std::to_string(index_count);
break; break;
case (int)TableFileSchema::BACKUP: case (int)TableFileSchema::BACKUP:
msg = msg + "backup files:" + std::to_string(raw_count); msg = msg + " backup files:" + std::to_string(backup_count);
break; break;
default:break; default:break;
} }