Skip to content

Commit e913907

Browse files
committed
fix(aws): allocate read buffer in S3 source
1 parent d43ee10 commit e913907

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

aws/s3.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -134,7 +134,7 @@ func (s *S3Source) getObjects(ctx context.Context) {
134134
slog.String("key", key))
135135
}
136136

137-
var data []byte
137+
data := make([]byte, s.config.ChunkSize)
138138
n, err := bufio.NewReaderSize(objectOutput.Body, s.config.ChunkSize).
139139
Read(data)
140140
if err != nil {

0 commit comments

Comments
 (0)