Hi Sean,
The fix was to provide explicitly typed versions of the the three generic
methods at the bottom of the code:
i.e
static List createListAndCombine(T v) {
List c = new ArrayList<>();
c.add(v);
return c;
}
becomes
static List createListAndCombine(Nut v) {
List c = new
I don't immediately see what the issue could be - try .count()-ing the
individual RDDs to narrow it down?
What code change made it work?
Also I think this could probably be a few lines of SQL with an
aggregate, collect_list(), and joins.
On Thu, May 21, 2020 at 11:27 PM Stephen Coy
wrote:
>
> Hi
