Siddharth Seth created TEZ-933:
----------------------------------
Summary: Race in getting source / destination numTasks on an Edge
Key: TEZ-933
URL: https://issues.apache.org/jira/browse/TEZ-933
Project: Apache Tez
Issue Type: Bug
Reporter: Siddharth Seth
Assignee: Siddharth Seth
Edges rely on getting properties (specifically numTasks in this case) from the
source or destination vertex.
This can end up with an incorrect value being used depending on the state of
the vertex - whether the vertex has been initialized, whether the parallelism
has been changed etc.
As an example
{code}
edgeManager.getNumSourceTaskPhysicalOutputs(destinationVertex.getTotalTasks(),
sourceTaskIndex))
{code}
destinationVertex.getTotalTasks() may be incorrect if the destinationVertex
hasn't yet been initialized. Alternately, this value can change based on
setParallelism calls.
--
This message was sent by Atlassian JIRA
(v6.2#6252)
