Skip to content

Commit 27e3628

Browse files
committed
fix compaction
1 parent 78ab809 commit 27e3628

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/Storages/ObjectStorage/DataLakes/Iceberg/Compaction.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -443,9 +443,9 @@ void writeMetadataFiles(
443443
if (plan.history[i].added_files == 0)
444444
continue;
445445

446-
auto initial_manifest_list_name = plan.history[i].manifest_list_path;
446+
auto initial_manifest_list_name = plan.history[i].manifest_list_absolute_path;
447447
auto initial_manifest_entries = plan.manifest_list_to_manifest_files[initial_manifest_list_name];
448-
auto renamed_manifest_list = manifest_list_renamings[initial_manifest_list_name];
448+
auto renamed_manifest_list = manifest_list_renamings[plan.history[i].manifest_list_path];
449449
std::vector<String> renamed_manifest_entries;
450450
Int32 total_manifest_file_sizes = 0;
451451
for (const auto & initial_manifest_entry : initial_manifest_entries)

0 commit comments

Comments
 (0)