SparkLoadJob

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total690 of 1,88263%76 of 14748%66109153413934
clearJob()1760%240%1313393911
submitPushTasks()11740977%113173%11222110401
unprotectedUpdateEtlStatusInternal(EtlStatus)791717%2250%23111701
tryCommitJob()626450%6225%45183001
readFields(DataInput)510%20%22121211
replayUpdateStateInfo(LoadJob.LoadJobStateUpdateInfo)450%30%33131311
onPendingTaskFinished(SparkPendingTaskAttachment)443846%2250%2361701
clearSparkLauncherLog()220%60%447711
unprotectedUpdateToLoadingState(EtlStatus, Map)185374%1375%1341601
unprotectedExecuteJob()143370%n/a0131101
setResourceInfo()123976%1375%1311101
updateLoadingStatus()107287%9950%91032101
afterAborted(TransactionState, boolean, String)80%n/a113311
cancelJobWithoutCheck(FailMsg, boolean, boolean)80%n/a113311
updateEtlStatus()76390%2675%2621601
afterVisible(TransactionState, boolean)70%n/a113311
cancelJob(FailMsg)60%n/a113311
getHandle()0%n/a111111
unprotectedPrepareLoadingInfos()7698%2466%2401301
SparkLoadJob(long, String, ResourceDesc, OriginStatement, UserIdentity)52100%n/a0101701
SparkLoadJob()45100%n/a0101601
getPushBrokerReaderParams(OlapTable, long)40100%1150%120701
addFinishedReplica(long, long, long)40100%3350%340901
beginTxn()27100%n/a010601
unprotectedLogUpdateStateInfo()27100%n/a010301
unprotectedProcessEtlFinish(EtlStatus, SparkEtlJobHandler)25100%2100%020701
checkState(JobState)16100%2100%020501
lambda$getPushBrokerReaderParams$0(List, Column)16100%n/a010401
executeEtl()15100%n/a010401
onTaskFinished(TaskAttachment)8100%1150%120301
setJobProperties(Map)6100%n/a010301
getResourceName()100%n/a010101
static {...}100%n/a010101
getEtlStartTimestamp()100%n/a010101