[beam] branch go-sdk updated: BEAM-3473: Fix GroupByKey iterators to be initialized.

[lc...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

lcwik pushed a commit to branch go-sdk
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/go-sdk by this push:
     new 1fe55ca  BEAM-3473: Fix GroupByKey iterators to be initialized.
1fe55ca is described below

commit 1fe55cac882a0cd60828ced4fc6b002c391de7cf
Author: Bill Neubauer <wc...@google.com>
AuthorDate: Fri Jan 12 11:07:47 2018 -0800

    BEAM-3473: Fix GroupByKey iterators to be initialized.
---
 sdks/go/pkg/beam/core/runtime/exec/fn.go | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/sdks/go/pkg/beam/core/runtime/exec/fn.go b/sdks/go/pkg/beam/core/runtime/exec/fn.go
index d23ec32..80fab1b 100644
--- a/sdks/go/pkg/beam/core/runtime/exec/fn.go
+++ b/sdks/go/pkg/beam/core/runtime/exec/fn.go
@@ -78,7 +78,9 @@ func Invoke(ctx context.Context, fn *funcx.Fn, opt *MainInput, extra ...reflect.
 
 			// TODO(herohde) 12/12/2017: allow form conversion on GBK results?
 
-			args[in[i]] = makeIter(param.T, iter).Value()
+			it := makeIter(param.T, iter)
+			it.Init()
+			args[in[i]] = it.Value()
 			i++
 		}
 	}

-- 
To stop receiving notification emails like this one, please contact
['"commits@beam.apache.org" <co...@beam.apache.org>'].