diff --git a/native/spark-expr/src/bloom_filter/spark_bit_array.rs b/native/spark-expr/src/bloom_filter/spark_bit_array.rs index 6d43bdb942f..0af1c598b03 100644 --- a/native/spark-expr/src/bloom_filter/spark_bit_array.rs +++ b/native/spark-expr/src/bloom_filter/spark_bit_array.rs @@ -77,8 +77,8 @@ impl SparkBitArray { pub fn merge_be_words(&mut self, incoming: &[u8]) { debug_assert_eq!(self.data.len() * 8, incoming.len()); let mut bit_count: usize = 0; - for (word, chunk) in self.data.iter_mut().zip(incoming.chunks_exact(8)) { - *word |= u64::from_be_bytes(chunk.try_into().unwrap()); + for (word, chunk) in self.data.iter_mut().zip(incoming.as_chunks::<8>().0) { + *word |= u64::from_be_bytes(*chunk); bit_count += word.count_ones() as usize; } self.bit_count = bit_count; diff --git a/native/spark-expr/src/nondetermenistic_funcs/internal/mersenne.rs b/native/spark-expr/src/nondetermenistic_funcs/internal/mersenne.rs index 783fd9e3600..4027c32978a 100644 --- a/native/spark-expr/src/nondetermenistic_funcs/internal/mersenne.rs +++ b/native/spark-expr/src/nondetermenistic_funcs/internal/mersenne.rs @@ -148,6 +148,8 @@ impl SparkMersenneTwister { /// Port of `BitsStreamGenerator.nextInt(int n)`. The caller always passes a /// strictly positive `n`, matching Spark's `random.nextInt(i + 1)`. + // `isolate_lowest_one` requires Rust 1.97, newer than Comet's Rust 1.88 MSRV. + #[allow(unknown_lints, clippy::manual_isolate_lowest_one)] pub(crate) fn next_int(&mut self, n: i32) -> i32 { if (n & n.wrapping_neg()) == n { // n is a power of two.