[jira] [Created] (TEZ-933) Race in getting source / destination numTasks on an Edge

["Siddharth Seth (JIRA)" <ji...@apache.org>]

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)