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 <[email protected]>
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
['"[email protected]" <[email protected]>'].
