AbstractITCommitProtocol

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total2,929 of 2,9290%36 of 360%1101107347349292
testParallelJobsToSameDestination()3120%40%33717111
testMapFileOutputCommitter()1920%n/a11383811
testOutputFormatIntegration()1610%20%22434311
testParallelJobsToAdjacentPaths()1590%n/a11444411
testConcurrentCommitTaskWithSubDir()1380%60%44282811
testTwoTaskAttemptsCommit()1310%n/a11333311
testSelfGeneratedUUID()1180%n/a11292911
testRecoveryAndCleanup()1130%n/a11272711
testCommitLifecycle()860%n/a11242411
validateContent(Path, boolean, String)750%20%22141411
testFailAbort()660%n/a11171711
testCommitWithStorageClassConfig()650%n/a11191911
testS3ACommitterFactoryBinding()590%n/a11121211
startJob(AbstractITCommitProtocol.CommitterFactory, boolean)570%20%22131311
writeMapFileOutput(RecordWriter, TaskAttemptContext)500%40%339911
testCommitterWithDuplicatedCommit()500%60%44141411
testAMWorkflow()500%n/a11181811
validateMapFileOutputContent(FileSystem, Path)490%n/a11111111
teardown()480%40%33151511
writeOutput(RecordWriter, TaskAttemptContext)440%n/a11121211
lambda$testConcurrentCommitTaskWithSubDir$12(TextOutputFormat[], int, TaskAttemptContext[])440%n/a119911
testCommitterWithFailure()430%n/a11121211
setup()380%n/a11101011
setup(AbstractITCommitProtocol.JobData)360%n/a11101011
getReaders(FileSystem, Path, Configuration)340%20%226611
assertJobAbortCleanedUp(AbstractITCommitProtocol.JobData)330%20%22101011
writeTextOutput(TaskAttemptContext)310%n/a116611
commit(AbstractS3ACommitter, JobContext, TaskAttemptContext)290%n/a118811
abortJobQuietly(AbstractS3ACommitter, JobContext, TaskAttemptContext)280%n/a11111111
getPart0000(Path)270%20%225511
testAbortTaskThenJob()270%n/a117711
executeWork(String, AbstractITCommitProtocol.JobData, AbstractITCommitProtocol.ActionToTest)260%n/a114411
validateStorageClass(Path, String)250%n/a117711
testCommitterWithNoOutputs()250%n/a117711
static {...}240%n/a116611
testRequirePropagatedUUID()220%n/a116611
lambda$testAbortJobNotTask$11(Job, JobContext, TaskAttemptContext, AbstractS3ACommitter)210%n/a116611
newJob(Path, Configuration, String)190%n/a116611
lambda$testCommitLifecycle$3(LocatedFileStatus)190%n/a113311
lambda$testCommitJobButNotTask$8(Job, JobContext, TaskAttemptContext, AbstractS3ACommitter)180%n/a115511
checkForThreadLeakage()170%n/a117711
setupCommitter(AbstractS3ACommitter, TaskAttemptContext)170%n/a114411
AbstractITCommitProtocol()150%n/a113311
expectSimulatedFailureOnJobCommit(JobContext, AbstractS3ACommitter)150%n/a113311
assertPart0000DoesNotExist(Path)150%n/a113311
unsetUUIDOptions(Configuration)140%n/a115511
assertTaskAttemptPathDoesNotExist(AbstractS3ACommitter, TaskAttemptContext)120%n/a114411
assertJobAttemptPathDoesNotExist(AbstractS3ACommitter, JobContext)120%n/a114411
assertJobAttemptPathExists(AbstractS3ACommitter, JobContext)110%n/a114411
createConfiguration()100%n/a114411
newJob()90%n/a111111
abortJobQuietly(AbstractITCommitProtocol.JobData)90%n/a112211
bindCommitter(Configuration)80%n/a112211
executeWork(String, AbstractITCommitProtocol.ActionToTest)80%n/a112211
cleanupDestDir()70%n/a112211
expectJobCommitFailure(JobContext, AbstractS3ACommitter, Class)70%n/a111111
expectFNFEonTaskCommit(AbstractS3ACommitter, TaskAttemptContext)70%n/a112211
getMethodName()60%n/a111111
abortInTeardown(AbstractITCommitProtocol.JobData)60%n/a112211
createCommitter(TaskAttemptContext)60%n/a111111
startJob(boolean)60%n/a111111
expectJobCommitToFail(JobContext, AbstractS3ACommitter)60%n/a112211
testCommitJobButNotTask()60%n/a112211
testAbortJobNotTask()60%n/a112211
lambda$expectFNFEonTaskCommit$5(AbstractS3ACommitter, TaskAttemptContext)60%n/a112211
lambda$expectJobCommitFailure$4(AbstractS3ACommitter, JobContext)60%n/a112211
dumpMultipartUploads()50%n/a112211
testAbortTaskNoWorkDone()50%n/a112211
testAbortJobNoWorkDone()50%n/a112211
lambda$testSelfGeneratedUUID$13(AbstractS3ACommitter, TaskAttemptContext)50%n/a112211
lambda$testAbortTaskThenJob$9(AbstractS3ACommitter)50%n/a111111
lambda$testAbortJobNoWorkDone$7(Job, JobContext, TaskAttemptContext, AbstractS3ACommitter)50%n/a111111
lambda$getPart0000$2(Path)50%n/a111111
commitTask(AbstractS3ACommitter, TaskAttemptContext)40%n/a112211
commitJob(AbstractS3ACommitter, JobContext)40%n/a112211
lambda$testRequirePropagatedUUID$14()40%n/a111111
lambda$assertPart0000DoesNotExist$10(Path)40%n/a111111
lambda$testAbortTaskNoWorkDone$6(Job, JobContext, TaskAttemptContext, AbstractS3ACommitter)40%n/a111111
lambda$testRecoveryAndCleanup$1(AbstractS3ACommitter, TaskAttemptContext)40%n/a111111
lambda$checkForThreadLeakage$0(String)40%n/a111111
getOutDir()30%n/a111111
getJobId()30%n/a111111
getAttempt0()30%n/a111111
getTaskAttempt0()30%n/a111111
getAttempt1()30%n/a111111
getTaskAttempt1()30%n/a111111
log()0%n/a111111
getCommitterFactoryName()0%n/a111111
shouldExpectSuccessMarker()0%n/a111111
validateTaskAttemptPathDuringWrite(Path, long, String)0%n/a111111
validateTaskAttemptPathAfterWrite(Path, long)0%n/a111111
validateTaskAttemptWorkingDirectory(AbstractS3ACommitter, TaskAttemptContext)0%n/a111111