diff --git a/src/io/ipc/compression.rs b/src/io/ipc/compression.rs index 64dc05fa1c2..9a69deb8248 100644 --- a/src/io/ipc/compression.rs +++ b/src/io/ipc/compression.rs @@ -48,13 +48,13 @@ pub fn compress_zstd(input_buf: &[u8], output_buf: &mut Vec) -> Result<()> { } #[cfg(not(feature = "io_ipc_compression"))] -pub fn compress_lz4(_input_buf: &[u8], _output_buf: &mut Vec) -> Result<()> { +pub fn compress_lz4(_input_buf: &[u8], _output_buf: &[u8]) -> Result<()> { use crate::error::Error; Err(Error::OutOfSpec("The crate was compiled without IPC compression. Use `io_ipc_compression` to write compressed IPC.".to_string())) } #[cfg(not(feature = "io_ipc_compression"))] -pub fn compress_zstd(_input_buf: &[u8], _output_buf: &mut Vec) -> Result<()> { +pub fn compress_zstd(_input_buf: &[u8], _output_buf: &[u8]) -> Result<()> { use crate::error::Error; Err(Error::OutOfSpec("The crate was compiled without IPC compression. Use `io_ipc_compression` to write compressed IPC.".to_string())) } diff --git a/src/io/ipc/write/common_sync.rs b/src/io/ipc/write/common_sync.rs index f20e70faab7..62548fe5e63 100644 --- a/src/io/ipc/write/common_sync.rs +++ b/src/io/ipc/write/common_sync.rs @@ -21,7 +21,7 @@ pub fn write_message(writer: &mut W, encoded: &EncodedData) -> Result< // write the flatbuf if flatbuf_size > 0 { - writer.write_all(&buffer)?; + writer.write_all(buffer)?; } // write padding // aligned to a 8 byte boundary, so maximum is [u8;8] diff --git a/src/temporal_conversions.rs b/src/temporal_conversions.rs index fcf2c0a746c..67f896c1154 100644 --- a/src/temporal_conversions.rs +++ b/src/temporal_conversions.rs @@ -295,8 +295,7 @@ fn chrono_tz_utf_to_timestamp_ns( timezone: String, ) -> Result> { Err(Error::InvalidArgumentError(format!( - "timezone \"{}\" cannot be parsed (feature chrono-tz is not active)", - timezone + "timezone \"{timezone}\" cannot be parsed (feature chrono-tz is not active)", ))) }