From ee0c387f5a4ab4f7740071be200e327af79746ce Mon Sep 17 00:00:00 2001 From: David Caputo Date: Wed, 16 Oct 2024 10:00:08 -0400 Subject: [PATCH] Fix Azure binlog upload for large files --- pkg/pxc/backup/storage/storage.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/pkg/pxc/backup/storage/storage.go b/pkg/pxc/backup/storage/storage.go index 876889445..1223c13ad 100644 --- a/pkg/pxc/backup/storage/storage.go +++ b/pkg/pxc/backup/storage/storage.go @@ -227,7 +227,10 @@ func (a *Azure) GetObject(ctx context.Context, name string) (io.ReadCloser, erro func (a *Azure) PutObject(ctx context.Context, name string, data io.Reader, _ int64) error { objPath := path.Join(a.prefix, name) - _, err := a.client.UploadStream(ctx, a.container, objPath, data, nil) + uploadOption := azblob.UploadStreamOptions{ + Concurrency: 4, + } + _, err := a.client.UploadStream(ctx, a.container, objPath, data, &uploadOption) if err != nil { return errors.Wrapf(err, "upload stream: %s", objPath) }