Hi,
Is there any way to detect the duration between the time when all the
map tasks have been assigned to a machine and the time when all the
reduce tasks finish?

Currently, I can only track the duration for JobClient.runJob(jobConf)
to run. But that duration includes the pending time when there is no
available machines in the cluster.

Regards,

Lei

Reply via email to