thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-17 13:13:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

Trying without fsync

Browse Source
This commit is contained in:
alesapin 2021-02-17 22:32:38 +03:00
parent bb4ced05f9
commit 6e244e7bb1
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/Coordination/Changelog.cpp
View File

@ -298,7 +298,7 @@ void Changelog::appendEntry(size_t index, nuraft::ptr<nuraft::log_entry> log_ent
if (current_writer->getEntriesWritten() == rotate_interval)
rotate(index);
auto offset = current_writer->appendRecord(buildRecord(index, log_entry), true);
auto offset = current_writer->appendRecord(buildRecord(index, log_entry), false);
if (!index_to_start_pos.try_emplace(index, offset).second)
throw Exception(ErrorCodes::LOGICAL_ERROR, "Record with index {} already exists", index);

2
src/Coordination/Changelog.h
View File

@ -101,7 +101,7 @@ public:
private:
void rotate(size_t new_start_log_idex);
void rotate(size_t new_start_log_idx);
ChangelogRecord buildRecord(size_t index, nuraft::ptr<nuraft::log_entry> log_entry) const;