search

twitter / scalding

A Scala API for Cascading
http://twitter.com/scalding
Apache License 2.0
3.48k stars 703 forks source link

Use BeamJoiner function in `planMapGroup` #1960

Closed nownikhil closed 2 years ago

nownikhil commented 2 years ago

User job was OOMing at groupBy step and the job finished after making this change.