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:09 UTC
[beam] 01/01: Revert "[Go SDK] Off By One error on splitting"
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),
},
},
},