testCrashed() |  | 0% |  | 0% | 12 | 12 | 113 | 113 | 1 | 1 |
testSpeculative() |  | 0% |  | 0% | 8 | 8 | 91 | 91 | 1 | 1 |
testMultipleCrashes() |  | 0% | | n/a | 1 | 1 | 72 | 72 | 1 | 1 |
testRecoveryFailsUsingCustomOutputCommitter() |  | 0% | | n/a | 1 | 1 | 81 | 81 | 1 | 1 |
testRecoveryWithoutShuffleSecret() |  | 0% | | n/a | 1 | 1 | 58 | 58 | 1 | 1 |
testOutputRecoveryMapsOnly() |  | 0% | | n/a | 1 | 1 | 59 | 59 | 1 | 1 |
testRecoverySuccessUsingCustomOutputCommitter() |  | 0% | | n/a | 1 | 1 | 64 | 64 | 1 | 1 |
testCrashOfMapsOnlyJob() |  | 0% | | n/a | 1 | 1 | 69 | 69 | 1 | 1 |
testOutputRecovery() |  | 0% | | n/a | 1 | 1 | 57 | 57 | 1 | 1 |
testRecoveryWithOldCommiter() |  | 0% | | n/a | 1 | 1 | 57 | 57 | 1 | 1 |
recoveryChecker(MapTaskImpl, TaskState, Map, ArgumentCaptor, List, long, long) |  | 0% |  | 0% | 12 | 12 | 48 | 48 | 1 | 1 |
testRecoveryWithSpillEncryption() |  | 0% | | n/a | 1 | 1 | 40 | 40 | 1 | 1 |
testRecoveryTaskSuccessAllAttemptsFail() |  | 0% | | n/a | 1 | 1 | 37 | 37 | 1 | 1 |
testRecoverySuccessAttempt() |  | 0% | | n/a | 1 | 1 | 36 | 36 | 1 | 1 |
testRecoveryAllFailAttempts() |  | 0% | | n/a | 1 | 1 | 36 | 36 | 1 | 1 |
testRecoveryTaskSuccessAllAttemptsSucceed() |  | 0% | | n/a | 1 | 1 | 36 | 36 | 1 | 1 |
testRecoveryAllAttemptsKilled() |  | 0% | | n/a | 1 | 1 | 36 | 36 | 1 | 1 |
getMockTaskAttemptInfo(TaskAttemptID, TaskAttemptState) |  | 0% | | n/a | 1 | 1 | 24 | 24 | 1 | 1 |
testPreviousJobIsNotCleanedWhenRecovery() |  | 0% | | n/a | 1 | 1 | 22 | 22 | 1 | 1 |
testPreviousJobOutputCleanedWhenNoRecovery() |  | 0% | | n/a | 1 | 1 | 21 | 21 | 1 | 1 |
getMockMapTask(long, EventHandler) |  | 0% | | n/a | 1 | 1 | 20 | 20 | 1 | 1 |
validateOutput() |  | 0% | | n/a | 1 | 1 | 11 | 11 | 1 | 1 |
writeBadOutput(TaskAttempt, Configuration) |  | 0% | | n/a | 1 | 1 | 20 | 20 | 1 | 1 |
writeOutput(TaskAttempt, Configuration) |  | 0% | | n/a | 1 | 1 | 20 | 20 | 1 | 1 |
slurp(File) |  | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
main(String[]) |  | 0% | | n/a | 1 | 1 | 14 | 14 | 1 | 1 |
TestRecovery() |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
setupClass() |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
waitForContainerAssignment(TaskAttempt) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
static {...} |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |