[ 
https://issues.apache.org/jira/browse/TEZ-2163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Jeff Zhang updated TEZ-2163:
----------------------------
    Attachment: TEZ-2163-1.patch

Upload patch to address this issue, besides also remove some unnecessary code 
in TaskAttemptImpl.java  [~sseth] Please help review

> Task status update should be handled in the START_WAIT state
> ------------------------------------------------------------
>
>                 Key: TEZ-2163
>                 URL: https://issues.apache.org/jira/browse/TEZ-2163
>             Project: Apache Tez
>          Issue Type: Sub-task
>            Reporter: Siddharth Seth
>            Assignee: Jeff Zhang
>            Priority: Critical
>         Attachments: TEZ-2163-1.patch
>
>
> It;s possible for a task to send in a STATUS_UPDATE before the 
> TA_STARTED_REMOTELY message is processed within the AM.
> {code}
> 2015-02-27 13:21:15,491 ERROR [Dispatcher thread: Central] 
> impl.TaskAttemptImpl: Can't handle this event at current state for 
> attempt_1424502260528_0177_5_03_000223_0
> org.apache.hadoop.yarn.state.InvalidStateTransitonException: Invalid event: 
> TA_STATUS_UPDATE at START_WAIT
>   at 
> org.apache.hadoop.yarn.state.StateMachineFactory.doTransition(StateMachineFactory.java:305)
>   at 
> org.apache.hadoop.yarn.state.StateMachineFactory.access$300(StateMachineFactory.java:46)
>   at 
> org.apache.hadoop.yarn.state.StateMachineFactory$InternalStateMachine.doTransition(StateMachineFactory.java:448)
>   at 
> org.apache.tez.dag.app.dag.impl.TaskAttemptImpl.handle(TaskAttemptImpl.java:670)
>   at 
> org.apache.tez.dag.app.dag.impl.TaskAttemptImpl.handle(TaskAttemptImpl.java:112)
>   at 
> org.apache.tez.dag.app.DAGAppMaster$TaskAttemptEventDispatcher.handle(DAGAppMaster.java:1835)
>   at 
> org.apache.tez.dag.app.DAGAppMaster$TaskAttemptEventDispatcher.handle(DAGAppMaster.java:1820)
>   at org.apache.tez.common.AsyncDispatcher.dispatch(AsyncDispatcher.java:184)
>   at org.apache.tez.common.AsyncDispatcher$1.run(AsyncDispatcher.java:115)
>   at java.lang.Thread.run(Thread.java:745)
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to