[GitHub] johnyangk opened a new pull request #112: [NEMO-179] Delayed Task Cloning

[GitBox <gi...@apache.org>]

johnyangk opened a new pull request #112: [NEMO-179] Delayed Task Cloning
URL: https://github.com/apache/incubator-nemo/pull/112
 
 
   JIRA: [NEMO-179: Delayed Task Cloning](https://issues.apache.org/jira/projects/NEMO/issues/NEMO-179)
   
   **Major changes:**
   - Two options for ClonedSchedulingProperty: Speculative execution(fraction, medianTimeMultiplier) + Upfront cloning
   - ScheduledExecutorService in RuntimeMaster: Check for speculative execution every 100ms
   - Data structures to identify stragglers and clone tasks in PlanStateManager
   
   **Minor changes to note:**
   - Log when the speculative execution is triggered
   - Indentations
   
   **Tests for the changes:**
   - Unit test(TaskRetryTest): Tests combinations of Task retry + Task speculation (cloning), both of which lead to new task attempts
   - Integration test(WordCountITCase#testSpeculativeExecution): In addition to the existing test for upfront cloning, this tests conditional (very aggressive) speculative cloning.
   
   **Other comments:**
   - N/A
   
   resolves [NEMO-179](https://issues.apache.org/jira/projects/NEMO/issues/NEMO-179)
   

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services