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