From 8408321e96f1c47f327fcfb7ee3cd8a7fc649098 Mon Sep 17 00:00:00 2001 From: Robert Burke Date: Thu, 29 Dec 2022 13:28:43 -0800 Subject: [PATCH] Reinstate comment --- sdks/go/pkg/beam/core/runtime/exec/sdf.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/sdks/go/pkg/beam/core/runtime/exec/sdf.go b/sdks/go/pkg/beam/core/runtime/exec/sdf.go index 62af4c2e1ab2..d4b1b32d257d 100644 --- 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)