Skip to content

Commit

Permalink
[GLUTEN-1632][CH]Daily Update Clickhouse Version (20240928) (#7379)
Browse files Browse the repository at this point in the history
* [GLUTEN-1632][CH]Daily Update Clickhouse Version (20240928)

* Fix build due to ClickHouse/ClickHouse#65625

* Fix build due to ClickHouse/ClickHouse#68410

---------

Co-authored-by: kyligence-git <gluten@kyligence.io>
Co-authored-by: Chang Chen <baibaichen@gmail.com>
  • Loading branch information
3 people authored Sep 28, 2024
1 parent b9fbb47 commit e29946d
Show file tree
Hide file tree
Showing 5 changed files with 6 additions and 7 deletions.
4 changes: 2 additions & 2 deletions cpp-ch/clickhouse.version
Original file line number Diff line number Diff line change
@@ -1,3 +1,3 @@
CH_ORG=Kyligence
CH_BRANCH=rebase_ch/20240920
CH_COMMIT=14c2da664d7
CH_BRANCH=rebase_ch/20240928
CH_COMMIT=348196b6011
Original file line number Diff line number Diff line change
Expand Up @@ -336,7 +336,6 @@ void AggregateRelParser::addMergingAggregatedStep()
false,
settings[Setting::max_block_size],
settings[Setting::aggregation_in_order_max_block_bytes],
SortDescription(),
settings[Setting::enable_memory_bound_merging_of_aggregation_results]);
steps.emplace_back(merging_step.get());
plan->addStep(std::move(merging_step));
Expand Down
2 changes: 1 addition & 1 deletion cpp-ch/local-engine/Parser/RelParsers/SortRelParser.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,7 @@ SortRelParser::parse(DB::QueryPlanPtr query_plan, const substrait::Rel & rel, st
return currentThreadGroupMemoryUsageRatio() > spill_mem_ratio;
};
auto sorting_step = std::make_unique<DB::SortingStep>(
query_plan->getCurrentDataStream(), sort_descr, limit, settings, false);
query_plan->getCurrentDataStream(), sort_descr, limit, settings);
sorting_step->setStepDescription("Sorting step");
steps.emplace_back(sorting_step.get());
query_plan->addStep(std::move(sorting_step));
Expand Down
4 changes: 2 additions & 2 deletions cpp-ch/local-engine/Storages/MergeTree/MetaDataHelper.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -118,7 +118,7 @@ void restoreMetaData<ROCKSDB>(const SparkStorageMergeTreePtr & storage, const Me
transaction->createDirectoryRecursive(part_path);
auto key = s3->generateObjectKeyForPath(metadata_file_path.generic_string(), std::nullopt);
StoredObject metadata_object(key.serialize());
auto part_metadata = extractPartMetaData(*s3->readObject(metadata_object));
auto part_metadata = extractPartMetaData(*s3->readObject(metadata_object, ReadSettings{}));
for (const auto & item : part_metadata)
{
auto item_path = part_path / item.first;
Expand Down Expand Up @@ -180,7 +180,7 @@ void restoreMetaData<LOCAL>(
metadata_disk->createDirectories(part_path);
auto key = s3->generateObjectKeyForPath(metadata_file_path.generic_string(), std::nullopt);
StoredObject metadata_object(key.serialize());
auto part_metadata = extractPartMetaData(*s3->readObject(metadata_object));
auto part_metadata = extractPartMetaData(*s3->readObject(metadata_object, ReadSettings{}));
for (const auto & item : part_metadata)
{
auto item_path = part_path / item.first;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -157,7 +157,7 @@ void SparkStorageMergeTree::prefetchMetaDataFile(std::unordered_set<std::string>
{
if (!disk->exists(meta_path))
continue;
auto in = disk->readFile(meta_path);
auto in = disk->readFile(meta_path, ReadSettings{});
String ignore_data;
readStringUntilEOF(ignore_data, *in);
}
Expand Down

0 comments on commit e29946d

Please sign in to comment.