Skip to content

Commit e36aa29

Browse files
authored
[Enhancement] Update vacuum metric when vacuum success (#62540)
Signed-off-by: sevev <qiangzh95@gmail.com>
1 parent 9798ba7 commit e36aa29

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

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

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,7 @@
3333
import com.starrocks.lake.LakeAggregator;
3434
import com.starrocks.lake.LakeTablet;
3535
import com.starrocks.lake.snapshot.ClusterSnapshotMgr;
36+
import com.starrocks.metric.MetricRepo;
3637
import com.starrocks.proto.TabletInfoPB;
3738
import com.starrocks.proto.VacuumRequest;
3839
import com.starrocks.proto.VacuumResponse;
@@ -329,6 +330,8 @@ private void vacuumPartitionImpl(Database db, OlapTable table, PhysicalPartition
329330
locker.unLockTablesWithIntensiveDbLock(db.getId(), Lists.newArrayList(table.getId()), LockType.WRITE);
330331
}
331332
}
333+
MetricRepo.COUNTER_VACUUM_FILES_NUMBER.increase(vacuumedFiles);
334+
MetricRepo.COUNTER_VACUUM_FILES_BYTES.increase(vacuumedFileSize);
332335
LOG.info("Vacuumed {}.{}.{} hasError={} vacuumedFiles={} vacuumedFileSize={} " +
333336
"visibleVersion={} minRetainVersion={} minActiveTxnId={} vacuumVersion={} extraFileSize={} cost={}ms",
334337
db.getFullName(), table.getName(), partition.getId(), hasError, vacuumedFiles, vacuumedFileSize,

0 commit comments

Comments
 (0)