Backport ClickHouse#88290 to 25.8: Fix object storages with correlated subqueries

Author: robot-clickhouse

src/Processors/QueryPlan/ReadFromObjectStorageStep.cpp

@@ -53,6 +53,11 @@ ReadFromObjectStorageStep::ReadFromObjectStorageStep(
 {
 }
 
+QueryPlanStepPtr ReadFromObjectStorageStep::clone() const
+{
+    return std::make_unique<ReadFromObjectStorageStep>(*this);
+}
+
 void ReadFromObjectStorageStep::applyFilters(ActionDAGNodes added_filter_nodes)
 {
     SourceStepWithFilter::applyFilters(std::move(added_filter_nodes));

src/Processors/QueryPlan/ReadFromObjectStorageStep.h

@@ -33,6 +33,7 @@ class ReadFromObjectStorageStep : public SourceStepWithFilter
     void updatePrewhereInfo(const PrewhereInfoPtr & prewhere_info_value) override;
 
     void initializePipeline(QueryPipelineBuilder & pipeline, const BuildQueryPipelineSettings &) override;
+    QueryPlanStepPtr clone() const override;
 
 private:
     ObjectStoragePtr object_storage;

tests/queries/0_stateless/03644_object_storage_correlated_subqueries.reference

@@ -0,0 +1,9 @@
+1
+2
+3
+4
+5
+6
+7
+8
+9

tests/queries/0_stateless/03644_object_storage_correlated_subqueries.sql

@@ -0,0 +1,16 @@
+-- Tags: no-fasttest
+-- Tag no-fasttest: needs s3
+
+-- Use correlated subqueries which are supported only by the new analyzer.
+set enable_analyzer = 1;
+
+INSERT INTO TABLE FUNCTION s3('http://localhost:11111/test/test-data-03644_object_storage.csv', 'test', 'testtest', 'CSV', 'number UInt64') SELECT number FROM numbers(10) SETTINGS s3_truncate_on_insert = 1;
+
+SELECT n1.c1
+FROM s3('http://localhost:11111/test/test-data-03644_object_storage.csv', 'test', 'testtest') AS n1
+WHERE n1.c1 > (
+    SELECT AVG(n2.c1)
+    FROM s3('http://localhost:11111/test/test-data-03644_object_storage.csv', 'test', 'testtest') AS n2
+    WHERE n2.c1 < n1.c1
+)
+SETTINGS allow_experimental_correlated_subqueries = 1;