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