MTMVTask

A different version of class was executed at runtime.

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total3,164 of 3,1640%383 of 3830%2542547547546060
getTvfInfo(String)2640%200%1111444411
executePartitionBasedRefresh(MTMVRefreshContext, RefreshMTMVInfo.RefreshMode, ConnectContext)2180%240%1313515111
run()1920%220%1313515111
static {...}1700%20%22292911
buildAttempts(MTMVTask.RefreshRequest, boolean)1560%330%1919343411
handlePendingIvmBaselineRebuild(MTMVRefreshContext, MTMVTask.RefreshRequest, ConnectContext, List)1420%200%1111383811
hasUnusableIvmStreamForPartitions(MTMVRefreshContext, List)1340%220%1212323211
executeIvmAttempt(MTMVRefreshContext, MTMVTask.RefreshRequest, ConnectContext, List)1150%140%88292911
refreshPartitions(Set, Map, Optional, RefreshMTMVInfo.RefreshMode)1130%80%55252511
syncPartitionsIfNeeded(ConnectContext, List)1050%140%88262611
executeWithRetry(Callable, String)1030%160%99262611
executeSingleIvmAttempt(MTMVRefreshContext)950%40%33262611
executePartitionBasedRefresh(MTMVRefreshContext, MTMVTask.RefreshRequest, ConnectContext)920%120%77232311
collectPctResetPartitionIds(MTMVRefreshContext, Set)680%80%55131311
handleIvmFallbackResult(IvmIncrRefreshResult, MTMVTask.RefreshRequest)660%60%44191911
validateIvmBaselineBeforePartitionSync(MTMVTask.RefreshRequest)640%180%1010141411
getProgress()630%40%33121211
resolveRefreshRequest()590%60%44101011
reconcileIvmStreams(ConnectContext)590%60%44151511
planPartitionRefresh(MTMVRefreshContext, MTMVTask.RefreshRequest)510%60%44161611
hasUnusableIvmStream()510%100%66151511
getRefreshAuditStmt(RefreshMTMVInfo.RefreshMode, Set)470%40%339911
beforeMTMVRefresh()470%60%44111111
runTask()400%60%44121211
lambda$executeSingleIvmAttempt$0(IvmIncrRefreshManager)380%n/a117711
closeOrReleaseResources()360%100%66111111
onSuccess()340%60%44111111
getIncrementalTableMap()340%40%338811
executeCompleteAttempt(MTMVRefreshContext, ConnectContext)330%40%339911
setupComputeGroup(ConnectContext)330%40%33121211
executeCancelLogic(boolean)320%40%33101011
before()290%20%229911
shouldUseCompleteForInitialIvmRefresh(boolean)260%100%664411
MTMVTask(long, long, MTMVTaskContext)250%n/a116611
needRetry(Exception)230%80%557711
usableIvmStream(Database, OlapTable)220%40%336611
onFail()220%40%338811
lambda$createRefreshConsumer$4(AtomicReference, StmtExecutor)220%60%447711
after()200%20%224411
isSkipPartitionSyncDebugPointEnabled()190%40%333311
registerExecutor(StmtExecutor)180%40%335511
ensureQueryUsableIfNeeded(ConnectContext, List)160%20%225511
generateRefreshMode(List)160%40%335511
toString()160%n/a112211
MTMVTask(MTMV, MTMVRelation, MTMVTaskContext)150%n/a116611
resolveIvmBaseTable(BaseTableInfo)150%n/a114411
closeExecutionContext(ConnectContext)150%40%336611
writeIvmBaselineBarrier(RefreshMTMVInfo.RefreshMode)140%20%223311
buildRefreshContext(List)130%n/a113311
refreshPartitionsWithRetry(Set, Map, Optional, RefreshMTMVInfo.RefreshMode)120%n/a111111
cancel(boolean)120%20%223311
recordQueryId(String)70%20%223311
lambda$refreshPartitionsWithRetry$2(Set, Map, Optional, RefreshMTMVInfo.RefreshMode)70%n/a111111
MTMVTask()60%n/a113311
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
lambda$collectPctResetPartitionIds$1(BaseTableInfo)0%n/a111111