[
https://issues.apache.org/jira/browse/TEZ-2242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14383514#comment-14383514
]
Bikas Saha commented on TEZ-2242:
---------------------------------
The patch refactors ShuffleVertexManager
1) moves initialization code (e.g.) checking egde properties etc. from
intiializer() to onVertexStarted(). Before a vertex starts, the edges could be
un-initialized.
2) Adds checks in the receiving methods of VertexStatus events to allow for
derived classes to forward events to this as a base class.
Pig's use case is to create a vertex manager that derives from shuffle vertex
manager. The vertex manager sets an initial parallelism and that allows the
vertex to start. After that it delegates to shuffle vertex manager to further
do auto reduce. Change 2 allows the derived class to forward all events to
shuffle vertex manager without bothering about which events can be handled.
Change 1 fixes the issue exposed in current code while using the derived class.
The shuffle vertex manager would read num tasks/edge types during initialize()
when they would not be valid.
@rajesh balamoha
> Refactor ShuffleVertexManager code
> ----------------------------------
>
> Key: TEZ-2242
> URL: https://issues.apache.org/jira/browse/TEZ-2242
> Project: Apache Tez
> Issue Type: Bug
> Reporter: Bikas Saha
> Assignee: Bikas Saha
> Attachments: TEZ-2242.1.patch
>
>
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
