From a138e8efdf96f785e15a1e413262ae571f96f04e Mon Sep 17 00:00:00 2001 From: Sergey Fedorov Date: Fri, 28 Mar 2014 20:01:36 +0400 Subject: [PATCH] dbms: insignificant fix in checking if block is ready for compression [METR-10570] --- dbms/include/DB/Storages/MergeTree/MergedBlockOutputStream.h | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/dbms/include/DB/Storages/MergeTree/MergedBlockOutputStream.h b/dbms/include/DB/Storages/MergeTree/MergedBlockOutputStream.h index fac3b5166e2..47e7f0ccf1c 100644 --- a/dbms/include/DB/Storages/MergeTree/MergedBlockOutputStream.h +++ b/dbms/include/DB/Storages/MergeTree/MergedBlockOutputStream.h @@ -132,7 +132,7 @@ protected: type_arr->serializeOffsets(column, stream.compressed, prev_mark, limit); /// Уже могло накопиться достаточно данных для сжатия в новый блок. - if (stream.compressed.offset() > storage.context.getSettings().min_compress_block_size) + if (stream.compressed.offset() >= storage.context.getSettings().min_compress_block_size) stream.compressed.next(); else stream.compressed.nextIfAtEnd(); /// Чтобы вместо засечек, указывающих на конец сжатого блока, были засечки, указывающие на начало следующего. @@ -163,7 +163,7 @@ protected: type.serializeBinary(column, stream.compressed, prev_mark, limit); /// Уже могло накопиться достаточно данных для сжатия в новый блок. - if (stream.compressed.offset() > storage.context.getSettings().min_compress_block_size) + if (stream.compressed.offset() >= storage.context.getSettings().min_compress_block_size) stream.compressed.next(); else stream.compressed.nextIfAtEnd(); /// Чтобы вместо засечек, указывающих на конец сжатого блока, были засечки, указывающие на начало следующего.