diff --git a/dbms/src/Storages/MergeTree/ReplicatedMergeTreeLogEntry.cpp b/dbms/src/Storages/MergeTree/ReplicatedMergeTreeLogEntry.cpp index e41da525f55e2f62fb3232909f2034e16e034af9..9d1a40b3f694ea9089f24ade4fedf8fe21ade46e 100644 --- a/dbms/src/Storages/MergeTree/ReplicatedMergeTreeLogEntry.cpp +++ b/dbms/src/Storages/MergeTree/ReplicatedMergeTreeLogEntry.cpp @@ -107,14 +107,15 @@ void ReplicatedMergeTreeLogEntry::readText(ReadBuffer & in) create_time = create_time_dt; } - in >> "source replica: " >> source_replica >> "\n" - >> type_str >> "\n"; + in >> "source replica: " >> source_replica >> "\n"; if (format_version >= 3) { in >> "block_id: " >> escape >> block_id >> "\n"; } + in >> type_str >> "\n"; + if (type_str == "get") { type = GET_PART;