File tree Expand file tree Collapse file tree 1 file changed +2
-7
lines changed
Expand file tree Collapse file tree 1 file changed +2
-7
lines changed Original file line number Diff line number Diff line change @@ -5959,12 +5959,7 @@ void MergeTreeData::exportPartToTableImpl(
59595959 manifest.create_time ,
59605960 local_context);
59615961
5962- // Switch to the export's thread group for memory tracking
5963- std::optional<ThreadGroupSwitcher> switcher;
5964- if (exports_list_entry)
5965- {
5966- switcher.emplace ((*exports_list_entry)->thread_group , " " , /* allow_existing_group*/ true );
5967- }
5962+ ThreadGroupSwitcher switcher ((*exports_list_entry)->thread_group , " " );
59685963
59695964 auto metadata_snapshot = getInMemoryMetadataPtr ();
59705965 Names columns_to_read = metadata_snapshot->getColumns ().getNamesOfPhysical ();
@@ -8755,7 +8750,7 @@ try
87558750 {
87568751 part_log_elem.rows_read = (*exports_entry)->rows_read ;
87578752 part_log_elem.bytes_read_uncompressed = (*exports_entry)->bytes_read_uncompressed ;
8758- part_log_elem.peak_memory_usage = (*exports_entry)->getMemoryTracker (). getPeak ();
8753+ part_log_elem.peak_memory_usage = (*exports_entry)->getPeakMemoryUsage ();
87598754 }
87608755
87618756 if (profile_counters)
You can’t perform that action at this time.
0 commit comments