[beam] branch master updated: Disable singleIterate (#23042)

[da...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

damccorm pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new b2a6f46fb21 Disable singleIterate (#23042)
b2a6f46fb21 is described below

commit b2a6f46fb21709cc1927ce1950a38a922dce0a35
Author: Danny McCormick <da...@google.com>
AuthorDate: Tue Sep 6 13:20:21 2022 -0400

    Disable singleIterate (#23042)
    
    * Disable singleIterate
    
    * Comment with TODO
---
 sdks/go/pkg/beam/core/runtime/exec/datasource.go | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/sdks/go/pkg/beam/core/runtime/exec/datasource.go b/sdks/go/pkg/beam/core/runtime/exec/datasource.go
index dc44470228c..3e5084e857d 100644
--- a/sdks/go/pkg/beam/core/runtime/exec/datasource.go
+++ b/sdks/go/pkg/beam/core/runtime/exec/datasource.go
@@ -78,7 +78,8 @@ func (n *DataSource) ID() UnitID {
 
 // Up initializes this datasource.
 func (n *DataSource) Up(ctx context.Context) error {
-	safeToSingleIterate := true
+	// TODO(https://github.com/apache/beam/issues/23043) - Reenable single iteration or more fully rip this out.
+	safeToSingleIterate := false
 	switch n.Out.(type) {
 	case *Expand, *Multiplex:
 		// CoGBK Expands aren't safe, as they may re-iterate the GBK stream.