Reinstate comment

apache · Dec 29, 2022 · 8408321 · 8408321
1 parent 152368b
commit 8408321
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/sdks/go/pkg/beam/core/runtime/exec/sdf.go b/sdks/go/pkg/beam/core/runtime/exec/sdf.go
@@ -191,6 +191,8 @@ func (n *SplitAndSizeRestrictions) ProcessElement(ctx context.Context, elm *Full
 	rest := elm.Elm2.(*FullValue).Elm
 	ws := elm.Elm2.(*FullValue).Elm2
 
+	// If receiving directly from a datasource,
+	// the element may not be wrapped in a *FullValue
 	mainElm := convertIfNeeded(elm.Elm, &FullValue{})
 
 	splitRests := n.splitInv.Invoke(mainElm, rest)