beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lostl...@apache.org
Subject [beam] branch master updated: Go changes for model updates. (#11211)
Date Wed, 25 Mar 2020 16:08:28 GMT
This is an automated email from the ASF dual-hosted git repository.

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


The following commit(s) were added to refs/heads/master by this push:
     new ba31a28  Go changes for model updates. (#11211)
ba31a28 is described below

commit ba31a28f5a3b3b28a3e09ebd9b5ac5b14dcde80a
Author: Robert Bradshaw <robertwb@google.com>
AuthorDate: Wed Mar 25 09:08:10 2020 -0700

    Go changes for model updates. (#11211)
---
 sdks/go/pkg/beam/core/runtime/pipelinex/clone.go | 2 --
 1 file changed, 2 deletions(-)

diff --git a/sdks/go/pkg/beam/core/runtime/pipelinex/clone.go b/sdks/go/pkg/beam/core/runtime/pipelinex/clone.go
index 12465a8..07b7d23 100644
--- a/sdks/go/pkg/beam/core/runtime/pipelinex/clone.go
+++ b/sdks/go/pkg/beam/core/runtime/pipelinex/clone.go
@@ -64,10 +64,8 @@ func ShallowCloneParDoPayload(p *pb.ParDoPayload) *pb.ParDoPayload {
 
 	ret := &pb.ParDoPayload{
 		DoFn:               p.DoFn,
-		Splittable:         p.Splittable,
 		RestrictionCoderId: p.RestrictionCoderId,
 	}
-	ret.Parameters, _ = reflectx.ShallowClone(p.Parameters).([]*pb.Parameter)
 	ret.SideInputs, _ = reflectx.ShallowClone(p.SideInputs).(map[string]*pb.SideInput)
 	ret.StateSpecs, _ = reflectx.ShallowClone(p.StateSpecs).(map[string]*pb.StateSpec)
 	ret.TimerSpecs, _ = reflectx.ShallowClone(p.TimerSpecs).(map[string]*pb.TimerSpec)


Mime
View raw message