From bfbb699036e7b64a2609f86860d523567564332d Mon Sep 17 00:00:00 2001 From: Jan Kaul Date: Thu, 1 Feb 2024 15:16:13 +0100 Subject: [PATCH] fix avro schema names for manifest and manifest_list --- crates/iceberg/src/spec/manifest.rs | 4 ++-- crates/iceberg/src/spec/manifest_list.rs | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/crates/iceberg/src/spec/manifest.rs b/crates/iceberg/src/spec/manifest.rs index d943a556c..fe5a0398b 100644 --- a/crates/iceberg/src/spec/manifest.rs +++ b/crates/iceberg/src/spec/manifest.rs @@ -662,7 +662,7 @@ mod _const_schema { )), ]; let schema = Schema::builder().with_fields(fields).build().unwrap(); - schema_to_avro_schema("manifest", &schema) + schema_to_avro_schema("manifest_entry", &schema) } pub(super) fn manifest_schema_v1(partition_type: StructType) -> Result { @@ -696,7 +696,7 @@ mod _const_schema { )), ]; let schema = Schema::builder().with_fields(fields).build().unwrap(); - schema_to_avro_schema("manifest", &schema) + schema_to_avro_schema("manifest_entry", &schema) } } diff --git a/crates/iceberg/src/spec/manifest_list.rs b/crates/iceberg/src/spec/manifest_list.rs index a3bf0c489..b252a5e2d 100644 --- a/crates/iceberg/src/spec/manifest_list.rs +++ b/crates/iceberg/src/spec/manifest_list.rs @@ -495,10 +495,10 @@ mod _const_schema { }; pub(super) static MANIFEST_LIST_AVRO_SCHEMA_V1: Lazy = - Lazy::new(|| schema_to_avro_schema("manifest_list", &V1_SCHEMA).unwrap()); + Lazy::new(|| schema_to_avro_schema("manifest_file", &V1_SCHEMA).unwrap()); pub(super) static MANIFEST_LIST_AVRO_SCHEMA_V2: Lazy = - Lazy::new(|| schema_to_avro_schema("manifest_list", &V2_SCHEMA).unwrap()); + Lazy::new(|| schema_to_avro_schema("manifest_file", &V2_SCHEMA).unwrap()); } /// Entry in a manifest list.