From 89e91f3dc48c28f461dca241d8f8526013e53709 Mon Sep 17 00:00:00 2001
From: Michael Kolupaev <mkolupaev@yandex-team.ru>
Date: Fri, 28 Feb 2014 14:32:07 +0400
Subject: [PATCH] Merge

---
 dbms/src/Storages/StorageMergeTree.cpp | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/dbms/src/Storages/StorageMergeTree.cpp b/dbms/src/Storages/StorageMergeTree.cpp
index 4e55321ed7c..0dfaf55badd 100644
--- a/dbms/src/Storages/StorageMergeTree.cpp
+++ b/dbms/src/Storages/StorageMergeTree.cpp
@@ -102,6 +102,7 @@ StorageMergeTree::StorageMergeTree(
 	merge_threads = new boost::threadpool::pool(settings.merging_threads);
 	
 	loadDataParts();
+	clearOldParts();
 
 	UInt64 max_part_id = 0;
 	for (DataParts::iterator it = data_parts.begin(); it != data_parts.end(); ++it)
@@ -769,7 +770,7 @@ void StorageMergeTree::mergeThread(bool while_can, bool aggressive)
 	{
 		while (!shutdown_called)
 		{
-			/// Удаляем старые куски.
+			/// Удаляем старые куски. На случай, если в слиянии что-то сломано, и из следующего блока вылетит исключение.
 			clearOldParts();
 
 			{
@@ -785,6 +786,9 @@ void StorageMergeTree::mergeThread(bool while_can, bool aggressive)
 			if (shutdown_called)
 				break;
 
+			/// Удаляем куски, которые мы только что сливали.
+			clearOldParts();
+
 			if (!while_can)
 				break;
 		}