AbstractManifestCommitterTest

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,175 of 1,1750%28 of 280%81812732736767
executeOneTaskAttempt(int, int, int)1710%20%22262611
createFilesOrDirs(List, Path, String, ExecutorService, int, int, int, boolean)1090%60%44161611
createStageConfig(int, int, int, Path)760%20%22252511
createFilesOrDirs(Path, String, ExecutorService, int, int, int, boolean)740%20%229911
executeTaskAttempts(int, int)470%20%22101011
setup()370%n/a119911
asyncMkdirs(Collection)360%40%338811
teardown()340%n/a117711
assertCleanupResult(CleanupJobStage.Result, CleanupJobStage.Outcome, int)330%20%228811
readText(Path)330%n/a117711
verifyManifestTaskAttemptID(TaskManifest, String)300%n/a117711
enableManifestCommitter(Configuration)300%20%228811
AbstractManifestCommitterTest()280%n/a116611
cleanup(boolean, boolean, boolean, boolean, CleanupJobStage.Outcome, int)260%n/a115511
lsR(FileSystem, Path, boolean)250%20%228811
static {...}230%n/a117711
createTaskStageConfig(int, String, String)220%n/a116611
makeStoreOperationsUnreliable()220%20%227711
lambda$asyncPut$3(Path, byte[], CompletableFuture)170%n/a116611
asyncPut(Path, byte[])150%n/a113311
verifyManifestFilesMatch(TaskManifest, List)150%n/a117711
verifyPath(String, Path, Path)150%n/a114411
asyncMkdir(Path)140%n/a113311
verifyJobDirsCleanedUp()140%n/a114411
lambda$asyncMkdir$2(Path, CompletableFuture)140%n/a116611
lambda$subpaths$1(Path, int)140%n/a111111
lambda$createFilesOrDirs$0(boolean, Path, byte[])140%20%224411
lambda$executeTaskAttempts$5(List, int, Integer)130%n/a113311
createManifestStoreOperations()100%n/a112211
subpaths(Path, int)100%n/a113311
describe(String, Object[])90%n/a114411
toMap(List)80%n/a112211
verifySuccessMarker(Path, String)70%n/a111111
createStageConfigForJob(int, Path)70%n/a111111
dumpFileSystemIOStatistics()60%n/a113311
pathMustExist(String, Path)60%n/a112211
readFile(Path)60%n/a111111
withManifestDir(Path)50%n/a112211
createContract(Configuration)50%n/a111111
createConfiguration()50%n/a111111
lambda$lsR$7(LocatedFileStatus)50%n/a111111
getConfiguration()40%n/a111111
setStoreOperations(ManifestStoreOperations)40%n/a112211
getTotalDataSize()40%n/a111111
getTestPath()40%n/a111111
setSubmitter(CloseableTaskPoolSubmitter)40%n/a112211
getExecutorService()40%n/a111111
setStageStatistics(IOStatisticsStore)40%n/a112211
getReportDirUri()40%n/a111111
setJobStageConfig(StageConfig)40%n/a112211
setDestDir(Path)40%n/a112211
progressOf(StageConfig)40%n/a111111
getStoreOperations()30%n/a111111
getTaskAttemptIds()30%n/a111111
getTaskIds()30%n/a111111
getManifestDir()30%n/a111111
getSubmitter()30%n/a111111
getStageStatistics()30%n/a111111
getProgressCounter()30%n/a111111
getReportDir()30%n/a111111
threadLeakage()30%n/a112211
getJobStageConfig()30%n/a111111
getDestDir()30%n/a111111
getTestTimeoutMillis()20%n/a111111
getThreadLeakTracker()20%n/a111111
lambda$executeOneTaskAttempt$6(TaskManifest)20%n/a111111
lambda$toMap$4(TaskManifest)20%n/a111111