damccorm commented on code in PR #35263:
URL: https://github.com/apache/beam/pull/35263#discussion_r2152753886


##########
sdks/go/pkg/beam/runners/prism/internal/stage.go:
##########
@@ -194,7 +194,8 @@ progress:
                case resp = <-b.Resp:
                        bundleFinished = true
                        if b.BundleErr != nil {
-                               return b.BundleErr
+                               // return b.BundleErr
+                               panic("this should get triggered")

Review Comment:
   Interestingly 
https://github.com/apache/beam/pull/35263/commits/9eaebbc81feef3ca2303ce7dafef1175338e4b0a
 causes the job to panic (correctly) 100% of the time (over 8 runs).
   
   But 
https://github.com/apache/beam/pull/35263/commits/837db22bc4c7c61dd5857be9a70a1c0a66f947c8
 only causes the job to panic (correctly) some of the time (3/4 runs).
   
   While 
https://github.com/apache/beam/pull/35263/commits/cbc2d2f6e766757fa1c85816112f0dab8a55b47c
 causes the job to panic (correctly) almost all of the time (16/16 runs), but 
not quite always.
   
   My current theory is that we're sometimes breaking either here:
   
   
https://github.com/apache/beam/blob/2e956263496564a614d216b7f985fa5a793baad7/sdks/go/pkg/beam/runners/prism/internal/stage.go#L210-L213
   
   or here
   
   
https://github.com/apache/beam/blob/2e956263496564a614d216b7f985fa5a793baad7/sdks/go/pkg/beam/runners/prism/internal/stage.go#L226-L229
   
   but those don't cause errors. I'm not sure what the correct behavior is, but 
it seems like we should probably either be continuing or throwing?



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: github-unsubscr...@beam.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to