From 37955a956a3d8b4b3f721c797bc7971e002c1d2a Mon Sep 17 00:00:00 2001 From: Robert Burke Date: Thu, 29 Dec 2022 13:21:51 -0800 Subject: [PATCH] [#24789] Spot fix fullvalue wrapping for SDF. --- sdks/go/pkg/beam/core/runtime/exec/sdf.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/sdks/go/pkg/beam/core/runtime/exec/sdf.go b/sdks/go/pkg/beam/core/runtime/exec/sdf.go index be4f491b04cf8..3a1812f06027e 100644 --- a/sdks/go/pkg/beam/core/runtime/exec/sdf.go +++ b/sdks/go/pkg/beam/core/runtime/exec/sdf.go @@ -190,7 +190,8 @@ func (n *SplitAndSizeRestrictions) StartBundle(ctx context.Context, id string, d func (n *SplitAndSizeRestrictions) ProcessElement(ctx context.Context, elm *FullValue, values ...ReStream) error { rest := elm.Elm2.(*FullValue).Elm ws := elm.Elm2.(*FullValue).Elm2 - mainElm := elm.Elm.(*FullValue) + + mainElm := convertIfNeeded(elm.Elm, &FullValue{}) splitRests := n.splitInv.Invoke(mainElm, rest)