fix build

mkmkme · mkmkme · commit e5e2e2471f68 · 2026-03-25T10:31:14.000+01:00
diff --git a/src/Storages/ObjectStorage/DataLakes/Iceberg/IcebergMetadata.cpp b/src/Storages/ObjectStorage/DataLakes/Iceberg/IcebergMetadata.cpp
@@ -258,15 +258,19 @@ void IcebergMetadata::backgroundMetadataPrefetcherThread()
         /// first, we fetch the latest metadata version and cache it;
         /// as a part of the same method, we download metadata.json of the latest metadata version
         /// and after parsing it, we fetch manifest lists, parse and cache them
-        auto ctx = Context::getGlobalContextInstance()->getBackgroundContext();
+        auto ctx = Context::createCopy(Context::getGlobalContextInstance());
         auto [actual_data_snapshot, actual_table_state_snapshot] = getRelevantState(ctx, true);
         if (actual_data_snapshot)
         {
             for (const auto & entry : actual_data_snapshot->manifest_list_entries)
             {
                 /// second, we fetch, parse and cache each manifest file
-                auto manifest_file_ptr = getManifestFileEntriesHandle(
-                    object_storage, persistent_components, ctx, log, entry, actual_table_state_snapshot.schema_id);
+                auto manifest_file_ptr = Iceberg::getManifestFile(
+                    object_storage, persistent_components, ctx, log,
+                    entry.manifest_file_absolute_path,
+                    entry.added_sequence_number,
+                    entry.added_snapshot_id,
+                    *secondary_storages);
             }
         }
 

Original file line number	Diff line number	Diff line change
`@@ -258,15 +258,19 @@ void IcebergMetadata::backgroundMetadataPrefetcherThread()`
`258`	`258`	`/// first, we fetch the latest metadata version and cache it;`
`259`	`259`	`/// as a part of the same method, we download metadata.json of the latest metadata version`
`260`	`260`	`/// and after parsing it, we fetch manifest lists, parse and cache them`
`261`		`- auto ctx = Context::getGlobalContextInstance()->getBackgroundContext();`
	`261`	`+ auto ctx = Context::createCopy(Context::getGlobalContextInstance());`
`262`	`262`	`auto [actual_data_snapshot, actual_table_state_snapshot] = getRelevantState(ctx, true);`
`263`	`263`	`if (actual_data_snapshot)`
`264`	`264`	`{`
`265`	`265`	`for (const auto & entry : actual_data_snapshot->manifest_list_entries)`
`266`	`266`	`{`
`267`	`267`	`/// second, we fetch, parse and cache each manifest file`
`268`		`- auto manifest_file_ptr = getManifestFileEntriesHandle(`
`269`		`- object_storage, persistent_components, ctx, log, entry, actual_table_state_snapshot.schema_id);`
	`268`	`+ auto manifest_file_ptr = Iceberg::getManifestFile(`
	`269`	`+ object_storage, persistent_components, ctx, log,`
	`270`	`+ entry.manifest_file_absolute_path,`
	`271`	`+ entry.added_sequence_number,`
	`272`	`+ entry.added_snapshot_id,`
	`273`	`+ *secondary_storages);`
`270`	`274`	`}`
`271`	`275`	`}`
`272`	`276`