[jira] [Updated] (MAPREDUCE-2512) wait(5000) and notify() mechanism can be implemented instead of sleep(5000) in reduce task when there are no copies in progress and no new copies to schedule

2011-06-06 Thread Todd Lipcon (JIRA) 

 [ 
https://issues.apache.org/jira/browse/MAPREDUCE-2512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Todd Lipcon updated MAPREDUCE-2512:
---

Status: Open  (was: Patch Available)

> wait(5000) and notify() mechanism can be implemented instead of sleep(5000) 
> in reduce task when there are no copies in progress and no new copies to 
> schedule
> -
>
> Key: MAPREDUCE-2512
> URL: https://issues.apache.org/jira/browse/MAPREDUCE-2512
> Project: Hadoop Map/Reduce
>  Issue Type: Improvement
>  Components: task
>Affects Versions: 0.20.2
>Reporter: Devaraj K
>Assignee: Devaraj K
> Fix For: 0.20.4
>
> Attachments: MAPREDUCE-2512.patch
>
>
> {code:title=ReduceTask.java|borderStyle=solid} 
>try { 
> if (numInFlight == 0 && numScheduled == 0) { 
>   // we should indicate progress as we don't want TT to think 
>   // we're stuck and kill us 
>   reporter.progress(); 
>   Thread.sleep(5000); 
> } 
>   } catch (InterruptedException e) { } // IGNORE 
> {code} 
> Here if we have no copies in flight and we can't schedule anything new, it is 
> going to wait for 5000 millis. Instead of waiting for 5000 millis, this 
> thread can wait with timeout and GetMapEventsThread can notify it if gets new 
> map completion events earlier than 5000 millis time. 
>  

--
This message is automatically generated by JIRA.
For more information on JIRA, see: http://www.atlassian.com/software/jira

[jira] [Updated] (MAPREDUCE-2512) wait(5000) and notify() mechanism can be implemented instead of sleep(5000) in reduce task when there are no copies in progress and no new copies to schedule

2011-06-03 Thread Devaraj K (JIRA) 

 [ 
https://issues.apache.org/jira/browse/MAPREDUCE-2512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Devaraj K updated MAPREDUCE-2512:
-

Fix Version/s: 0.20.4
   Status: Patch Available  (was: Open)

Patch is provided for 0.20.4 version.

> wait(5000) and notify() mechanism can be implemented instead of sleep(5000) 
> in reduce task when there are no copies in progress and no new copies to 
> schedule
> -
>
> Key: MAPREDUCE-2512
> URL: https://issues.apache.org/jira/browse/MAPREDUCE-2512
> Project: Hadoop Map/Reduce
>  Issue Type: Improvement
>  Components: task
>Affects Versions: 0.20.2
>Reporter: Devaraj K
>Assignee: Devaraj K
> Fix For: 0.20.4
>
> Attachments: MAPREDUCE-2512.patch
>
>
> {code:title=ReduceTask.java|borderStyle=solid} 
>try { 
> if (numInFlight == 0 && numScheduled == 0) { 
>   // we should indicate progress as we don't want TT to think 
>   // we're stuck and kill us 
>   reporter.progress(); 
>   Thread.sleep(5000); 
> } 
>   } catch (InterruptedException e) { } // IGNORE 
> {code} 
> Here if we have no copies in flight and we can't schedule anything new, it is 
> going to wait for 5000 millis. Instead of waiting for 5000 millis, this 
> thread can wait with timeout and GetMapEventsThread can notify it if gets new 
> map completion events earlier than 5000 millis time. 
>  

--
This message is automatically generated by JIRA.
For more information on JIRA, see: http://www.atlassian.com/software/jira

[jira] [Updated] (MAPREDUCE-2512) wait(5000) and notify() mechanism can be implemented instead of sleep(5000) in reduce task when there are no copies in progress and no new copies to schedule

2011-06-03 Thread Devaraj K (JIRA) 

 [ 
https://issues.apache.org/jira/browse/MAPREDUCE-2512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Devaraj K updated MAPREDUCE-2512:
-

Attachment: MAPREDUCE-2512.patch

> wait(5000) and notify() mechanism can be implemented instead of sleep(5000) 
> in reduce task when there are no copies in progress and no new copies to 
> schedule
> -
>
> Key: MAPREDUCE-2512
> URL: https://issues.apache.org/jira/browse/MAPREDUCE-2512
> Project: Hadoop Map/Reduce
>  Issue Type: Improvement
>  Components: task
>Affects Versions: 0.20.2
>Reporter: Devaraj K
>Assignee: Devaraj K
> Attachments: MAPREDUCE-2512.patch
>
>
> {code:title=ReduceTask.java|borderStyle=solid} 
>try { 
> if (numInFlight == 0 && numScheduled == 0) { 
>   // we should indicate progress as we don't want TT to think 
>   // we're stuck and kill us 
>   reporter.progress(); 
>   Thread.sleep(5000); 
> } 
>   } catch (InterruptedException e) { } // IGNORE 
> {code} 
> Here if we have no copies in flight and we can't schedule anything new, it is 
> going to wait for 5000 millis. Instead of waiting for 5000 millis, this 
> thread can wait with timeout and GetMapEventsThread can notify it if gets new 
> map completion events earlier than 5000 millis time. 
>  

--
This message is automatically generated by JIRA.
For more information on JIRA, see: http://www.atlassian.com/software/jira