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 |
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 |
validateMapFileOutputContent(FileSystem, Path) |  | 0% | | n/a | 1 | 1 | 11 | 11 | 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 | 10 | 10 | 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 |
newJob(Path, Configuration, String) |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
lambda$testCommitLifecycle$3(LocatedFileStatus) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 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 |