flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Robert Metzger <metrob...@gmail.com>
Subject Re: Flink execution time benchmark
Date Sat, 21 Mar 2015 12:19:36 GMT
Hi,

The execute() method returns an execution result object that also contains the runtime of
the job.



Sent from my iPhone

> On 21.03.2015, at 11:09, Giacomo Licari <giacomo.licari@gmail.com> wrote:
> 
> Hi guys,
> I'm trying to execute a benchmark reading a 1GB file and applying a reduce function.
> 
> I'd like to get the overall execution time.
> 
> I put that code before applying the reduce function:
> long startTime = System.currentTimeMillis();
> 
> and after env.execute("Flink Processor"); I put the code to print out the overall time,
but it doen't work.
> 
> Did you try something about?
> 
> Thanks a lot,
> Giacomo

Mime
View raw message