tool
/
starrocks
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[Enhancement] Update vacuum metric when vacuum success (backport #62540) (#63099) 

Signed-off-by: sevev <qiangzh95@gmail.com>
Co-authored-by: zhangqiang <qiangzh95@gmail.com>
This commit is contained in:
mergify[bot] 2025-09-16 09:56:32 +08:00 committed by GitHub
parent 5670387325
commit 53754c69a8
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
fe/fe-core/src/main/java/com/starrocks/lake/vacuum/AutovacuumDaemon.java
View File

@ -33,6 +33,7 @@ import com.starrocks.common.util.concurrent.lock.Locker;
import com.starrocks.lake.LakeAggregator;
import com.starrocks.lake.LakeTablet;
import com.starrocks.lake.snapshot.ClusterSnapshotMgr;
import com.starrocks.metric.MetricRepo;
import com.starrocks.proto.TabletInfoPB;
import com.starrocks.proto.VacuumRequest;
import com.starrocks.proto.VacuumResponse;
@ -329,6 +330,8 @@ public class AutovacuumDaemon extends FrontendDaemon {
locker.unLockTablesWithIntensiveDbLock(db.getId(), Lists.newArrayList(table.getId()), LockType.WRITE);
}
}
MetricRepo.COUNTER_VACUUM_FILES_NUMBER.increase(vacuumedFiles);
MetricRepo.COUNTER_VACUUM_FILES_BYTES.increase(vacuumedFileSize);
LOG.info("Vacuumed {}.{}.{} hasError={} vacuumedFiles={} vacuumedFileSize={} " +
"visibleVersion={} minRetainVersion={} minActiveTxnId={} vacuumVersion={} extraFileSize={} cost={}ms",
db.getFullName(), table.getName(), partition.getId(), hasError, vacuumedFiles, vacuumedFileSize,