From 443a3e7e6fd2452bf3efa8e4ab2a349feaf3b29f Mon Sep 17 00:00:00 2001
From: Nikolai Kochetov <nik-kochetov@yandex-team.ru>
Date: Fri, 12 Feb 2021 13:12:31 +0300
Subject: [PATCH] Fix limit push down.

---
 src/Processors/QueryPlan/Optimizations/Optimizations.h    | 4 ++--
 src/Processors/QueryPlan/Optimizations/filterPushDown.cpp | 6 +++---
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/src/Processors/QueryPlan/Optimizations/Optimizations.h b/src/Processors/QueryPlan/Optimizations/Optimizations.h
index be7f81e5db0..a5c3af488a9 100644
--- a/src/Processors/QueryPlan/Optimizations/Optimizations.h
+++ b/src/Processors/QueryPlan/Optimizations/Optimizations.h
@@ -40,7 +40,7 @@ size_t tryMergeExpressions(QueryPlan::Node * parent_node, QueryPlan::Nodes &);
 
 /// Move FilterStep down if possible.
 /// May split FilterStep and push down only part of it.
-size_t tryPushDownLimit(QueryPlan::Node * parent_node, QueryPlan::Nodes & nodes);
+size_t tryPushDownFilter(QueryPlan::Node * parent_node, QueryPlan::Nodes & nodes);
 
 inline const auto & getOptimizations()
 {
@@ -50,7 +50,7 @@ inline const auto & getOptimizations()
         {tryPushDownLimit, "pushDownLimit"},
         {trySplitFilter, "splitFilter"},
         {tryMergeExpressions, "mergeExpressions"},
-        {tryPushDownLimit, "pushDownFilter"},
+        {tryPushDownFilter, "pushDownFilter"},
      }};
 
     return optimizations;
diff --git a/src/Processors/QueryPlan/Optimizations/filterPushDown.cpp b/src/Processors/QueryPlan/Optimizations/filterPushDown.cpp
index a5f1d37e2f2..ac95d69d237 100644
--- a/src/Processors/QueryPlan/Optimizations/filterPushDown.cpp
+++ b/src/Processors/QueryPlan/Optimizations/filterPushDown.cpp
@@ -42,11 +42,11 @@ size_t tryPushDownLimit(QueryPlan::Node * parent_node, QueryPlan::Nodes & nodes)
         for (auto pos : params.keys)
             keys.push_back(params.src_header.getByPosition(pos).name);
 
-        // std::cerr << "Filter: \n" << expression->dumpDAG() << std::endl;
+        std::cerr << "Filter: \n" << expression->dumpDAG() << std::endl;
         if (auto split_filter = expression->splitActionsForFilter(filter_column_name, removes_filter, keys))
         {
-            // std::cerr << "===============\n" << expression->dumpDAG() << std::endl;
-            // std::cerr << "---------------\n" << split_filter->dumpDAG() << std::endl;
+            std::cerr << "===============\n" << expression->dumpDAG() << std::endl;
+            std::cerr << "---------------\n" << split_filter->dumpDAG() << std::endl;
 
             auto it = expression->getIndex().find(filter_column_name);
             if (it == expression->getIndex().end())