You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by "Navina Ramesh (JIRA)" <ji...@apache.org> on 2016/03/16 03:18:33 UTC

[jira] [Commented] (SAMZA-875) Don't try to access the package during containerStart

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

Navina Ramesh commented on SAMZA-875:
-------------------------------------

Hi [~alexeyraga]

Thanks for opening the JIRA and sorry for the delay in response. 
I understand what you are trying to say. But what is the issue that you face here, exactly? Are you getting exceptions? 

Thanks!

> Don't try to access the package during containerStart
> -----------------------------------------------------
>
>                 Key: SAMZA-875
>                 URL: https://issues.apache.org/jira/browse/SAMZA-875
>             Project: Samza
>          Issue Type: Bug
>          Components: container
>    Affects Versions: 0.10.1
>            Reporter: Alexey Raga
>
> When the job is submitted using {{run-job.sh}} the package file is given to {{YARN}}. The job is the accepted, the container is created, the package is unpacked and is ready to execute.
> However, the {{startContainer}} method ({{ContainerUtil:159}}) then tries to access the original package file. 
> {code}
>     try {
>       fileStatus = packagePath.getFileSystem(yarnConfiguration).getFileStatus(packagePath);
>     } catch (IOException ioe) {
>       log.error("IO Exception when accessing the package status from the filesystem", ioe);
>       throw new SamzaException("IO Exception when accessing the package status from the filesystem");
>     }
> {code}
> It wants to do it just to set the length of the file and the modification time to the resource:
> {code}
>     packageResource.setSize(fileStatus.getLen());
>     packageResource.setTimestamp(fileStatus.getModificationTime());
> {code}
> If these attributes (length and timestamp) are really needed then I think they could be captured and submitted by {{run-job.sh}} which would allow to avoid this issue.



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