Skip to content

Commit 3881404

Browse files
mccheahash211
authored andcommitted
Remove some leftover code and fix a constant. (apache-spark-on-k8s#297)
* Remove some leftover code and fix a constant. * Fix build
1 parent fe03c7c commit 3881404

File tree

2 files changed

+9
-120
lines changed

2 files changed

+9
-120
lines changed

resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/kubernetes/constants.scala

Lines changed: 9 additions & 45 deletions
Original file line numberDiff line numberDiff line change
@@ -23,21 +23,7 @@ package object constants {
2323
private[spark] val SPARK_APP_NAME_LABEL = "spark-app-name"
2424
private[spark] val SPARK_EXECUTOR_ID_LABEL = "spark-exec-id"
2525

26-
// Secrets
27-
private[spark] val DRIVER_CONTAINER_SUBMISSION_SECRETS_BASE_DIR =
28-
"/var/run/secrets/spark-submission"
29-
private[spark] val SUBMISSION_APP_SECRET_NAME = "spark-submission-server-secret"
30-
private[spark] val SUBMISSION_APP_SECRET_PREFIX = "spark-submission-server-secret"
31-
private[spark] val SUBMISSION_APP_SECRET_VOLUME_NAME = "spark-submission-secret-volume"
32-
private[spark] val SUBMISSION_SSL_KEY_PASSWORD_SECRET_NAME =
33-
"spark-submission-server-key-password"
34-
private[spark] val SUBMISSION_SSL_KEYSTORE_PASSWORD_SECRET_NAME =
35-
"spark-submission-server-keystore-password"
36-
private[spark] val SUBMISSION_SSL_KEYSTORE_SECRET_NAME = "spark-submission-server-keystore"
37-
private[spark] val SUBMISSION_SSL_SECRETS_PREFIX = "spark-submission-server-ssl"
38-
private[spark] val SUBMISSION_SSL_SECRETS_VOLUME_NAME = "spark-submission-server-ssl-secrets"
39-
private[spark] val SUBMISSION_SSL_KEY_PEM_SECRET_NAME = "spark-submission-server-key-pem"
40-
private[spark] val SUBMISSION_SSL_CERT_PEM_SECRET_NAME = "spark-submission-server-cert-pem"
26+
// Credentials secrets
4127
private[spark] val DRIVER_CREDENTIALS_SECRETS_BASE_DIR =
4228
"/mnt/secrets/spark-kubernetes-credentials"
4329
private[spark] val DRIVER_CREDENTIALS_CA_CERT_SECRET_NAME = "ca-cert"
@@ -54,30 +40,15 @@ package object constants {
5440
s"$DRIVER_CREDENTIALS_SECRETS_BASE_DIR/$DRIVER_CREDENTIALS_OAUTH_TOKEN_SECRET_NAME"
5541
private[spark] val DRIVER_CREDENTIALS_SECRET_VOLUME_NAME = "kubernetes-credentials"
5642

57-
5843
// Default and fixed ports
5944
private[spark] val SUBMISSION_SERVER_PORT = 7077
6045
private[spark] val DEFAULT_DRIVER_PORT = 7078
6146
private[spark] val DEFAULT_BLOCKMANAGER_PORT = 7079
6247
private[spark] val DEFAULT_UI_PORT = 4040
63-
private[spark] val UI_PORT_NAME = "spark-ui-port"
64-
private[spark] val SUBMISSION_SERVER_PORT_NAME = "submit-server"
6548
private[spark] val BLOCK_MANAGER_PORT_NAME = "blockmanager"
66-
private[spark] val DRIVER_PORT_NAME = "driver"
6749
private[spark] val EXECUTOR_PORT_NAME = "executor"
6850

6951
// Environment Variables
70-
private[spark] val ENV_SUBMISSION_SECRET_LOCATION = "SPARK_SUBMISSION_SECRET_LOCATION"
71-
private[spark] val ENV_SUBMISSION_SERVER_PORT = "SPARK_SUBMISSION_SERVER_PORT"
72-
private[spark] val ENV_SUBMISSION_KEYSTORE_FILE = "SPARK_SUBMISSION_KEYSTORE_FILE"
73-
private[spark] val ENV_SUBMISSION_KEYSTORE_PASSWORD_FILE =
74-
"SPARK_SUBMISSION_KEYSTORE_PASSWORD_FILE"
75-
private[spark] val ENV_SUBMISSION_KEYSTORE_KEY_PASSWORD_FILE =
76-
"SPARK_SUBMISSION_KEYSTORE_KEY_PASSWORD_FILE"
77-
private[spark] val ENV_SUBMISSION_KEYSTORE_TYPE = "SPARK_SUBMISSION_KEYSTORE_TYPE"
78-
private[spark] val ENV_SUBMISSION_KEY_PEM_FILE = "SPARK_SUBMISSION_KEY_PEM_FILE"
79-
private[spark] val ENV_SUBMISSION_CERT_PEM_FILE = "SPARK_SUBMISSION_CERT_PEM_FILE"
80-
private[spark] val ENV_SUBMISSION_USE_SSL = "SPARK_SUBMISSION_USE_SSL"
8152
private[spark] val ENV_EXECUTOR_PORT = "SPARK_EXECUTOR_PORT"
8253
private[spark] val ENV_DRIVER_URL = "SPARK_DRIVER_URL"
8354
private[spark] val ENV_EXECUTOR_CORES = "SPARK_EXECUTOR_CORES"
@@ -87,27 +58,14 @@ package object constants {
8758
private[spark] val ENV_EXECUTOR_POD_IP = "SPARK_EXECUTOR_POD_IP"
8859
private[spark] val ENV_DRIVER_MEMORY = "SPARK_DRIVER_MEMORY"
8960
private[spark] val ENV_SUBMIT_EXTRA_CLASSPATH = "SPARK_SUBMIT_EXTRA_CLASSPATH"
90-
private[spark] val ENV_EXECUTOR_EXTRA_CLASSPATH = "SPARK_SUBMIT_EXTRA_CLASSPATH"
61+
private[spark] val ENV_EXECUTOR_EXTRA_CLASSPATH = "SPARK_EXECUTOR_EXTRA_CLASSPATH"
9162
private[spark] val ENV_MOUNTED_CLASSPATH = "SPARK_MOUNTED_CLASSPATH"
9263
private[spark] val ENV_DRIVER_MAIN_CLASS = "SPARK_DRIVER_CLASS"
9364
private[spark] val ENV_DRIVER_ARGS = "SPARK_DRIVER_ARGS"
9465
private[spark] val ENV_DRIVER_JAVA_OPTS = "SPARK_DRIVER_JAVA_OPTS"
9566
private[spark] val ENV_MOUNTED_FILES_DIR = "SPARK_MOUNTED_FILES_DIR"
9667

97-
// Annotation keys
98-
private[spark] val ANNOTATION_PROVIDE_EXTERNAL_URI =
99-
"spark-job.alpha.apache.org/provideExternalUri"
100-
private[spark] val ANNOTATION_RESOLVED_EXTERNAL_URI =
101-
"spark-job.alpha.apache.org/resolvedExternalUri"
102-
103-
// Miscellaneous
104-
private[spark] val DRIVER_CONTAINER_NAME = "spark-kubernetes-driver"
105-
private[spark] val DRIVER_SUBMIT_SSL_NAMESPACE = "kubernetes.driversubmitserver"
106-
private[spark] val KUBERNETES_MASTER_INTERNAL_URL = "https://kubernetes.default.svc"
107-
private[spark] val MEMORY_OVERHEAD_FACTOR = 0.10
108-
private[spark] val MEMORY_OVERHEAD_MIN = 384L
109-
110-
// V2 submission init container
68+
// Bootstrapping dependencies with the init-container
11169
private[spark] val INIT_CONTAINER_ANNOTATION = "pod.beta.kubernetes.io/init-containers"
11270
private[spark] val INIT_CONTAINER_SECRET_VOLUME_MOUNT_PATH =
11371
"/mnt/secrets/spark-init"
@@ -127,4 +85,10 @@ package object constants {
12785
s"$INIT_CONTAINER_PROPERTIES_FILE_DIR/$INIT_CONTAINER_PROPERTIES_FILE_NAME"
12886
private[spark] val DEFAULT_SHUFFLE_MOUNT_NAME = "shuffle"
12987
private[spark] val INIT_CONTAINER_SECRET_VOLUME_NAME = "spark-init-secret"
88+
89+
// Miscellaneous
90+
private[spark] val DRIVER_CONTAINER_NAME = "spark-kubernetes-driver"
91+
private[spark] val KUBERNETES_MASTER_INTERNAL_URL = "https://kubernetes.default.svc"
92+
private[spark] val MEMORY_OVERHEAD_FACTOR = 0.10
93+
private[spark] val MEMORY_OVERHEAD_MIN = 384L
13094
}

resource-managers/kubernetes/integration-tests/src/test/scala/org/apache/spark/deploy/kubernetes/integrationtest/ExternalUriProviderWatch.scala

Lines changed: 0 additions & 75 deletions
This file was deleted.

0 commit comments

Comments
 (0)