Hello, I am trying to measure the total time my flink app takes.
I've read it can be done with this:
val r = env.execute("NAME")
System.out.println("The job took " + r.getNetRuntime(TimeUnit.SECONDS) +
" s to execute")
The thing is, it works for some task, where all computations occur in
the same DAG (I Think), but in others I get different job assigned and
can't measure the time of the whole process.
How could I do it?
Best
--
elbauldelprogramador.com
0xAD8D7F23318B63C0.asc
Description: application/pgp-keys
signature.asc
Description: OpenPGP digital signature
