File tree Expand file tree Collapse file tree 3 files changed +5
-4
lines changed
job-server/src/spark.jobserver Expand file tree Collapse file tree 3 files changed +5
-4
lines changed Original file line number Diff line number Diff line change @@ -36,7 +36,7 @@ object JobServer {
36
36
println(" Could not find configuration file " + configFile)
37
37
sys.exit(1 )
38
38
}
39
- ConfigFactory .parseFile(configFile).withFallback(defaultConfig)
39
+ ConfigFactory .parseFile(configFile).withFallback(defaultConfig).resolve()
40
40
} else {
41
41
defaultConfig
42
42
}
Original file line number Diff line number Diff line change @@ -117,7 +117,7 @@ class WebApi(system: ActorSystem,
117
117
complete(StatusCodes .BadRequest , errMap(" context name must start with letters" ))
118
118
} else {
119
119
parameterMap { (params) =>
120
- val config = ConfigFactory .parseMap(params.asJava)
120
+ val config = ConfigFactory .parseMap(params.asJava).resolve()
121
121
val future = (supervisor ? AddContext (contextName, config))(contextTimeout.seconds)
122
122
respondWithMediaType(MediaTypes .`application/json`) { ctx =>
123
123
future.map {
@@ -290,7 +290,7 @@ class WebApi(system: ActorSystem,
290
290
try {
291
291
val async = ! syncOpt.getOrElse(false )
292
292
val postedJobConfig = ConfigFactory .parseString(configString)
293
- val jobConfig = postedJobConfig.withFallback(config)
293
+ val jobConfig = postedJobConfig.withFallback(config).resolve()
294
294
val contextConfig = Try (jobConfig.getConfig(" spark.context-settings" )).
295
295
getOrElse(ConfigFactory .empty)
296
296
val jobManager = getJobManagerForContext(contextOpt, contextConfig, classPath)
Original file line number Diff line number Diff line change 1
1
#Scala #akka @ApacheSpark
2
2
3
3
* Spark streaming context support !! (@zeitos )
4
- * Change ` server_start.sh ` to use ` spark-submit `
4
+ * Change ` server_start.sh ` to use ` spark-submit ` . This should fix some edge case bugs.
5
5
* Configurable driver memory (@acidghost )
6
+ * Be able to accept environment vars in job server config files, eg ` master = ${?MY_SPARK_HOST} `
You can’t perform that action at this time.
0 commit comments