[GLUTEN-1632][CH]Daily Update Clickhouse Version (20240906)

backends-clickhouse/src/test/scala/org/apache/gluten/execution/GlutenClickHouseMergeTreeCacheDataSSuite.scala

@@ -58,6 +58,7 @@ class GlutenClickHouseMergeTreeCacheDataSSuite
       .set(
         "spark.gluten.sql.columnar.backend.ch.runtime_settings.mergetree.merge_after_insert",
         "false")
+    // .set("spark.gluten.sql.columnar.backend.ch.runtime_config.path", "/data") // for local test
   }
 
   override protected def beforeEach(): Unit = {

cpp-ch/clickhouse.version

@@ -1,3 +1,3 @@
 CH_ORG=Kyligence
-CH_BRANCH=rebase_ch/20240830
-CH_COMMIT=5e2eaab52ac
+CH_BRANCH=rebase_ch/20240906
+CH_COMMIT=4513a954b95

cpp-ch/local-engine/Parser/MergeTreeRelParser.cpp

@@ -96,8 +96,7 @@ DB::QueryPlanPtr MergeTreeRelParser::parseReadRel(
 
     auto read_step = storage->reader.readFromParts(
         selected_parts,
-        /* alter_conversions = */
-        {},
+        storage->getMutationsSnapshot({}),
         names_and_types_list.getNames(),
         storage_snapshot,
         *query_info,

cpp-ch/local-engine/Storages/Cache/CacheManager.cpp

@@ -101,8 +101,7 @@ Task CacheManager::cachePart(const MergeTreeTableInstance & table, const MergeTr
                 = StorageMergeTreeFactory::getDataPartsByNames(storage->getStorageID(), "", {job_detail.table.parts.front().name});
             auto read_step = storage->reader.readFromParts(
                 selected_parts,
-                /* alter_conversions = */
-                {},
+                storage->getMutationsSnapshot({}),
                 names_and_types_list.getNames(),
                 storage_snapshot,
                 *query_info,

cpp-ch/local-engine/Storages/MergeTree/SparkMergeTreeMeta.cpp

@@ -286,7 +286,6 @@ RangesInDataParts MergeTreeTableInstance::extractRange(DataPartsVector parts_vec
             ranges_in_data_part.data_part = name_index.at(part.name);
             ranges_in_data_part.part_index_in_query = 0;
             ranges_in_data_part.ranges.emplace_back(MarkRange(part.begin, part.end));
-            ranges_in_data_part.alter_conversions = std::make_shared<AlterConversions>();
             return ranges_in_data_part;
         });
     return ranges_in_data_parts;

cpp-ch/local-engine/Storages/MergeTree/SparkStorageMergeTree.h

@@ -50,6 +50,19 @@ class SparkStorageMergeTree : public MergeTreeData
 {
     friend class MergeSparkMergeTreeTask;
 
+    struct SparkMutationsSnapshot : public IMutationsSnapshot
+    {
+        SparkMutationsSnapshot() = default;
+
+        MutationCommands getAlterMutationCommandsForPart(const MergeTreeData::DataPartPtr & part) const override { return {}; }
+        std::shared_ptr<MergeTreeData::IMutationsSnapshot> cloneEmpty() const override
+        {
+            return std::make_shared<SparkMutationsSnapshot>();
+        }
+
+        NameSet getAllUpdatedColumns() const override { return {}; }
+    };
+
 public:
     static void wrapRangesInDataParts(DB::ReadFromMergeTree & source, const DB::RangesInDataParts & ranges);
     static void analysisPartsByRanges(DB::ReadFromMergeTree & source, const DB::RangesInDataParts & ranges_in_data_parts);
@@ -94,8 +107,13 @@ class SparkStorageMergeTree : public MergeTreeData
     void replacePartitionFrom(const StoragePtr & source_table, const ASTPtr & partition, bool replace, ContextPtr context) override;
     void movePartitionToTable(const StoragePtr & dest_table, const ASTPtr & partition, ContextPtr context) override;
     bool partIsAssignedToBackgroundOperation(const DataPartPtr & part) const override;
-    MutationCommands getAlterMutationCommandsForPart(const DataPartPtr & /*part*/) const override { return {}; }
     void attachRestoredParts(MutableDataPartsVector && /*parts*/) override { throw std::runtime_error("not implement"); }
+
+public:
+    MutationsSnapshotPtr getMutationsSnapshot(const IMutationsSnapshot::Params & /*params*/) const override
+    {
+        return std::make_shared<SparkMutationsSnapshot>();
+    };
 };
 
 class SparkWriteStorageMergeTree final : public SparkStorageMergeTree