Skip to content

Commit c0a50c4

Browse files
committed
Revert "Remove redundant java options."
This reverts commit e8d79f3.
1 parent f4f3743 commit c0a50c4

File tree

1 file changed

+30
-13
lines changed

1 file changed

+30
-13
lines changed

rust/crd/src/lib.rs

Lines changed: 30 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -538,6 +538,29 @@ impl SparkApplication {
538538
}
539539
}
540540

541+
// Extra JVM opts:
542+
// - java security properties
543+
// - s3 with TLS
544+
let mut extra_java_opts = vec![format!(
545+
"-Djava.security.properties={VOLUME_MOUNT_PATH_LOG_CONFIG}/{JVM_SECURITY_PROPERTIES_FILE}"
546+
)];
547+
if tlscerts::tls_secret_names(s3conn, s3_log_dir).is_some() {
548+
extra_java_opts.extend(
549+
vec![
550+
format!("-Djavax.net.ssl.trustStore={STACKABLE_TRUST_STORE}/truststore.p12"),
551+
format!("-Djavax.net.ssl.trustStorePassword={STACKABLE_TLS_STORE_PASSWORD}"),
552+
format!("-Djavax.net.ssl.trustStoreType=pkcs12"),
553+
format!("-Djavax.net.debug=ssl,handshake"),
554+
]
555+
.into_iter(),
556+
);
557+
}
558+
let str_extra_java_opts = extra_java_opts.join(" ");
559+
submit_cmd.extend(vec![
560+
format!("--conf spark.driver.extraJavaOptions=\"{str_extra_java_opts}\""),
561+
format!("--conf spark.executor.extraJavaOptions=\"{str_extra_java_opts}\""),
562+
]);
563+
541564
// repositories and packages arguments
542565
if let Some(deps) = self.spec.deps.clone() {
543566
submit_cmd.extend(
@@ -636,23 +659,17 @@ impl SparkApplication {
636659
value_from: None,
637660
});
638661
}
639-
640-
// Extra JVM opts:
641-
// - java security properties
642-
// - s3 with TLS
643-
let mut daemon_java_opts = vec![format!(
644-
"-Djava.security.properties={VOLUME_MOUNT_PATH_LOG_CONFIG}/{JVM_SECURITY_PROPERTIES_FILE}"
645-
)];
646662
if let Some(s3logdir) = s3logdir {
647663
if tlscerts::tls_secret_name(&s3logdir.bucket.connection).is_some() {
648-
daemon_java_opts.push( format!("-Djavax.net.ssl.trustStore={STACKABLE_TRUST_STORE}/truststore.p12 -Djavax.net.ssl.trustStorePassword={STACKABLE_TLS_STORE_PASSWORD} -Djavax.net.ssl.trustStoreType=pkcs12"));
664+
e.push(EnvVar {
665+
name: "SPARK_DAEMON_JAVA_OPTS".to_string(),
666+
value: Some(format!(
667+
"-Djavax.net.ssl.trustStore={STACKABLE_TRUST_STORE}/truststore.p12 -Djavax.net.ssl.trustStorePassword={STACKABLE_TLS_STORE_PASSWORD} -Djavax.net.ssl.trustStoreType=pkcs12"
668+
)),
669+
value_from: None,
670+
});
649671
}
650672
}
651-
e.push(EnvVar {
652-
name: "SPARK_DAEMON_JAVA_OPTS".to_string(),
653-
value: Some(daemon_java_opts.join(" ")),
654-
value_from: None,
655-
});
656673

657674
e
658675
}

0 commit comments

Comments
 (0)