Github user skonto commented on a diff in the pull request:
https://github.com/apache/spark/pull/21652#discussion_r199610357
--- Diff:
resource-managers/kubernetes/integration-tests/src/test/scala/org/apache/spark/deploy/k8s/integrationtest/KubernetesSuite.scala
---
@@ -265,6 +323,37 @@ private[spark] class KubernetesSuite extends
SparkFunSuite
assert(envVars("ENV2") === "VALUE2")
}
+ private def executeCommand(cmd: String*)(implicit podName: String):
String = {
+ val out = new ByteArrayOutputStream()
+ val watch = kubernetesTestComponents
+ .kubernetesClient
+ .pods()
+ .withName(podName)
+ .readingInput(System.in)
+ .writingOutput(out)
+ .writingError(System.err)
+ .withTTY()
+ .exec(cmd.toArray: _*)
+ // wait to get some result back
+ Thread.sleep(1000)
--- End diff --
Ok will have a look. It does work because I guess its minikube and it is
fast, I didn't see any issues. But might be a problem don't know.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
