Mailing-List: contact issues-help@tez.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@tez.apache.org
Date: Mon, 2 Feb 2015 23:18:34 +0000 (UTC)
From: "Hitesh Shah (JIRA)" <jira@apache.org>
To: issues@tez.apache.org
Message-ID: <JIRA.12771684.1422870180000.235319.1422919114496@Atlassian.JIRA>
In-Reply-To: <JIRA.12771684.1422870180000@Atlassian.JIRA>
References: <JIRA.12771684.1422870180000@Atlassian.JIRA>
 <JIRA.12771684.1422870180632@arcas>
Subject: [jira] [Commented] (TEZ-2022) java.lang.IllegalStateException:
 Vertex: got invalid start event
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit


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

Hitesh Shah commented on TEZ-2022:
----------------------------------

Seems like multiple bugs, one of which would be a variation of TEZ-1893 where a user error is not caught and causes the AM to crash. 

> java.lang.IllegalStateException: Vertex: got invalid start event
> ----------------------------------------------------------------
>
>                 Key: TEZ-2022
>                 URL: https://issues.apache.org/jira/browse/TEZ-2022
>             Project: Apache Tez
>          Issue Type: Bug
>            Reporter: Rajesh Balamohan
>         Attachments: TEZ-2022-DAG.png, TEZ-2022.applog.1.txt, TEZ-2022.applog.txt
>
>
> Latest Tez (with tez-2020 patch) + Pig 
> When running pig with rank function, the following exception happens consistently
> {code}
> java.lang.IllegalStateException: Vertex: vertex_1422270854961_0113_1_03 [scope-47] got invalid start event
>         at com.google.common.base.Preconditions.checkState(Preconditions.java:145)
>         at org.apache.tez.dag.app.dag.impl.VertexImpl$StartWhileInitializingTransition.transition(VertexImpl.java:3178)
>         at org.apache.tez.dag.app.dag.impl.VertexImpl$StartWhileInitializingTransition.transition(VertexImpl.java:3170)
>         at org.apache.hadoop.yarn.state.StateMachineFactory$SingleInternalArc.doTransition(StateMachineFactory.java:362)
>         at org.apache.hadoop.yarn.state.StateMachineFactory.doTransition(StateMachineFactory.java:302)
>         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.state.StateMachineTez.doTransition(StateMachineTez.java:57)
>         at org.apache.tez.dag.app.dag.impl.VertexImpl.handle(VertexImpl.java:1547)
>         at org.apache.tez.dag.app.dag.impl.VertexImpl.handle(VertexImpl.java:181)
>         at org.apache.tez.dag.app.DAGAppMaster$VertexEventDispatcher.handle(DAGAppMaster.java:1768)
>         at org.apache.tez.dag.app.DAGAppMaster$VertexEventDispatcher.handle(DAGAppMaster.java:1754)
>         at org.apache.tez.common.AsyncDispatcher.dispatch(AsyncDispatcher.java:184)
>         at org.apache.tez.common.AsyncDispatcher$1.run(AsyncDispatcher.java:116)
>         at java.lang.Thread.run(Thread.java:744)
> {code}
> {code}
> rawLogs = load '/tmp/logs/root/logs/application_1422270854961_0093/' using org.apache.tez.tools.TFileLoader() as (machine:chararray, key:chararray, line:chararray);
> raw = FOREACH rawLogs GENERATE TRIM(REGEX_EXTRACT(machine, '(.*)_(\\d+)', 1)) as machine, key, line;
> machines = FOREACH raw GENERATE machine;
> distinctMachines = DISTINCT machines;
> sortByMachines = ORDER distinctMachines BY machine;
> ranked = RANK sortByMachines;
> dump ranked;
> {code}
> Will attach the DAG and applog asap.


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