clusteredPoints.writeAsCsv(outputPath, "\n", " ");
// since file sinks are lazy, we trigger the execution explicitly
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?