[ https://issues.apache.org/jira/browse/TEZ-3395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ming Ma updated TEZ-3395: ------------------------- Attachment: TEZ-3395.patch Here is the draft patch. The major changes are: * Move event handling to {{ShuffleVertexManagerBase}}. * Move the policies that decide when to trigger routing computation to {{ShuffleVertexManagerBase}}. Combine those policies into function {{getComputeRoutingAction}}. * Define the flow when {{ShuffleVertexManagerBase}} processes a completed source task in function {{processPendingTasks}}. * Rename PendingTaskInfo from outputStats to inputStats. * The routing computation is defined in {{ShuffleVertexManager}}. * The scheduling policy is defined in {{ShuffleVertexManager}}. * Fix comments such as from "All source tasks assigned" to "All source tasks completed”. * Parameterize {{TestShuffleVertexManager}} so that the majority of the test code can be reused by the new FairShuffleVertexManager. > Refactor ShuffleVertexManager > ----------------------------- > > Key: TEZ-3395 > URL: https://issues.apache.org/jira/browse/TEZ-3395 > Project: Apache Tez > Issue Type: Sub-task > Reporter: Ming Ma > Attachments: TEZ-3395.patch > > > By putting event handling and other common functionalities into a super > class, it makes writing new {{VertexManagerPlugin}} other than the existing > {{ShuffleVertexManager}} easier and more robust. -- This message was sent by Atlassian JIRA (v6.3.4#6332)