From b6139c17bc1a2cf32ea05c9e750c64cf085fffa7 Mon Sep 17 00:00:00 2001 From: Michael Kolupaev Date: Mon, 3 Dec 2012 10:43:25 +0000 Subject: [PATCH] Merge --- dbms/src/Storages/StorageMergeTree.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dbms/src/Storages/StorageMergeTree.cpp b/dbms/src/Storages/StorageMergeTree.cpp index 9a6753aa921..571c24c2e1e 100644 --- a/dbms/src/Storages/StorageMergeTree.cpp +++ b/dbms/src/Storages/StorageMergeTree.cpp @@ -1123,7 +1123,7 @@ BlockInputStreams StorageMergeTree::read( for (size_t i = 0; i < effective_threads && marks_spread < sum_marks; ++i) { - size_t need_marks = std::min((sum_marks - 1) / effective_threads, sum_marks - marks_spread); + size_t need_marks = std::min((sum_marks - 1) / effective_threads + 1, sum_marks - marks_spread); BlockInputStreams streams; while (need_marks > 0)