Details
-
Bug
-
Status: Resolved
-
P2
-
Resolution: Fixed
-
None
Description
Another thing that works on the direct runner but fails on Dataflow: LazyAggregateCombineFn.mergeAccumulators [1] throws an UnsupportedOperationException because the "remove" method is not implemented in CombineFns$ProjectionIterable [2]. We will have to modify the implementation of LazyAggregateCombineFn.mergeAccumulators accordingly.
Attachments
Issue Links
- links to