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 7b4fd90aa5fd [SPARK-46784][K8S][TESTS] Create and use a K8s test tag
for `PersistentVolume`
7b4fd90aa5fd is described below
commit 7b4fd90aa5fd8162076b80246f5faf3481b78d92
Author: Dongjoon Hyun <[email protected]>
AuthorDate: Sat Jan 20 01:58:39 2024 -0800
[SPARK-46784][K8S][TESTS] Create and use a K8s test tag for
`PersistentVolume`
### What changes were proposed in this pull request?
This PR aims to create and use a new K8s test tag, `pv`, for
`PersistentVolume` tests.
### Why are the changes needed?
To improve `PersistentVolume` tests
### Does this PR introduce _any_ user-facing change?
No.
### How was this patch tested?
Pass the CIs.
### Was this patch authored or co-authored using generative AI tooling?
No.
Closes #44810 from dongjoon-hyun/SPARK-46784.
Authored-by: Dongjoon Hyun <[email protected]>
Signed-off-by: Dongjoon Hyun <[email protected]>
---
.../apache/spark/deploy/k8s/integrationtest/KubernetesSuite.scala | 1 +
.../org/apache/spark/deploy/k8s/integrationtest/PVTestsSuite.scala | 6 +++---
2 files changed, 4 insertions(+), 3 deletions(-)
diff --git
a/resource-managers/kubernetes/integration-tests/src/test/scala/org/apache/spark/deploy/k8s/integrationtest/KubernetesSuite.scala
b/resource-managers/kubernetes/integration-tests/src/test/scala/org/apache/spark/deploy/k8s/integrationtest/KubernetesSuite.scala
index c3b6cc1d3893..2039b59b0ab5 100644
---
a/resource-managers/kubernetes/integration-tests/src/test/scala/org/apache/spark/deploy/k8s/integrationtest/KubernetesSuite.scala
+++
b/resource-managers/kubernetes/integration-tests/src/test/scala/org/apache/spark/deploy/k8s/integrationtest/KubernetesSuite.scala
@@ -642,6 +642,7 @@ class KubernetesSuite extends SparkFunSuite
private[spark] object KubernetesSuite {
val k8sTestTag = Tag("k8s")
val localTestTag = Tag("local")
+ val pvTestTag = Tag("pv")
val schedulingTestTag = Tag("schedule")
val decomTestTag = Tag("decom")
val rTestTag = Tag("r")
diff --git
a/resource-managers/kubernetes/integration-tests/src/test/scala/org/apache/spark/deploy/k8s/integrationtest/PVTestsSuite.scala
b/resource-managers/kubernetes/integration-tests/src/test/scala/org/apache/spark/deploy/k8s/integrationtest/PVTestsSuite.scala
index a6a9b4856202..127731bd6eb4 100644
---
a/resource-managers/kubernetes/integration-tests/src/test/scala/org/apache/spark/deploy/k8s/integrationtest/PVTestsSuite.scala
+++
b/resource-managers/kubernetes/integration-tests/src/test/scala/org/apache/spark/deploy/k8s/integrationtest/PVTestsSuite.scala
@@ -135,7 +135,7 @@ private[spark] trait PVTestsSuite { k8sSuite:
KubernetesSuite =>
}
}
- test("PVs with local hostpath storage on statefulsets", k8sTestTag,
MinikubeTag) {
+ test("PVs with local hostpath storage on statefulsets", k8sTestTag,
pvTestTag) {
assume(this.getClass.getSimpleName == "KubernetesSuite")
sparkAppConf
.set(s"spark.kubernetes.driver.volumes.persistentVolumeClaim.data.mount.path",
@@ -167,7 +167,7 @@ private[spark] trait PVTestsSuite { k8sSuite:
KubernetesSuite =>
}
}
- test("PVs with local hostpath and storageClass on statefulsets", k8sTestTag,
MinikubeTag) {
+ test("PVs with local hostpath and storageClass on statefulsets", k8sTestTag,
pvTestTag) {
assume(this.getClass.getSimpleName == "KubernetesSuite")
sparkAppConf
.set(s"spark.kubernetes.driver.volumes.persistentVolumeClaim.data.mount.path",
@@ -202,7 +202,7 @@ private[spark] trait PVTestsSuite { k8sSuite:
KubernetesSuite =>
}
}
- test("PVs with local storage", k8sTestTag, MinikubeTag) {
+ test("PVs with local storage", k8sTestTag, pvTestTag) {
assume(this.getClass.getSimpleName == "KubernetesSuite")
sparkAppConf
.set(s"spark.kubernetes.driver.volumes.persistentVolumeClaim.data.mount.path",
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
