Measure task execution time

[Alejandro Alcalde]

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

[vino yang]

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 <[hidden email]> 于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