MAPREDUCE-5373. TestFetchFailure.testFetchFailureMultipleReduces could fail intermittently (jeagles)
git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/trunk@1542456 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
fef8f49c58
commit
a02e60fefc
@ -1546,6 +1546,9 @@ Release 0.23.10 - UNRELEASED
|
||||
|
||||
MAPREDUCE-5587. TestTextOutputFormat fails on JDK7 (jeagles)
|
||||
|
||||
MAPREDUCE-5373. TestFetchFailure.testFetchFailureMultipleReduces could fail
|
||||
intermittently (jeagles)
|
||||
|
||||
Release 0.23.9 - 2013-07-08
|
||||
|
||||
INCOMPATIBLE CHANGES
|
||||
|
@ -322,19 +322,19 @@ public void testFetchFailureMultipleReduces() throws Exception {
|
||||
reduceTask3.getAttempts().values().iterator().next();
|
||||
app.waitForState(reduceAttempt3, TaskAttemptState.RUNNING);
|
||||
updateStatus(app, reduceAttempt3, Phase.SHUFFLE);
|
||||
|
||||
//send 3 fetch failures from reduce to trigger map re execution
|
||||
|
||||
//send 2 fetch failures from reduce to prepare for map re execution
|
||||
sendFetchFailure(app, reduceAttempt, mapAttempt1);
|
||||
sendFetchFailure(app, reduceAttempt, mapAttempt1);
|
||||
sendFetchFailure(app, reduceAttempt, mapAttempt1);
|
||||
|
||||
|
||||
//We should not re-launch the map task yet
|
||||
assertEquals(TaskState.SUCCEEDED, mapTask.getState());
|
||||
updateStatus(app, reduceAttempt2, Phase.REDUCE);
|
||||
updateStatus(app, reduceAttempt3, Phase.REDUCE);
|
||||
|
||||
|
||||
//send 3rd fetch failures from reduce to trigger map re execution
|
||||
sendFetchFailure(app, reduceAttempt, mapAttempt1);
|
||||
|
||||
|
||||
//wait for map Task state move back to RUNNING
|
||||
app.waitForState(mapTask, TaskState.RUNNING);
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user