From 4af369fbc4bada857e267f34440df72f1aaba425 Mon Sep 17 00:00:00 2001
From: Alexander Gololobov <davenger@clickhouse.com>
Date: Mon, 16 Sep 2024 13:34:01 +0200
Subject: [PATCH] Failpoint for testing slow index analysis

---
 src/Common/FailPoint.cpp                             |  1 +
 .../MergeTree/MergeTreeDataSelectExecutor.cpp        | 12 ++++++++++++
 2 files changed, 13 insertions(+)

diff --git a/src/Common/FailPoint.cpp b/src/Common/FailPoint.cpp
index b2fcbc77c56..1b65447efc3 100644
--- a/src/Common/FailPoint.cpp
+++ b/src/Common/FailPoint.cpp
@@ -63,6 +63,7 @@ static struct InitFiu
     REGULAR(keepermap_fail_drop_data) \
     REGULAR(lazy_pipe_fds_fail_close) \
     PAUSEABLE(infinite_sleep) \
+    REGULAR(slowdown_index_analysis) \
 
 
 namespace FailPoints
diff --git a/src/Storages/MergeTree/MergeTreeDataSelectExecutor.cpp b/src/Storages/MergeTree/MergeTreeDataSelectExecutor.cpp
index 5d246293396..6e0ae8f7cca 100644
--- a/src/Storages/MergeTree/MergeTreeDataSelectExecutor.cpp
+++ b/src/Storages/MergeTree/MergeTreeDataSelectExecutor.cpp
@@ -41,6 +41,8 @@
 #include <Core/UUID.h>
 #include <Core/Settings.h>
 #include <Common/CurrentMetrics.h>
+#include <Common/FailPoint.h>
+#include <base/sleep.h>
 #include <DataTypes/DataTypeDate.h>
 #include <DataTypes/DataTypeEnum.h>
 #include <DataTypes/DataTypeUUID.h>
@@ -75,6 +77,11 @@ namespace ErrorCodes
     extern const int DUPLICATED_PART_UUIDS;
 }
 
+namespace FailPoints
+{
+    extern const char slowdown_index_analysis[];
+}
+
 
 MergeTreeDataSelectExecutor::MergeTreeDataSelectExecutor(const MergeTreeData & data_)
     : data(data_), log(getLogger(data.getLogName() + " (SelectExecutor)"))
@@ -1565,6 +1572,11 @@ void MergeTreeDataSelectExecutor::selectPartsToRead(
         if (query_status)
             query_status->checkTimeLimit();
 
+        fiu_do_on(FailPoints::slowdown_index_analysis,
+        {
+            sleepForMilliseconds(1000);
+        });
+
         const auto * part = part_or_projection->isProjectionPart() ? part_or_projection->getParentPart() : part_or_projection.get();
         if (part_values && part_values->find(part->name) == part_values->end())
             continue;