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 f0951fb [BEAM-10289] Adding required transform ID to Go channel split.
new 5b79814 Merge pull request #12555 from [BEAM-10289] Adding required
transform ID to Go channel split.
f0951fb is described below
commit f0951fbd7dc1d594ea54bd9b7b66d254aec0e920
Author: Daniel Oliveira <[email protected]>
AuthorDate: Wed Aug 12 13:52:59 2020 -0700
[BEAM-10289] Adding required transform ID to Go channel split.
---
sdks/go/pkg/beam/core/runtime/harness/harness.go | 1 +
1 file changed, 1 insertion(+)
diff --git a/sdks/go/pkg/beam/core/runtime/harness/harness.go
b/sdks/go/pkg/beam/core/runtime/harness/harness.go
index 1f904df..0dd4832 100644
--- a/sdks/go/pkg/beam/core/runtime/harness/harness.go
+++ b/sdks/go/pkg/beam/core/runtime/harness/harness.go
@@ -347,6 +347,7 @@ func (c *control) handleInstruction(ctx context.Context,
req *fnpb.InstructionRe
Response: &fnpb.InstructionResponse_ProcessBundleSplit{
ProcessBundleSplit:
&fnpb.ProcessBundleSplitResponse{
ChannelSplits:
[]*fnpb.ProcessBundleSplitResponse_ChannelSplit{{
+ TransformId:
plan.SourcePTransformID(),
LastPrimaryElement: sr.PI,
FirstResidualElement: sr.RI,
}},
