MTMVTask

A different version of class was executed at runtime.

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total3,968 of 3,9680%459 of 4590%3153159219218282
getTvfInfo(String)2870%220%1212474711
executePartitionBasedRefresh(MTMVRefreshContext, RefreshMTMVInfo.RefreshMode, ConnectContext, List)2560%280%1515616111
executeIvmAttempt(MTMVRefreshContext, MTMVTask.RefreshRequest, ConnectContext, List)2460%240%1313616111
buildAttempts(MTMVTask.RefreshRequest, boolean)2300%490%2727474711
run()2230%220%1313606011
static {...}2100%20%22383811
hasUnusableIvmStreamForPartitions(MTMVRefreshContext, List)1340%220%1212323211
refreshPartitions(Set, Map, Optional, RefreshMTMVInfo.RefreshMode)1190%100%66272711
syncPartitionsIfNeeded(ConnectContext, List)1050%140%88262611
executeSingleIvmAttempt(MTMVRefreshContext, Set)1050%60%44292911
executeWithRetry(Callable, String)1030%160%99262611
adoptPartitionsCreatedByTheRetry(Set)1020%120%77171711
executePartitionBasedRefresh(MTMVRefreshContext, MTMVTask.RefreshRequest, ConnectContext)950%120%77232311
recordIvmRefreshMetrics()900%140%99212111
planPartitionRefresh(MTMVRefreshContext, MTMVTask.RefreshRequest)680%80%55191911
collectPctResetPartitionIds(MTMVRefreshContext, Set)680%80%55131311
getProgress()630%40%33121211
resolveRefreshRequest()590%60%44101011
reconcileIvmStreams(ConnectContext)590%60%44151511
handleIvmFallbackResult(IvmIncrRefreshResult, MTMVTask.RefreshRequest)570%40%33161611
hasUnusableIvmStream()510%100%66151511
MTMVTask(long, long, MTMVTaskContext)500%n/a11141411
getRefreshAuditStmt(RefreshMTMVInfo.RefreshMode, Set)470%40%339911
beforeMTMVRefresh()470%60%44111111
after()470%80%55111111
MTMVTask(MTMV, MTMVRelation, MTMVTaskContext)400%n/a11141411
executeCompleteAttempt(MTMVRefreshContext, ConnectContext)400%40%33111111
runTask()400%60%44121211
excludingRebuiltPartitions(List)390%80%559911
lambda$executeSingleIvmAttempt$0(Set, IvmIncrRefreshManager)370%n/a117711
closeOrReleaseResources()360%100%66111111
onSuccess()340%60%44111111
getIncrementalTableMap()340%40%338811
executeCancelLogic(boolean)320%40%33101011
MTMVTask()310%n/a11111111
setupComputeGroup(ConnectContext)310%20%22111111
commitCapturedEpochs(Map)300%20%225511
before()290%20%229911
holdCapturedEpochs(Map, Map)270%20%226611
recordRebuiltPartitions(MTMVTask.RefreshRequest)260%60%445511
shouldUseCompleteForInitialIvmRefresh(boolean)260%100%664411
onRejected()250%40%338811
needRetry(Exception)230%80%557711
checkNoRowTtlBaseTable()220%20%227711
plannedCeiling(Map.Entry)220%20%222211
usableIvmStream(Database, OlapTable)220%40%336611
onFail()220%40%338811
lambda$createRefreshConsumer$4(AtomicReference, StmtExecutor)220%60%447711
redeemHeldRecords()210%20%227711
isSkipPartitionSyncDebugPointEnabled()190%40%333311
applyComputeGroup(ConnectContext)190%20%225511
registerExecutor(StmtExecutor)180%40%335511
ensureQueryUsableIfNeeded(ConnectContext, List)170%20%225511
recordCapturedPartitionId(String)160%20%224411
generateRefreshMode(List)160%40%335511
toString()160%n/a112211
resolveIvmBaseTable(BaseTableInfo)150%n/a114411
closeExecutionContext(ConnectContext)150%40%336611
recordRefreshScope(Collection)140%20%224411
recordRefreshCompleted(Collection)140%20%224411
raiseRequirementForRefreshScope(Collection)140%20%224411
givingUpTheIncrementalAttemptIsAFallback()130%40%331111
buildRefreshContext(List)130%n/a113311
recordCommitted(IvmRefreshMethod)120%20%224411
refreshPartitionsWithRetry(Set, Map, Optional, RefreshMTMVInfo.RefreshMode)120%n/a111111
cancel(boolean)120%20%223311
captureLatestEpochs(Set)100%20%223311
getIvmCapturedEpochs()90%20%221111
hasRecordsHeldForTheDelta()80%20%221111
checkComputeGroupBeforeTask(ConnectContext, Optional)80%n/a113311
recordQueryId(String)70%20%223311
lambda$refreshPartitionsWithRetry$2(Set, Map, Optional, RefreshMTMVInfo.RefreshMode)70%n/a111111
lambda$createRefreshConsumer$3(AtomicReference, IvmRewriteResult)50%n/a111111
createRefreshConsumer(AtomicReference)40%n/a111111
getTaskContext()30%n/a111111
getMtmvSchemaChangeVersion()30%n/a111111
getRefreshedIvmPlanSignature()30%n/a111111
getIvmRefreshMethod()30%n/a111111
getIvmFailureReason()30%n/a111111
isIvmFallback()30%n/a111111
getIvmFallbackReason()30%n/a111111
lambda$collectPctResetPartitionIds$1(BaseTableInfo)0%n/a111111