in spark-operator/src/main/java/org/apache/spark/k8s/operator/reconciler/SparkAppResourceSpecFactory.java [124:138]
private static Map<String, String> getOrCreateLocalFileForDriverSpec(
final SparkApplication app, final Map<String, String> confOverrides) {
if (overrideDriverTemplateEnabled(app.getSpec())) {
Optional<File> localFile =
getLocalFileFromPathKey(confOverrides, DRIVER_SPARK_TEMPLATE_FILE_PROP_KEY);
if (localFile.isEmpty() || !localFile.get().exists() || !localFile.get().isFile()) {
String filePath =
createLocalFileForPodTemplateSpec(
app.getSpec().getDriverSpec().getPodTemplateSpec(),
app.getMetadata().getUid() + "-driver-");
return Collections.singletonMap(DRIVER_SPARK_TEMPLATE_FILE_PROP_KEY, filePath);
}
}
return Collections.emptyMap();
}