Correct chunk size.

lostluck · lostluck · commit 99514a6635d4 · 2023-09-14T18:02:34.000-07:00
diff --git a/sdks/go/pkg/beam/runners/prism/internal/jobservices/artifact.go b/sdks/go/pkg/beam/runners/prism/internal/jobservices/artifact.go
@@ -104,7 +104,7 @@ func (s *Server) GetArtifact(req *jobpb.GetArtifactRequest, stream jobpb.Artifac
 		slog.Warn("unable to provide artifact to worker", "artifact_info", pt)
 		return fmt.Errorf("unable to provide %v to worker", pt)
 	}
-	chunk := 4 * 1024 * 1024 // 128 MB
+	chunk := 128 * 1024 * 1024 // 128 MB
 	var i int
 	for i+chunk < len(buf) {
 		stream.Send(&jobpb.GetArtifactResponse{

Original file line number	Diff line number	Diff line change
`@@ -104,7 +104,7 @@ func (s Server) GetArtifact(req jobpb.GetArtifactRequest, stream jobpb.Artifac`
`104`	`104`	`slog.Warn("unable to provide artifact to worker", "artifact_info", pt)`
`105`	`105`	`return fmt.Errorf("unable to provide %v to worker", pt)`
`106`	`106`	`}`
`107`		`- chunk := 4 * 1024 * 1024 // 128 MB`
	`107`	`+ chunk := 128 * 1024 * 1024 // 128 MB`
`108`	`108`	`var i int`
`109`	`109`	`for i+chunk < len(buf) {`
`110`	`110`	`stream.Send(&jobpb.GetArtifactResponse{`