diff --git a/cpp-ch/local-engine/Storages/MergeTree/SparkMergeTreeMeta.cpp b/cpp-ch/local-engine/Storages/MergeTree/SparkMergeTreeMeta.cpp index 788b1b39fc203..2921fc887f323 100644 --- a/cpp-ch/local-engine/Storages/MergeTree/SparkMergeTreeMeta.cpp +++ b/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(); return ranges_in_data_part; }); return ranges_in_data_parts; diff --git a/cpp-ch/local-engine/Storages/MergeTree/SparkStorageMergeTree.h b/cpp-ch/local-engine/Storages/MergeTree/SparkStorageMergeTree.h index fbd19de643eaa..84dd66b2c7be7 100644 --- a/cpp-ch/local-engine/Storages/MergeTree/SparkStorageMergeTree.h +++ b/cpp-ch/local-engine/Storages/MergeTree/SparkStorageMergeTree.h @@ -94,8 +94,12 @@ 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 + { + throw std::runtime_error("not implement"); + }; }; class SparkWriteStorageMergeTree final : public SparkStorageMergeTree