some object store should set atomic_write_dir

risingwavelabs · Feb 20, 2024 · ef1342f · ef1342f
1 parent 8481ea7
commit ef1342f
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/src/object_store/src/object/opendal_engine/fs.rs b/src/object_store/src/object/opendal_engine/fs.rs
@@ -25,6 +25,7 @@ impl OpendalObjectStore {
         let mut builder = Fs::default();
 
         builder.root(&root);
+        builder.atomic_write_dir(&root);
 
         let op: Operator = Operator::new(builder)?
             .layer(RetryLayer::default())

diff --git a/src/object_store/src/object/opendal_engine/hdfs.rs b/src/object_store/src/object/opendal_engine/hdfs.rs
@@ -26,7 +26,7 @@ impl OpendalObjectStore {
         // Set the name node for hdfs.
         builder.name_node(&namenode);
         builder.root(&root);
-
+        builder.atomic_write_dir(&root);
         let op: Operator = Operator::new(builder)?
             .layer(LoggingLayer::default())
             .layer(RetryLayer::default())