flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: Simple batch job hangs if run twice
Date Sat, 17 Sep 2016 13:15:58 GMT
Hi,
when is the "first time". It seems you have tried this repeatedly so what
differentiates a "first time" from the other times? Are you closing your
IDE in-between or do you mean running the job a second time within the same
program?

Cheers,
Aljoscha

On Fri, 9 Sep 2016 at 16:40 Yassine MARZOUGUI <y.marzougui@mindlytix.com>
wrote:

> 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