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: [email protected] With regards, Apache Git Services
