Hi,
the problem is that print() eagerly executes the program even before execute()
is called. For running the program on a cluster I would suggest to completely
remove the “.print()”.
Cheers,
Aljoscha
> On 13 Mar 2016, at 16:13, subash basnet wrote:
>
> Hello all,
>
> I created KMeans.jar fro
Hello all,
I created KMeans.jar from the source-code and it works fine.
But when I had put the *print* statement before *writeAsCsv, *the result
folder does not get created.
Eg:
clusteredPoints.print();
clusteredPoints.writeAsCsv(outputPath, "\n", " ");
// since file sinks are lazy, we trigger the
