Skip to content

Commit 4bedc6a

Browse files
JanKaulFokko
authored andcommitted
Fix avro schema names for manifest and manifest_list (apache#182)
Co-authored-by: Fokko Driesprong <[email protected]>
1 parent aa59f57 commit 4bedc6a

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

crates/iceberg/src/spec/manifest.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -662,7 +662,7 @@ mod _const_schema {
662662
)),
663663
];
664664
let schema = Schema::builder().with_fields(fields).build()?;
665-
schema_to_avro_schema("manifest", &schema)
665+
schema_to_avro_schema("manifest_entry", &schema)
666666
}
667667

668668
pub(super) fn manifest_schema_v1(partition_type: StructType) -> Result<AvroSchema, Error> {
@@ -696,7 +696,7 @@ mod _const_schema {
696696
)),
697697
];
698698
let schema = Schema::builder().with_fields(fields).build().unwrap();
699-
schema_to_avro_schema("manifest", &schema)
699+
schema_to_avro_schema("manifest_entry", &schema)
700700
}
701701
}
702702

crates/iceberg/src/spec/manifest_list.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -495,10 +495,10 @@ mod _const_schema {
495495
};
496496

497497
pub(super) static MANIFEST_LIST_AVRO_SCHEMA_V1: Lazy<AvroSchema> =
498-
Lazy::new(|| schema_to_avro_schema("manifest_list", &V1_SCHEMA).unwrap());
498+
Lazy::new(|| schema_to_avro_schema("manifest_file", &V1_SCHEMA).unwrap());
499499

500500
pub(super) static MANIFEST_LIST_AVRO_SCHEMA_V2: Lazy<AvroSchema> =
501-
Lazy::new(|| schema_to_avro_schema("manifest_list", &V2_SCHEMA).unwrap());
501+
Lazy::new(|| schema_to_avro_schema("manifest_file", &V2_SCHEMA).unwrap());
502502
}
503503

504504
/// Entry in a manifest list.

0 commit comments

Comments
 (0)