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

Rajesh Balamohan commented on TEZ-2419:
---------------------------------------

lgtm. Corner case in sorter with spill:- If there is a large partition being 
spilled, it is possible that 
{noformat}
while (spindex < mend &&
                kvmeta.get(offsetFor(spindex) + PARTITION) == i) {
...
..
writer.append(key, value);
}
{noformat}
can get into tight loop and might not respond to interrupts.  Listed down 
defaultsorter code. Should we check for interrupted status in this case? If 
this is relevant, it can be addressed in different jira. 

> Inputs/Outputs should inform the Processor about Interrupts when interrupted 
> during a blocking Op
> -------------------------------------------------------------------------------------------------
>
>                 Key: TEZ-2419
>                 URL: https://issues.apache.org/jira/browse/TEZ-2419
>             Project: Apache Tez
>          Issue Type: Improvement
>            Reporter: Siddharth Seth
>            Assignee: Siddharth Seth
>         Attachments: TEZ-2419.1.wip.txt, TEZ-2419.2.txt
>
>




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

Reply via email to