From 8e725ab7fb07ae768ad4ed80ec3387a0a0a6c51d Mon Sep 17 00:00:00 2001 From: sundaresanr Date: Fri, 17 Apr 2026 14:58:33 -0700 Subject: [PATCH] Fix compile errors on v0.51-exaforce MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - Add ParquetSerializer, ParquetSerializerConfig, ParquetSerializerOptions to the format:: import block in serializer.rs (7 E0412/E0433 errors). - Fix SerializerConfig::Gelf match arm in build_batched() — the enum is Gelf(GelfSerializerConfig), not a unit variant (E0532). - Drop `ref mut` from BoolColumnWriter match arm in parquet.rs — Rust 2024 match ergonomics disallow it when binding mode is already `move`. Verified with `cargo check -p codecs`. --- lib/codecs/src/encoding/format/parquet.rs | 2 +- lib/codecs/src/encoding/serializer.rs | 7 ++++--- 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/lib/codecs/src/encoding/format/parquet.rs b/lib/codecs/src/encoding/format/parquet.rs index 9b5fdf5f2174b..bf62381865b1c 100644 --- a/lib/codecs/src/encoding/format/parquet.rs +++ b/lib/codecs/src/encoding/format/parquet.rs @@ -299,7 +299,7 @@ impl Encoder> for ParquetSerializer { let mut row_group_writer = parquet_writer.next_row_group()?; while let Some(mut column_writer) = row_group_writer.next_column()? { match column_writer.untyped() { - BoolColumnWriter(ref mut writer) => { + BoolColumnWriter(writer) => { let desc = writer.get_descriptor().clone(); self.process( &events, diff --git a/lib/codecs/src/encoding/serializer.rs b/lib/codecs/src/encoding/serializer.rs index 925bf7a8145b7..d60c3d5e69e62 100644 --- a/lib/codecs/src/encoding/serializer.rs +++ b/lib/codecs/src/encoding/serializer.rs @@ -10,8 +10,9 @@ use super::format::{ CefSerializerConfig, CsvSerializer, CsvSerializerConfig, GelfSerializer, GelfSerializerConfig, JsonSerializer, JsonSerializerConfig, LogfmtSerializer, LogfmtSerializerConfig, NativeJsonSerializer, NativeJsonSerializerConfig, NativeSerializer, NativeSerializerConfig, - ProtobufSerializer, ProtobufSerializerConfig, RawMessageSerializer, RawMessageSerializerConfig, - TextSerializer, TextSerializerConfig, + ParquetSerializer, ParquetSerializerConfig, ParquetSerializerOptions, ProtobufSerializer, + ProtobufSerializerConfig, RawMessageSerializer, RawMessageSerializerConfig, TextSerializer, + TextSerializerConfig, }; #[cfg(feature = "opentelemetry")] use super::format::{OtlpSerializer, OtlpSerializerConfig}; @@ -256,7 +257,7 @@ impl SerializerConfig { ))), SerializerConfig::Avro { .. } | SerializerConfig::Csv(..) - | SerializerConfig::Gelf + | SerializerConfig::Gelf(..) | SerializerConfig::Json(..) | SerializerConfig::Logfmt | SerializerConfig::Native