diff --git a/flow/connectors/utils/avro/avro_writer.go b/flow/connectors/utils/avro/avro_writer.go
index 1908d43972..ad2597478a 100644
--- a/flow/connectors/utils/avro/avro_writer.go
+++ b/flow/connectors/utils/avro/avro_writer.go
@@ -197,11 +197,7 @@ func (p *peerDBOCFWriter) WriteRecordsToS3(
 		numRows, writeOcfError = p.WriteOCF(ctx, w)
 	}()
 
-	uploader := manager.NewUploader(s3svc, func(u *manager.Uploader) {
-		u.PartSize = 4 * 1024 * 1024 * 1024
-	})
-
-	_, err = uploader.Upload(ctx, &s3.PutObjectInput{
+	_, err = manager.NewUploader(s3svc).Upload(ctx, &s3.PutObjectInput{
 		Bucket: aws.String(bucketName),
 		Key:    aws.String(key),
 		Body:   r,