Daniel Oliveira created BEAM-9526:
-------------------------------------
Summary: Bug in top.LargestPerKey, disappearing elements.
Key: BEAM-9526
URL: https://issues.apache.org/jira/browse/BEAM-9526
Project: Beam
Issue Type: Bug
Components: sdk-go
Reporter: Daniel Oliveira
Assignee: Daniel Oliveira
There's a bug in top.LargestPerKey that appears when running it on a runner
that has combiner lifting. Since it's similar to a GBK, we should be inputting
a K, V and receiving a K, []V as output. When the runner has combiner lifting,
the []V always contains an empty slice.
I already found the fix for this, just logging this to attach it to the PR.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)