From 54f3913bedf3145a899f2ef872735dd54e468fcc Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Martin=20Stiborsk=C3=BD?= Date: Tue, 14 May 2024 15:48:24 +0200 Subject: [PATCH] [s3] Fixed s3 replication by sending content-md as base64 (#5596) --- weed/replication/sink/s3sink/s3_sink.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/weed/replication/sink/s3sink/s3_sink.go b/weed/replication/sink/s3sink/s3_sink.go index 81acd9a2d..6e7549cdc 100644 --- a/weed/replication/sink/s3sink/s3_sink.go +++ b/weed/replication/sink/s3sink/s3_sink.go @@ -11,6 +11,7 @@ import ( "github.com/seaweedfs/seaweedfs/weed/s3api/s3_constants" "strconv" "strings" + "encoding/base64" "github.com/seaweedfs/seaweedfs/weed/filer" "github.com/seaweedfs/seaweedfs/weed/glog" @@ -202,7 +203,7 @@ func (s3sink *S3Sink) CreateEntry(key string, entry *filer_pb.Entry, signatures Tagging: aws.String(tags), } if len(entry.Attributes.Md5) > 0 { - uploadInput.ContentMD5 = aws.String(fmt.Sprintf("%x", entry.Attributes.Md5)) + uploadInput.ContentMD5 = aws.String(base64.StdEncoding.EncodeToString([]byte(entry.Attributes.Md5))) } _, err = uploader.Upload(&uploadInput)