RoutineLoadManager

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,141 of 2,24249%146 of 20930%1101702374952165
getAvailableBeForTask(long, long)1950%300%1616404011
getAvailableBackendIds(long)1040%120%77232311
getMinTaskBeId(String)1030%120%77222211
checkPrivAndGetAllJobs(String)700%120%77171711
cleanOverLimitRoutineLoadJobs()60811%8220%56202301
getBeCurrentTasksNumMap()531825%5116%3471101
checkPrivAndGetJob(String, String)525852%4450%3581901
getTagsFromReplicaAllocation(long, long)510%20%22111111
sortRoutineLoadJob(List)451322%12214%78101501
isInBlacklist(long)380%40%338811
getJobByName(String)360%40%338811
addRoutineLoadJob(RoutineLoadJob, String, String)315061%2250%2321201
getJob(String, String, boolean, PatternMatcher)289877%51372%51072801
isNameUsed(Long, String)27720%3125%237901
alterRoutineLoadJob(AlterRoutineLoadCommand)222250%3125%2331001
getSizeOfIdToRoutineLoadTask()220%20%225511
getRoutineLoadJobByMultiLoadTaskTxnId(long)210%20%224411
createRoutineLoadJob(CreateRoutineLoadInfo, ConnectContext)188181%2360%2432101
pauseRoutineLoadJob(PauseRoutineLoadCommand)187380%3350%2452101
resumeRoutineLoadJob(ResumeRoutineLoadCommand)186578%3350%2452301
replayChangeRoutineLoadJob(RoutineLoadOperation)183163%n/a0151301
checkTaskInJob(RoutineLoadTaskInfo)170%20%224411
getClusterIdleSlotNum()153871%1375%1311001
addMultiLoadTaskTxnIdToRoutineLoadJobId(long, long)90%n/a112211
addToBlacklist(long)90%n/a112211
getTotalMaxConcurrentTaskNum()80%n/a111111
lambda$isNameUsed$7(RoutineLoadJob)80%20%221111
readFields(DataInput)76890%4660%4621801
getAllRoutineLoadJobs()70%n/a111111
lambda$getJob$9(PatternMatcher, RoutineLoadJob)50%n/a111111
lambda$isNameUsed$6(String, RoutineLoadJob)50%n/a111111
getAvailableBackendIdsForUt(long)40%n/a111111
cleanOldRoutineLoadJobs()3770%1150%121401
getBlacklist()30%n/a111111
lambda$cleanOverLimitRoutineLoadJobs$11(RoutineLoadJob)30%n/a111111
lambda$getTotalMaxConcurrentTaskNum$3(Integer)30%n/a111111
getJob(String, String)21588%1150%121401
lambda$getActiveRoutineLoadJobs$0(RoutineLoadJob)2675%1150%120101
lambda$getJob$8(RoutineLoadJob)787%1150%120101
clearRoutineLoadJobIf(Predicate)66100%4100%0301901
unprotectedRemoveJobFromDb(RoutineLoadJob)55100%2250%230601
stopRoutineLoadJob(StopRoutineLoadCommand)52100%n/a0101201
unprotectedAddJob(RoutineLoadJob)34100%n/a010801
RoutineLoadManager()28100%n/a010801
replayRemoveOldRoutineLoad(RoutineLoadOperation)24100%1150%120701
write(DataOutput)22100%2100%020501
updateRoutineLoadJob()20100%4100%030501
replayCreateRoutineLoadJob(RoutineLoadJob)17100%n/a010501
processTimeoutTasks()16100%2100%020401
replayAlterRoutineLoadJob(AlterRoutineLoadJobOperationLog)15100%n/a010401
getRoutineLoadJobByState(Set)13100%n/a010301
updateBeIdToMaxConcurrentTasks()12100%n/a010301
getActiveRoutineLoadJobs()10100%n/a010301
removeMultiLoadTaskTxnIdToRoutineLoadJobId(long)7100%n/a010201
getJob(long)7100%n/a010101
readLock()5100%n/a010201
readUnlock()5100%n/a010201
writeLock()5100%n/a010201
writeUnlock()5100%n/a010201
lambda$getRoutineLoadJobByState$10(Set, RoutineLoadJob)5100%n/a010101
static {...}4100%n/a010101
lambda$updateBeIdToMaxConcurrentTasks$2(Long)3100%n/a010101
lambda$unprotectedAddJob$5(String)2100%n/a010101
lambda$unprotectedAddJob$4(Long)2100%n/a010101
lambda$updateBeIdToMaxConcurrentTasks$1(Long)2100%n/a010101