Disable singleIterate (#23042)

* Disable singleIterate * Comment with TODO
apache · Sep 6, 2022 · b2a6f46 · b2a6f46
1 parent 57f5c2c
commit b2a6f46
Showing 1 changed file with 2 additions and 1 deletion.
diff --git 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.