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

Rajesh Balamohan commented on TEZ-2454:
---------------------------------------

- FetcherOrderedGrouped - MapHost would not be null in fetchNext()?
- FetcherOrderedGrouped- httpConnection need not be volatile?
- HttpConnection - connection, DataInputStream, connectionSucceeed need not be 
volatile?
- "count" in ShuffleSchedulerCallable should be incremented in inner loop?, 
otherwise it might end up scheduling continuously.

> Change FetcherOrderedGroup to work as Callables instead of blocking threads
> ---------------------------------------------------------------------------
>
>                 Key: TEZ-2454
>                 URL: https://issues.apache.org/jira/browse/TEZ-2454
>             Project: Apache Tez
>          Issue Type: Improvement
>            Reporter: Siddharth Seth
>            Assignee: Siddharth Seth
>         Attachments: TEZ-2454.1.wip.txt, TEZ-2454.2.txt
>
>
> The Fetcher threads for Ordered Input currently run and block till merge 
> completes, which makes it difficult to use them via ThreadPools.



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

Reply via email to