@@ -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}
0 commit comments