| testParallelJobsToSameDestination() |  | 0% |  | 0% | 3 | 3 | 71 | 71 | 1 | 1 |
| testMapFileOutputCommitter() |  | 0% | | n/a | 1 | 1 | 38 | 38 | 1 | 1 |
| testOutputFormatIntegration() |  | 0% |  | 0% | 2 | 2 | 43 | 43 | 1 | 1 |
| testParallelJobsToAdjacentPaths() |  | 0% | | n/a | 1 | 1 | 44 | 44 | 1 | 1 |
| testConcurrentCommitTaskWithSubDir() |  | 0% |  | 0% | 4 | 4 | 28 | 28 | 1 | 1 |
| testTwoTaskAttemptsCommit() |  | 0% | | n/a | 1 | 1 | 33 | 33 | 1 | 1 |
| testSelfGeneratedUUID() |  | 0% | | n/a | 1 | 1 | 29 | 29 | 1 | 1 |
| testRecoveryAndCleanup() |  | 0% | | n/a | 1 | 1 | 27 | 27 | 1 | 1 |
| testCommitLifecycle() |  | 0% | | n/a | 1 | 1 | 24 | 24 | 1 | 1 |
| validateContent(Path, boolean, String) |  | 0% |  | 0% | 2 | 2 | 14 | 14 | 1 | 1 |
| testFailAbort() |  | 0% | | n/a | 1 | 1 | 17 | 17 | 1 | 1 |
| testCommitWithStorageClassConfig() |  | 0% | | n/a | 1 | 1 | 19 | 19 | 1 | 1 |
| testS3ACommitterFactoryBinding() |  | 0% | | n/a | 1 | 1 | 12 | 12 | 1 | 1 |
| startJob(AbstractITCommitProtocol.CommitterFactory, boolean) |  | 0% |  | 0% | 2 | 2 | 13 | 13 | 1 | 1 |
| validateMapFileOutputContent(FileSystem, Path) |  | 0% | | n/a | 1 | 1 | 11 | 11 | 1 | 1 |
| writeMapFileOutput(RecordWriter, TaskAttemptContext) |  | 0% |  | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
| testCommitterWithDuplicatedCommit() |  | 0% |  | 0% | 4 | 4 | 14 | 14 | 1 | 1 |
| testAMWorkflow() |  | 0% | | n/a | 1 | 1 | 18 | 18 | 1 | 1 |
| teardown() |  | 0% |  | 0% | 3 | 3 | 15 | 15 | 1 | 1 |
| writeOutput(RecordWriter, TaskAttemptContext) |  | 0% | | n/a | 1 | 1 | 12 | 12 | 1 | 1 |
| lambda$testConcurrentCommitTaskWithSubDir$12(TextOutputFormat[], int, TaskAttemptContext[]) |  | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
| testCommitterWithFailure() |  | 0% | | n/a | 1 | 1 | 12 | 12 | 1 | 1 |
| setup() |  | 0% | | n/a | 1 | 1 | 11 | 11 | 1 | 1 |
| setup(AbstractITCommitProtocol.JobData) |  | 0% | | n/a | 1 | 1 | 10 | 10 | 1 | 1 |
| getReaders(FileSystem, Path, Configuration) |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| assertJobAbortCleanedUp(AbstractITCommitProtocol.JobData) |  | 0% |  | 0% | 2 | 2 | 10 | 10 | 1 | 1 |
| writeTextOutput(TaskAttemptContext) |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
| commit(AbstractS3ACommitter, JobContext, TaskAttemptContext) |  | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
| abortJobQuietly(AbstractS3ACommitter, JobContext, TaskAttemptContext) |  | 0% | | n/a | 1 | 1 | 11 | 11 | 1 | 1 |
| getPart0000(Path) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| testAbortTaskThenJob() |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
| executeWork(String, AbstractITCommitProtocol.JobData, AbstractITCommitProtocol.ActionToTest) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| validateStorageClass(Path, String) |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
| testCommitterWithNoOutputs() |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
| static {...} |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
| testRequirePropagatedUUID() |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
| lambda$testAbortJobNotTask$11(Job, JobContext, TaskAttemptContext, AbstractS3ACommitter) |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
| lambda$testCommitLifecycle$3(LocatedFileStatus) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| newJob(Path, Configuration, String) |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
| lambda$testCommitJobButNotTask$8(Job, JobContext, TaskAttemptContext, AbstractS3ACommitter) |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
| checkForThreadLeakage() |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
| setupCommitter(AbstractS3ACommitter, TaskAttemptContext) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| AbstractITCommitProtocol() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| expectSimulatedFailureOnJobCommit(JobContext, AbstractS3ACommitter) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| assertPart0000DoesNotExist(Path) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| unsetUUIDOptions(Configuration) |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
| assertTaskAttemptPathDoesNotExist(AbstractS3ACommitter, TaskAttemptContext) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| assertJobAttemptPathDoesNotExist(AbstractS3ACommitter, JobContext) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| assertJobAttemptPathExists(AbstractS3ACommitter, JobContext) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| createConfiguration() |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| newJob() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| abortJobQuietly(AbstractITCommitProtocol.JobData) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| bindCommitter(Configuration) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| executeWork(String, AbstractITCommitProtocol.ActionToTest) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| cleanupDestDir() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| expectJobCommitFailure(JobContext, AbstractS3ACommitter, Class) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| expectFNFEonTaskCommit(AbstractS3ACommitter, TaskAttemptContext) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| getMethodName() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| abortInTeardown(AbstractITCommitProtocol.JobData) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| createCommitter(TaskAttemptContext) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| startJob(boolean) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| expectJobCommitToFail(JobContext, AbstractS3ACommitter) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| testCommitJobButNotTask() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| testAbortJobNotTask() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$expectFNFEonTaskCommit$5(AbstractS3ACommitter, TaskAttemptContext) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$expectJobCommitFailure$4(AbstractS3ACommitter, JobContext) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| dumpMultipartUploads() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| testAbortTaskNoWorkDone() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| testAbortJobNoWorkDone() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$testSelfGeneratedUUID$13(AbstractS3ACommitter, TaskAttemptContext) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$testAbortTaskThenJob$9(AbstractS3ACommitter) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$testAbortJobNoWorkDone$7(Job, JobContext, TaskAttemptContext, AbstractS3ACommitter) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$getPart0000$2(Path) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| commitTask(AbstractS3ACommitter, TaskAttemptContext) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| commitJob(AbstractS3ACommitter, JobContext) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$testRequirePropagatedUUID$14() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$assertPart0000DoesNotExist$10(Path) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$testAbortTaskNoWorkDone$6(Job, JobContext, TaskAttemptContext, AbstractS3ACommitter) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$testRecoveryAndCleanup$1(AbstractS3ACommitter, TaskAttemptContext) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$checkForThreadLeakage$0(String) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getOutDir() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getJobId() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getAttempt0() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getTaskAttempt0() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getAttempt1() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getTaskAttempt1() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| log() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getCommitterFactoryName() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| shouldExpectSuccessMarker() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| validateTaskAttemptPathDuringWrite(Path, long, String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| validateTaskAttemptPathAfterWrite(Path, long) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| validateTaskAttemptWorkingDirectory(AbstractS3ACommitter, TaskAttemptContext) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |