diff --git a/src/object_store/src/object/opendal_engine/fs.rs b/src/object_store/src/object/opendal_engine/fs.rs index c1841363e198f..b0a1f917baa33 100644 --- a/src/object_store/src/object/opendal_engine/fs.rs +++ b/src/object_store/src/object/opendal_engine/fs.rs @@ -27,8 +27,7 @@ impl OpendalObjectStore { let mut builder = Fs::default(); builder.root(&root); - let atomic_write_dir = format!("{}{}", root, ATOMIC_WRITE_DIR); - builder.atomic_write_dir(&atomic_write_dir); + builder.atomic_write_dir(ATOMIC_WRITE_DIR); let op: Operator = Operator::new(builder)? .layer(RetryLayer::default()) diff --git a/src/object_store/src/object/opendal_engine/webhdfs.rs b/src/object_store/src/object/opendal_engine/webhdfs.rs index f591a91f8f16a..7116eac18582f 100644 --- a/src/object_store/src/object/opendal_engine/webhdfs.rs +++ b/src/object_store/src/object/opendal_engine/webhdfs.rs @@ -31,8 +31,7 @@ impl OpendalObjectStore { // NOTE: the root must be absolute path. builder.root(&root); - let atomic_write_dir = format!("{}{}", root, ATOMIC_WRITE_DIR); - builder.atomic_write_dir(&atomic_write_dir); + builder.atomic_write_dir(ATOMIC_WRITE_DIR); let op: Operator = Operator::new(builder)? .layer(LoggingLayer::default()) .layer(RetryLayer::default())