|
16 | 16 | */
|
17 | 17 | package org.apache.spark.deploy.kubernetes.integrationtest
|
18 | 18 |
|
| 19 | +import java.io.File |
19 | 20 | import java.nio.file.Paths
|
20 | 21 | import java.util.UUID
|
21 | 22 |
|
| 23 | +import com.google.common.base.Charsets |
| 24 | +import com.google.common.io.Files |
22 | 25 | import io.fabric8.kubernetes.client.internal.readiness.Readiness
|
23 |
| -import org.apache.spark.{SSLOptions, SparkConf, SparkFunSuite} |
| 26 | +import org.scalatest.BeforeAndAfter |
| 27 | +import org.scalatest.concurrent.{Eventually, PatienceConfiguration} |
| 28 | +import org.scalatest.time.{Minutes, Seconds, Span} |
| 29 | +import scala.collection.JavaConverters._ |
| 30 | + |
| 31 | +import org.apache.spark.{SparkConf, SparkFunSuite, SSLOptions} |
| 32 | +import org.apache.spark.deploy.kubernetes.SSLUtils |
24 | 33 | import org.apache.spark.deploy.kubernetes.config._
|
25 | 34 | import org.apache.spark.deploy.kubernetes.integrationtest.backend.IntegrationTestBackendFactory
|
26 | 35 | import org.apache.spark.deploy.kubernetes.integrationtest.backend.minikube.Minikube
|
27 | 36 | import org.apache.spark.deploy.kubernetes.integrationtest.constants.MINIKUBE_TEST_BACKEND
|
28 | 37 | import org.apache.spark.deploy.kubernetes.integrationtest.kerberos.KerberosDriverWatcherCache
|
29 |
| -import org.apache.spark.deploy.kubernetes.submit._ |
30 |
| -import org.scalatest.BeforeAndAfter |
31 |
| -import org.scalatest.concurrent.{Eventually, PatienceConfiguration} |
32 |
| -import org.scalatest.time.{Minutes, Seconds, Span} |
33 |
| - |
34 |
| -import scala.collection.JavaConverters._ |
| 38 | +import org.apache.spark.deploy.kubernetes.submit.{Client, ClientArguments, JavaMainAppResource, KeyAndCertPem, MainAppResource, PythonMainAppResource} |
| 39 | +import org.apache.spark.launcher.SparkLauncher |
| 40 | +import org.apache.spark.util.Utils |
35 | 41 |
|
36 | 42 | private[spark] class KubernetesSuite extends SparkFunSuite with BeforeAndAfter {
|
37 | 43 | import KubernetesSuite._
|
|
0 commit comments