Hi all,
When I run the following batch job inside the IDE for the first time, it
outputs results and switches to FINISHED, but when I run it again it is
stuck in the state RUNNING. The csv file size is 160 MB. What could be the
reason for this behaviour?
public class BatchJob {
public static void main(String[] args) throws Exception {
final ExecutionEnvironment env =
ExecutionEnvironment.getExecutionEnvironment();
env.readCsvFile("dump.csv")
.ignoreFirstLine()
.fieldDelimiter(";")
.includeFields("111000")
.types(String.class, String.class, String.class)
.first(100)
.print();
}
}
Best,
Yassine