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 <rober...@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)
