Skip to content
Merged
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Cleaned up docker image builder
  • Loading branch information
kimoonkim committed Dec 16, 2017
commit 567ad3eab6eeba500b1420b597fbe5cd564bb15f
Original file line number Diff line number Diff line change
Expand Up @@ -16,12 +16,9 @@
*/
package org.apache.spark.deploy.k8s.integrationtest.docker

import java.io.File
import java.net.URI
import java.nio.file.Paths

import scala.collection.JavaConverters._

import com.spotify.docker.client.{DefaultDockerClient, DockerCertificates, LoggingBuildHandler}
import org.apache.http.client.utils.URIBuilder
import org.scalatest.concurrent.{Eventually, PatienceConfiguration}
Expand All @@ -36,14 +33,7 @@ private[spark] class SparkDockerImageBuilder
// Dockerfile paths must be relative to the build path.
private val BASE_DOCKER_FILE = "dockerfiles/spark-base/Dockerfile"
private val DRIVER_DOCKER_FILE = "dockerfiles/driver/Dockerfile"
private val DRIVERPY_DOCKER_FILE = "dockerfiles/driver-py/Dockerfile"
private val DRIVERR_DOCKER_FILE = "dockerfiles/driver-r/Dockerfile"
private val EXECUTOR_DOCKER_FILE = "dockerfiles/executor/Dockerfile"
private val EXECUTORPY_DOCKER_FILE = "dockerfiles/executor-py/Dockerfile"
private val EXECUTORR_DOCKER_FILE = "dockerfiles/executor-r/Dockerfile"
private val SHUFFLE_SERVICE_DOCKER_FILE = "dockerfiles/shuffle-service/Dockerfile"
private val INIT_CONTAINER_DOCKER_FILE = "dockerfiles/init-container/Dockerfile"
private val STAGING_SERVER_DOCKER_FILE = "dockerfiles/resource-staging-server/Dockerfile"
private val STATIC_ASSET_SERVER_DOCKER_FILE =
"dockerfiles/integration-test-asset-server/Dockerfile"
private val TIMEOUT = PatienceConfiguration.Timeout(Span(2, Minutes))
Expand Down Expand Up @@ -73,14 +63,7 @@ private[spark] class SparkDockerImageBuilder
Eventually.eventually(TIMEOUT, INTERVAL) { dockerClient.ping() }
buildImage("spark-base", BASE_DOCKER_FILE)
buildImage("spark-driver", DRIVER_DOCKER_FILE)
buildImage("spark-driver-py", DRIVERPY_DOCKER_FILE)
buildImage("spark-driver-r", DRIVERR_DOCKER_FILE)
buildImage("spark-executor", EXECUTOR_DOCKER_FILE)
buildImage("spark-executor-py", EXECUTORPY_DOCKER_FILE)
buildImage("spark-executor-r", EXECUTORR_DOCKER_FILE)
buildImage("spark-shuffle", SHUFFLE_SERVICE_DOCKER_FILE)
buildImage("spark-resource-staging-server", STAGING_SERVER_DOCKER_FILE)
buildImage("spark-init", INIT_CONTAINER_DOCKER_FILE)
buildImage("spark-integration-test-asset-server", STATIC_ASSET_SERVER_DOCKER_FILE)
}

Expand Down