Hi,
Can you express it more clearly? Whether you measure the execution time of
the job or the execution time of the task instance.
Why can't you measure the kind of scene you said? All jobs are logically a
DAG.
Thanks, vino.
Alejandro <algu...@gmail.com> 于2018年9月26日周三 下午4:17写道：
> 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
>
