From 20960eeba9e41c2e4f38cd307571d81f8919b0c1 Mon Sep 17 00:00:00 2001 From: nooberfsh Date: Wed, 17 Jul 2024 10:21:53 +0800 Subject: [PATCH] Fix ManifestFile length calculation --- crates/iceberg/src/spec/manifest.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/crates/iceberg/src/spec/manifest.rs b/crates/iceberg/src/spec/manifest.rs index dd1482361..f4b933175 100644 --- a/crates/iceberg/src/spec/manifest.rs +++ b/crates/iceberg/src/spec/manifest.rs @@ -289,8 +289,8 @@ impl ManifestWriter { avro_writer.append(value)?; } - let length = avro_writer.flush()?; let content = avro_writer.into_inner()?; + let length = content.len(); self.output.write(Bytes::from(content)).await?; let partition_summary =