You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lo...@apache.org on 2020/08/12 22:36:42 UTC
[beam] branch master updated: [BEAM-10289] Adding required
transform ID to Go channel split.
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 <da...@gmail.com>
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,
}},