[ 
https://issues.apache.org/jira/browse/TEZ-1564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14275785#comment-14275785
 ] 

Hitesh Shah commented on TEZ-1564:
----------------------------------

Seems like a bug/race condition somewhere:

{code}
2014-09-09 21:47:16,744 INFO [AsyncDispatcher event handler] 
org.apache.tez.dag.history.HistoryEventHandler: 
[HISTORY][DAG:dag_1409722953518_0162_1][Event:TASK_STARTED]: vertexName=Map 5, 
taskId=task_1409722953518_0162_1_07_000000, scheduledTime=1410324436744, 
launchTime=1410324436744
2014-09-09 21:47:16,744 INFO [AsyncDispatcher event handler] 
org.apache.tez.dag.app.dag.impl.TaskImpl: task_1409722953518_0162_1_07_000000 
Task Transitioned from NEW to SCHEDULED
2014-09-09 21:47:16,757 ERROR [AsyncDispatcher event handler] 
org.apache.tez.dag.app.dag.impl.TaskImpl: Can't handle this event at current 
state for task_1409722953518_0162_1_07_000000
2014-09-09 21:47:16,760 ERROR [AsyncDispatcher event handler] 
org.apache.tez.dag.app.dag.impl.TaskImpl: Invalid event T_SCHEDULE on Task 
task_1409722953518_0162_1_07_000000 in state:SCHEDULED
{code}

Somehow the task is being scheduled twice. 

> State machine error: Invalid event: T_SCHEDULE at SCHEDULED
> -----------------------------------------------------------
>
>                 Key: TEZ-1564
>                 URL: https://issues.apache.org/jira/browse/TEZ-1564
>             Project: Apache Tez
>          Issue Type: Bug
>            Reporter: Rajesh Balamohan
>            Priority: Critical
>         Attachments: applogs.txt.tar.gz, dag.dot
>
>
> ERROR [AsyncDispatcher event handler] 
> org.apache.tez.dag.app.dag.impl.TaskImpl: Can't handle this event at current 
> state for task_1409722953518_0162_1_07_000000
> org.apache.hadoop.yarn.state.InvalidStateTransitonException: Invalid event: 
> T_SCHEDULE at SCHEDULED
>       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.TaskImpl.handle(TaskImpl.java:827)
>       at org.apache.tez.dag.app.dag.impl.TaskImpl.handle(TaskImpl.java:95)
>       at 
> org.apache.tez.dag.app.DAGAppMaster$TaskEventDispatcher.handle(DAGAppMaster.java:1604)
>       at 
> org.apache.tez.dag.app.DAGAppMaster$TaskEventDispatcher.handle(DAGAppMaster.java:1590)
>       at 
> org.apache.hadoop.yarn.event.AsyncDispatcher.dispatch(AsyncDispatcher.java:173)
>       at 
> org.apache.hadoop.yarn.event.AsyncDispatcher$1.run(AsyncDispatcher.java:106)
>       at java.lang.Thread.run(Thread.java:724)
> I will attach the dag + app logs soon.



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

Reply via email to