flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Yassine MARZOUGUI <y.marzou...@mindlytix.com>
Subject Simple batch job hangs if run twice
Date Fri, 09 Sep 2016 14:40:55 GMT
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

Mime
View raw message