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

Reply via email to