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();	/// Чтобы вместо засечек, указывающих на конец сжатого блока, были засечки, указывающие на начало следующего.