diff --git a/datafusion/physical-plan/Cargo.toml b/datafusion/physical-plan/Cargo.toml index 83dc9549531d..a72d19cda3b1 100644 --- a/datafusion/physical-plan/Cargo.toml +++ b/datafusion/physical-plan/Cargo.toml @@ -68,7 +68,6 @@ tokio = { workspace = true } criterion = { version = "0.5", features = ["async_futures"] } datafusion-functions-aggregate = { workspace = true } datafusion-functions-window = { workspace = true } -once_cell = "1.18.0" rand = { workspace = true } rstest = { workspace = true } rstest_reuse = "0.7.0" diff --git a/datafusion/physical-plan/src/joins/symmetric_hash_join.rs b/datafusion/physical-plan/src/joins/symmetric_hash_join.rs index 2dbff25e703e..59aab3395ea2 100644 --- a/datafusion/physical-plan/src/joins/symmetric_hash_join.rs +++ b/datafusion/physical-plan/src/joins/symmetric_hash_join.rs @@ -1711,7 +1711,7 @@ pub enum SHJStreamState { #[cfg(test)] mod tests { use std::collections::HashMap; - use std::sync::Mutex; + use std::sync::{LazyLock, Mutex}; use super::*; use crate::joins::test_utils::{ @@ -1729,7 +1729,6 @@ mod tests { use datafusion_physical_expr::expressions::{binary, col, lit, Column}; use datafusion_physical_expr_common::sort_expr::{LexOrdering, PhysicalSortExpr}; - use once_cell::sync::Lazy; use rstest::*; const TABLE_SIZE: i32 = 30; @@ -1738,8 +1737,8 @@ mod tests { type TableValue = (Vec, Vec); // (left, right) // Cache for storing tables - static TABLE_CACHE: Lazy>> = - Lazy::new(|| Mutex::new(HashMap::new())); + static TABLE_CACHE: LazyLock>> = + LazyLock::new(|| Mutex::new(HashMap::new())); fn get_or_create_table( cardinality: (i32, i32),