From 6faa4dd20c7d9182f21a4f9f1c6cc1e6a83258cd Mon Sep 17 00:00:00 2001
From: Igor Nikonov <igor@clickhouse.com>
Date: Wed, 15 May 2024 11:19:03 +0000
Subject: [PATCH] Fix

---
 src/Planner/PlannerJoinTree.cpp | 11 +++++------
 1 file changed, 5 insertions(+), 6 deletions(-)

diff --git a/src/Planner/PlannerJoinTree.cpp b/src/Planner/PlannerJoinTree.cpp
index 42374cd1cdf..158bcd94380 100644
--- a/src/Planner/PlannerJoinTree.cpp
+++ b/src/Planner/PlannerJoinTree.cpp
@@ -873,19 +873,18 @@ JoinTreeQueryPlan buildQueryPlanForTableExpression(QueryTreeNodePtr table_expres
                     ReadFromMergeTree * reading = nullptr;
                     while (node)
                     {
-                        IQueryPlanStep * step = typeid_cast<ISourceStep *>(node->step.get());
-                        if (step)
-                        {
-                            reading = typeid_cast<ReadFromMergeTree *>(step);
+                        reading = typeid_cast<ReadFromMergeTree *>(node->step.get());
+                        if (reading)
                             break;
-                        }
 
                         if (!node->children.empty())
                             node = node->children.at(0);
                     }
 
+                    chassert(reading);
+
                     // (2) if it's ReadFromMergeTree - run index analysis and check number of rows to read
-                    if (reading && settings.parallel_replicas_min_number_of_rows_per_replica > 0)
+                    if (settings.parallel_replicas_min_number_of_rows_per_replica > 0)
                     {
                         auto result_ptr = reading->selectRangesToRead(reading->getParts(), reading->getAlterConvertionsForParts());