Skip to content

Conversation

@warrenzhu25
Copy link

@warrenzhu25 warrenzhu25 commented Jan 6, 2026

Which Delta project/connector is this regarding?

  • Spark
  • Standalone
  • Flink
  • Kernel
  • Other (fill in here)

Description

Add metrics for the vacuum command.

Refactors VacuumCommand to expose metrics for:

  • numFilesToDelete
  • sizeOfDataToDelete
  • numDeletedFiles
  • numVacuumedDirectories
  • status
image

Also adds a unit test to verify these metrics.

How was this patch tested?

Existing UTs.
Ignored flaky test "parallel file delete" in DeltaVacuumSuite.
New UT verify vacuum command metrics in DeltaVacuumSuite.

Does this PR introduce any user-facing changes?

No

#### Which Delta project/connector is this regarding?

- [x] Spark
- [ ] Standalone
- [ ] Flink
- [ ] Kernel
- [ ] Other (fill in here)

## Description
Add metrics for the vacuum command.

Refactors `VacuumCommand` to expose metrics for:
- numFilesToDelete
- sizeOfDataToDelete
- numDeletedFiles
- numVacuumedDirectories
- status

https: //screenshot.googleplex.com/5X3HgSXUEJ33F2L.png

## How was this patch tested?
Existing UTs.
Ignored flaky test "parallel file delete" in DeltaVacuumSuite.

## Does this PR introduce _any_ user-facing changes?
No

Change-Id: Icbf47d080ca52127d8058ebcd3f5efc6e462ef7b
#### Which Delta project/connector is this regarding?

- [x] Spark
- [ ] Standalone
- [ ] Flink
- [ ] Kernel
- [ ] Other (fill in here)

## Description
Adds a unit test to verify that vacuum command metrics are correctly reported.

## How was this patch tested?
New UT `verify vacuum command metrics` in `DeltaVacuumSuite`.

## Does this PR introduce _any_ user-facing changes?
No

Change-Id: I268885e4040c5388c3870fa20ba8490dbe60895b
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant