tmp

arthurpassos · arthurpassos · commit c5c00cd06f2d · 2025-10-28T12:51:54.000+01:00
diff --git a/src/Storages/MergeTree/MergeTreeData.cpp b/src/Storages/MergeTree/MergeTreeData.cpp
@@ -6244,9 +6244,7 @@ void MergeTreeData::exportPartToTable(const PartitionCommand & command, ContextP
         MergeTreeExportManifest manifest(
             dest_storage->getStorageID(),
             part,
-            query_context->getSettingsRef()[Setting::export_merge_tree_part_overwrite_file_if_exists],
-            query_context->getSettingsRef()[Setting::output_format_parallel_formatting],
-            query_context->getSettingsRef()[Setting::output_format_parallel_formatting_parquet]);
+            query_context);
 
         std::lock_guard lock(export_manifests_mutex);
 
@@ -6291,17 +6289,14 @@ void MergeTreeData::exportPartToTableImpl(
     std::string destination_file_path;
 
     try
-    {
-        auto context_copy = Context::createCopy(local_context);
-        context_copy->setSetting("output_format_parallel_formatting", manifest.parallel_formatting);
-        context_copy->setSetting("output_format_parquet_parallel_encoding", manifest.parallel_formatting_parquet);
+        {
 
         sink = destination_storage->import(
             manifest.data_part->name + "_" + manifest.data_part->checksums.getTotalChecksumHex(),
             block_with_partition_values,
             destination_file_path,
             manifest.overwrite_file_if_exists,
-            context_copy);
+            local_context);
     }
     catch (const Exception & e)
     {
diff --git a/src/Storages/MergeTree/MergeTreeExportManifest.h b/src/Storages/MergeTree/MergeTreeExportManifest.h
@@ -12,23 +12,15 @@ struct MergeTreeExportManifest
     MergeTreeExportManifest(
         const StorageID & destination_storage_id_,
         const DataPartPtr & data_part_,
-        bool overwrite_file_if_exists_,
-        bool parallel_formatting_,
-        bool parallel_formatting_parquet_)
+        ContextPtr context_)
         : destination_storage_id(destination_storage_id_),
           data_part(data_part_),
-          overwrite_file_if_exists(overwrite_file_if_exists_),
-          parallel_formatting(parallel_formatting_),
-          parallel_formatting_parquet(parallel_formatting_parquet_),
+          context(context_),
           create_time(time(nullptr)) {}
 
     StorageID destination_storage_id;
     DataPartPtr data_part;
-    bool overwrite_file_if_exists;
-    bool parallel_formatting;
-    /// parquet has a different setting for parallel formatting
-    bool parallel_formatting_parquet;
-
+    ContextPtr context;
     time_t create_time;
     mutable bool in_progress = false;
 
