diff --git a/dbms/src/Storages/MergeTree/MergeTreeDataSelectExecutor.cpp b/dbms/src/Storages/MergeTree/MergeTreeDataSelectExecutor.cpp
index a3f59080ba0..911c3f6094a 100644
--- a/dbms/src/Storages/MergeTree/MergeTreeDataSelectExecutor.cpp
+++ b/dbms/src/Storages/MergeTree/MergeTreeDataSelectExecutor.cpp
@@ -254,8 +254,6 @@ BlockInputStreams MergeTreeDataSelectExecutor::read(
 		}
 	}
 
-	RangesInDataParts * final_parts_with_ranges = nullptr;
-
 	if (settings.parallel_replicas_count > 1)
 	{
 		PartsWithRangesSplitter splitter(parts_with_ranges, sum_marks, data.settings.min_rows_for_seek,
@@ -285,20 +283,18 @@ BlockInputStreams MergeTreeDataSelectExecutor::read(
 					return lhs.first < rhs.first;
 				});
 
-				final_parts_with_ranges = hashed_segments[settings.parallel_replica_offset].second;
+				parts_with_ranges = std::move(*(hashed_segments[settings.parallel_replica_offset].second));
 
 				/// Пересчитываем количество засечек и диапазонов.
 				sum_marks = 0;
 				sum_ranges = 0;
-				for (const auto & part_with_ranges : *final_parts_with_ranges)
+				for (const auto & part_with_ranges : parts_with_ranges)
 				{
 					sum_ranges += part_with_ranges.ranges.size();
 					for (const auto & range : part_with_ranges.ranges)
 						sum_marks += range.end - range.begin;
 				}
 			}
-			else
-				final_parts_with_ranges = &parts_with_ranges;
 		}
 		else
 		{
@@ -306,10 +302,8 @@ BlockInputStreams MergeTreeDataSelectExecutor::read(
 			return res;
 		}
 	}
-	else 
-		final_parts_with_ranges = &parts_with_ranges;
 
-	LOG_DEBUG(log, "Selected " << parts.size() << " parts by date, " << final_parts_with_ranges->size() << " parts by key, "
+	LOG_DEBUG(log, "Selected " << parts.size() << " parts by date, " << parts_with_ranges.size() << " parts by key, "
 			  << sum_marks << " marks to read from " << sum_ranges << " ranges");
 
 	BlockInputStreams res;
@@ -324,7 +318,7 @@ BlockInputStreams MergeTreeDataSelectExecutor::read(
 		column_names_to_read.erase(std::unique(column_names_to_read.begin(), column_names_to_read.end()), column_names_to_read.end());
 
 		res = spreadMarkRangesAmongThreadsFinal(
-			*final_parts_with_ranges,
+			parts_with_ranges,
 			threads,
 			column_names_to_read,
 			max_block_size,
@@ -336,7 +330,7 @@ BlockInputStreams MergeTreeDataSelectExecutor::read(
 	else
 	{
 		res = spreadMarkRangesAmongThreads(
-			*final_parts_with_ranges,
+			parts_with_ranges,
 			threads,
 			column_names_to_read,
 			max_block_size,