flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: KMeans result folder not created
Date Mon, 14 Mar 2016 09:54:57 GMT
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()”.

> On 13 Mar 2016, at 16:13, subash basnet <yasubash@gmail.com> wrote:
> 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 execution explicitly
> env.execute("KMeans Example");
> But if I run KMeans.java with above print statement via eclipse it works fine, but why
not when I upload it to the flink?
> Or is the flink taking long time to process the print statement before reaching writeAsCsv?
> Or after print statement writes to outputstream of JVM, the writeAsCsv doesn't get executed?

> Best Regards,
> Subash Basnet

View raw message