I have a program that contains a preprocessing with Flink Objects and at the 
end writes the result with „result.writeAsText(„...“)“.
After that I call a method that is basically a MapReduce-Job (actually only a 
Map-Job) which depends on the written file.

So what is the smartest way to delay the execution of the Map-Job until the 
file is written completely?
Right now I I am doing it the following way:

val written = result.writeAsText(„…“)
if(written.getDataSet.count() > 0){ ...do Map-Job...}

Thanks in advance!
Best regards,

Reply via email to