dongjoon-hyun opened a new pull request, #835:
URL: https://github.com/apache/spark-kubernetes-operator/pull/835
### What changes were proposed in this pull request?
This PR aims to add `KueueWorkloadUtils`, the first part of the Kueue
runtime integration for `SparkApplication` and `SparkCluster` resources that
have the `kueue.x-k8s.io/queue-name` label.
- `requestAdmission` gets or creates a `Workload` and returns one of the
following results.
- `ADMITTED`: Kueue admitted the `Workload`.
- `PENDING`: The `Workload` is waiting for quota.
- `STALE`: The `Workload` cannot be used because it is being deleted,
belongs to another resource, or is pending with outdated pod sets. In the last
two cases, it is deleted without waiting so that it can be recreated.
- `releaseWorkload` deletes the `Workload` to release its quota. If the
deletion fails, it only logs a warning.
- `KueueWorkloadFactory.getWorkloadName` becomes package-private.
Nothing calls this class yet. Follow-up PRs will use it in `AppInitStep`,
`ClusterInitStep` and `AppCleanUpStep`.
### Why are the changes needed?
To support Kueue admission control for `SparkApplication` and `SparkCluster`
in smaller PRs.
### Does this PR introduce _any_ user-facing change?
No. Nothing calls the new class yet.
### How was this patch tested?
Pass the CIs with the newly added `KueueWorkloadUtilsTest`.
### Was this patch authored or co-authored using generative AI tooling?
Generated-by: Claude Opus 5
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
