This is an automated email from the ASF dual-hosted git repository.
dongjoon pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/master by this push:
new 9bede26 [MINOR][K8S][TESTS] Remove `verifyPriority` from
`VolcanoFeatureStepSuite`
9bede26 is described below
commit 9bede263a745a28cb6d8b17271c8b04415a9e2eb
Author: William Hyun <[email protected]>
AuthorDate: Sun Mar 13 00:52:40 2022 -0800
[MINOR][K8S][TESTS] Remove `verifyPriority` from `VolcanoFeatureStepSuite`
### What changes were proposed in this pull request?
This PR aims to remove `verifyPriority` from
`VolcanoFeatureStepSuite.scala`.
### Why are the changes needed?
This is unused.
### Does this PR introduce _any_ user-facing change?
No.
### How was this patch tested?
Pass the CIs.
Closes #35832 from williamhyun/remove-priority.
Authored-by: William Hyun <[email protected]>
Signed-off-by: Dongjoon Hyun <[email protected]>
---
.../spark/deploy/k8s/features/VolcanoFeatureStepSuite.scala | 10 ----------
1 file changed, 10 deletions(-)
diff --git
a/resource-managers/kubernetes/core/src/test/scala/org/apache/spark/deploy/k8s/features/VolcanoFeatureStepSuite.scala
b/resource-managers/kubernetes/core/src/test/scala/org/apache/spark/deploy/k8s/features/VolcanoFeatureStepSuite.scala
index 12daffc..d0d1f5e 100644
---
a/resource-managers/kubernetes/core/src/test/scala/org/apache/spark/deploy/k8s/features/VolcanoFeatureStepSuite.scala
+++
b/resource-managers/kubernetes/core/src/test/scala/org/apache/spark/deploy/k8s/features/VolcanoFeatureStepSuite.scala
@@ -66,14 +66,4 @@ class VolcanoFeatureStepSuite extends SparkFunSuite {
assert(podGroup.getSpec.getPriorityClassName == "driver-priority")
assert(podGroup.getSpec.getQueue == "driver-queue")
}
-
- private def verifyPriority(pod: SparkPod): Unit = {
- val sparkConf = new SparkConf()
- val kubernetesConf = KubernetesTestConf.createDriverConf(sparkConf)
- val step = new VolcanoFeatureStep()
- step.init(kubernetesConf)
- val sparkPod = step.configurePod(pod)
- val podGroup =
step.getAdditionalPreKubernetesResources().head.asInstanceOf[PodGroup]
- assert(podGroup.getSpec.getPriorityClassName ===
sparkPod.pod.getSpec.getPriorityClassName)
- }
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
