Author: sseth
Date: Wed May 1 07:30:33 2013
New Revision: 1477919
URL: http://svn.apache.org/r1477919
Log:
TEZ-98. TaskAttempt should be registered against a running container in
TaskAttemptListener. (sseth)
Modified:
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/TaskAttemptListenerImpTezDag.java
Modified:
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/TaskAttemptListenerImpTezDag.java
URL:
http://svn.apache.org/viewvc/incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/TaskAttemptListenerImpTezDag.java?rev=1477919&r1=1477918&r2=1477919&view=diff
==============================================================================
---
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/TaskAttemptListenerImpTezDag.java
(original)
+++
incubator/tez/branches/TEZ-1/tez-dag/src/main/java/org/apache/tez/dag/app/TaskAttemptListenerImpTezDag.java
Wed May 1 07:30:33 2013
@@ -220,6 +220,8 @@ public class TaskAttemptListenerImpTezDa
LOG.info("No task currently assigned to Container with id: "
+ containerId);
} else {
+ registerTaskAttempt(taskContext.getTask().getTaskAttemptId(),
+ containerId);
task = new ContainerTask(taskContext.getTask(), false);
context.getEventHandler().handle(
new TaskAttemptEventStartedRemotely(taskContext.getTask()
