[beam] branch beam24789convertifneeded2 created (now 37955a956a3)

[lo...@apache.org]

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

lostluck pushed a change to branch beam24789convertifneeded2
in repository https://gitbox.apache.org/repos/asf/beam.git


      at 37955a956a3 [#24789] Spot fix fullvalue wrapping for SDF.

This branch includes the following new commits:

     new 37955a956a3 [#24789] Spot fix fullvalue wrapping for SDF.

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

[beam] 01/01: [#24789] Spot fix fullvalue wrapping for SDF.

[lo...@apache.org]

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

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

commit 37955a956a3d8b4b3f721c797bc7971e002c1d2a
Author: Robert Burke <ro...@frantil.com>
AuthorDate: Thu Dec 29 13:21:51 2022 -0800

    [#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 be4f491b04c..3a1812f0602 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)