Fix Dumps ordering problem when writing

gugacavalieri · Nov 9, 2022 · 82b6a20 · 82b6a20
1 parent 92f3cdd
commit 82b6a20
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/replibyte/src/datastore/local_disk.rs b/replibyte/src/datastore/local_disk.rs
@@ -124,7 +124,7 @@ impl Datastore for LocalDisk {
 
         let data_size = data.len();
         let dump_dir_path = format!("{}/{}", self.dir, self.dump_name);
-        let dump_file_path = format!("{}/{}.dump", dump_dir_path, file_part);
+        let dump_file_path = format!("{}/{:02}.dump", dump_dir_path, file_part);
 
         // create the dump directory if needed
         DirBuilder::new()
@@ -317,7 +317,7 @@ mod tests {
 
         // part 1 of dump should exists
         assert!(Path::new(&format!(
-            "{}/{}/1.dump",
+            "{}/{}/01.dump",
             dir.path().to_str().unwrap(),
             dump.directory_name
         ))

diff --git a/replibyte/src/datastore/s3.rs b/replibyte/src/datastore/s3.rs
@@ -314,9 +314,9 @@ fn write_objects<B: Datastore>(
     };
 
     let data_size = data.len();
-    let key = format!("{}/{}.dump", root_key, file_part);
+    let key = format!("{}/{:02}.dump", root_key, file_part);
 
-    info!("upload object '{}' part {} on", key.as_str(), file_part);
+    info!("upload object '{}' part {:02} on", key.as_str(), file_part);
 
     let _ = create_object(client, bucket, key.as_str(), data)?;