You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by va...@apache.org on 2019/03/01 19:25:21 UTC
[spark] branch master updated: [K8S][MINOR] Log minikube version
when running integration tests.
This is an automated email from the ASF dual-hosted git repository.
vanzin 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 9f16af6 [K8S][MINOR] Log minikube version when running integration tests.
9f16af6 is described below
commit 9f16af636661ec1f7af057764409fe359da0026a
Author: Marcelo Vanzin <va...@cloudera.com>
AuthorDate: Fri Mar 1 11:24:08 2019 -0800
[K8S][MINOR] Log minikube version when running integration tests.
Closes #23893 from vanzin/minikube-version.
Authored-by: Marcelo Vanzin <va...@cloudera.com>
Signed-off-by: Marcelo Vanzin <va...@cloudera.com>
---
.../spark/deploy/k8s/integrationtest/backend/minikube/Minikube.scala | 4 ++++
.../k8s/integrationtest/backend/minikube/MinikubeTestBackend.scala | 1 +
2 files changed, 5 insertions(+)
diff --git a/resource-managers/kubernetes/integration-tests/src/test/scala/org/apache/spark/deploy/k8s/integrationtest/backend/minikube/Minikube.scala b/resource-managers/kubernetes/integration-tests/src/test/scala/org/apache/spark/deploy/k8s/integrationtest/backend/minikube/Minikube.scala
index 8f406d8..78ef44b 100644
--- a/resource-managers/kubernetes/integration-tests/src/test/scala/org/apache/spark/deploy/k8s/integrationtest/backend/minikube/Minikube.scala
+++ b/resource-managers/kubernetes/integration-tests/src/test/scala/org/apache/spark/deploy/k8s/integrationtest/backend/minikube/Minikube.scala
@@ -34,6 +34,10 @@ private[spark] object Minikube extends Logging {
private val MINIKUBE_PREFIX = "minikube: "
private val MINIKUBE_PATH = ".minikube"
+ def logVersion(): Unit = {
+ logInfo(executeMinikube("version").mkString("\n"))
+ }
+
def getMinikubeIp: String = {
val outputs = executeMinikube("ip")
.filter(_.matches("^\\d{1,3}\\.\\d{1,3}\\.\\d{1,3}\\.\\d{1,3}$"))
diff --git a/resource-managers/kubernetes/integration-tests/src/test/scala/org/apache/spark/deploy/k8s/integrationtest/backend/minikube/MinikubeTestBackend.scala b/resource-managers/kubernetes/integration-tests/src/test/scala/org/apache/spark/deploy/k8s/integrationtest/backend/minikube/MinikubeTestBackend.scala
index cb93241..f92977d 100644
--- a/resource-managers/kubernetes/integration-tests/src/test/scala/org/apache/spark/deploy/k8s/integrationtest/backend/minikube/MinikubeTestBackend.scala
+++ b/resource-managers/kubernetes/integration-tests/src/test/scala/org/apache/spark/deploy/k8s/integrationtest/backend/minikube/MinikubeTestBackend.scala
@@ -25,6 +25,7 @@ private[spark] object MinikubeTestBackend extends IntegrationTestBackend {
private var defaultClient: DefaultKubernetesClient = _
override def initialize(): Unit = {
+ Minikube.logVersion()
val minikubeStatus = Minikube.getMinikubeStatus
require(minikubeStatus == MinikubeStatus.RUNNING,
s"Minikube must be running to use the Minikube backend for integration tests." +
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org