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 2019/09/09 23:32:08 UTC
[beam] branch revert-9528-lostluck-patch-2 created (now f7b9d7e)
This is an automated email from the ASF dual-hosted git repository.
lostluck pushed a change to branch revert-9528-lostluck-patch-2
in repository https://gitbox.apache.org/repos/asf/beam.git.
at f7b9d7e Revert "[Go SDK] Off By One error on splitting"
This branch includes the following new commits:
new f7b9d7e Revert "[Go SDK] Off By One error on splitting"
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: Revert "[Go SDK] Off By One error on splitting"
Posted by lo...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
lostluck pushed a commit to branch revert-9528-lostluck-patch-2
in repository https://gitbox.apache.org/repos/asf/beam.git
commit f7b9d7efba4863e0f20b7901e04b1eaa1d248990
Author: Robert Burke <lo...@users.noreply.github.com>
AuthorDate: Mon Sep 9 16:31:38 2019 -0700
Revert "[Go SDK] Off By One error on splitting"
This reverts commit 4a618a2d48499ebab7379e3f26abc4e2833a4867.
---
sdks/go/pkg/beam/core/runtime/harness/harness.go | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/sdks/go/pkg/beam/core/runtime/harness/harness.go b/sdks/go/pkg/beam/core/runtime/harness/harness.go
index b5fffa5..642583d 100644
--- a/sdks/go/pkg/beam/core/runtime/harness/harness.go
+++ b/sdks/go/pkg/beam/core/runtime/harness/harness.go
@@ -272,8 +272,8 @@ func (c *control) handleInstruction(ctx context.Context, req *fnpb.InstructionRe
ProcessBundleSplit: &fnpb.ProcessBundleSplitResponse{
ChannelSplits: []*fnpb.ProcessBundleSplitResponse_ChannelSplit{
&fnpb.ProcessBundleSplitResponse_ChannelSplit{
- LastPrimaryElement: int32(split),
- FirstResidualElement: int32(split + 1),
+ LastPrimaryElement: int32(split - 1),
+ FirstResidualElement: int32(split),
},
},
},