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 于2018年9月26日周三 下午4:17写道：
> Hello,
>
> I am trying to measure
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 sa
