You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@tez.apache.org by "Jonathan Eagles (JIRA)" <ji...@apache.org> on 2016/08/12 20:25:20 UTC

[jira] [Commented] (TEZ-3408) Allow Task Output Files to reside in DAG specific directories for Custom Shuffle Handler

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

Jonathan Eagles commented on TEZ-3408:
--------------------------------------

Unused import
{code:title=TestShuffleHandler.java}
import org.apache.tez.runtime.library.common.shuffle.ShuffleUtils;
{code}

Since SimpleFetchedInputAllocator is a private class. Just modify the constructor to always take a dagId. Then you can removed the constructor helper getSimpleFetchedInputAllocator and keep the logic from polluting UnorderedKVInput

TODO comment addressed (file a jira) or removed
{code:title=TezTaskOutputFiles}
//TODO : Add dag based logic
{code}

Comments in TezTaskOutputFiles don't reflect the new
{code:title=TezTaskOutputFiles}
  /*
   * ${appDir}/output/${uniqueId}
   */
  private Path getAttemptOutputDir() {
{code}

> Allow Task Output Files to reside in DAG specific directories for Custom Shuffle Handler
> ----------------------------------------------------------------------------------------
>
>                 Key: TEZ-3408
>                 URL: https://issues.apache.org/jira/browse/TEZ-3408
>             Project: Apache Tez
>          Issue Type: Sub-task
>            Reporter: Kuhu Shukla
>            Assignee: Kuhu Shukla
>         Attachments: TEZ-3408.001.patch, TEZ-3408.002.patch
>
>
> When configured to use Custom Tez Shuffle Handler, the task output files can be in DAG specific output directories,for example: \{appDir\}/dag_123/output/$\{uniqueId\}/file.out
> This is one step towards multiple files feature.



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