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 =

                .types(String.class, String.class, String.class)



View raw message