Update DatabaseReplicatedWorker.cpp

This commit is contained in:
tavplubix 2022-04-08 22:12:57 +03:00 committed by GitHub
parent faae540a85
commit 2894672ecc
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -319,7 +319,6 @@ bool DatabaseReplicatedDDLWorker::canRemoveQueueEntry(const String & entry_name,
void DatabaseReplicatedDDLWorker::initializeLogPointer(const String & processed_entry_name) void DatabaseReplicatedDDLWorker::initializeLogPointer(const String & processed_entry_name)
{ {
updateMaxDDLEntryID(processed_entry_name); updateMaxDDLEntryID(processed_entry_name);
assert(max_id.load() == parse<UInt32>(getAndSetZooKeeper()->get(fs::path(database->replica_path) / "log_ptr")));
} }
UInt32 DatabaseReplicatedDDLWorker::getLogPointer() const UInt32 DatabaseReplicatedDDLWorker::getLogPointer() const