Add MD5 hash to snapshot validation marker puts. (#1126)

mattl-netflix · web-flow · commit aeeb7e1c8ee3 · 2025-11-28T15:58:11.000-08:00
diff --git a/priam/src/main/java/com/netflix/priam/aws/S3FileSystem.java b/priam/src/main/java/com/netflix/priam/aws/S3FileSystem.java
@@ -105,8 +105,9 @@ protected void downloadFileImpl(AbstractBackupPath path, String suffix)
 
     @Override
     public void putObject(String bucket, String key, String value) {
+        String md5 = SystemUtils.toBase64(SystemUtils.md5(value.getBytes()));
         s3Client.putObject(
-                PutObjectRequest.builder().bucket(bucket).key(key).build(),
+                PutObjectRequest.builder().bucket(bucket).key(key).contentMD5(md5).build(),
                 RequestBody.fromBytes(value.getBytes()));
     }
 

Original file line number	Diff line number	Diff line change
`@@ -105,8 +105,9 @@ protected void downloadFileImpl(AbstractBackupPath path, String suffix)`
`105`	`105`
`106`	`106`	`@Override`
`107`	`107`	`public void putObject(String bucket, String key, String value) {`
	`108`	`+ String md5 = SystemUtils.toBase64(SystemUtils.md5(value.getBytes()));`
`108`	`109`	`s3Client.putObject(`
`109`		`- PutObjectRequest.builder().bucket(bucket).key(key).build(),`
	`110`	`+ PutObjectRequest.builder().bucket(bucket).key(key).contentMD5(md5).build(),`
`110`	`111`	`RequestBody.fromBytes(value.getBytes()));`
`111`	`112`	`}`
`112`	`113`