@@ -229,12 +229,14 @@ void writeDataFiles(
229229 ObjectStoragePtr object_storage,
230230 const std::optional<FormatSettings> & format_settings,
231231 ContextPtr context,
232- StorageObjectStorageConfigurationPtr configuration)
232+ StorageObjectStorageConfigurationPtr configuration,
233+ const String & table_location,
234+ std::map<String, ObjectStoragePtr> & secondary_storages)
233235{
234236 for (auto & [_, data_file] : initial_plan.path_to_data_file )
235237 {
236238 auto delete_file_transform = std::make_shared<IcebergBitmapPositionDeleteTransform>(
237- sample_block, data_file->data_object_info , object_storage, format_settings, context);
239+ sample_block, data_file->data_object_info , object_storage, format_settings, context, table_location, secondary_storages );
238240
239241 StorageObjectStorage::ObjectInfo object_info (data_file->data_object_info ->getPath ());
240242 auto read_buffer = createReadBuffer (object_info, object_storage, context, getLogger (" IcebergCompaction" ));
@@ -525,7 +527,7 @@ void compactIcebergTable(
525527 if (plan.need_optimize )
526528 {
527529 auto old_files = getOldFiles (object_storage_, configuration_);
528- writeDataFiles (plan, sample_block_, object_storage_, format_settings_, context_, configuration_);
530+ writeDataFiles (plan, sample_block_, object_storage_, format_settings_, context_, configuration_, persistent_table_components. table_location , secondary_storages_ );
529531 writeMetadataFiles (plan, object_storage_, configuration_, context_, sample_block_);
530532 clearOldFiles (object_storage_, old_files);
531533 }
0 commit comments