File tree Expand file tree Collapse file tree 1 file changed +2
-1
lines changed
job-server/src/main/scala/spark/jobserver Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Original file line number Diff line number Diff line change @@ -134,6 +134,7 @@ class WebApi(system: ActorSystem,
134
134
.fold(100 * 1024 )(config.getBytes(_).toInt)
135
135
136
136
val contextTimeout = SparkJobUtils .getContextCreationTimeout(config)
137
+ val contextDeletionTimeout = SparkJobUtils .getContextDeletionTimeout(config)
137
138
val bindAddress = config.getString(" spark.jobserver.bind-address" )
138
139
139
140
val logger = LoggerFactory .getLogger(getClass)
@@ -390,7 +391,7 @@ class WebApi(system: ActorSystem,
390
391
// and currently running jobs will be lost. Use with care!
391
392
path(Segment ) { (contextName) =>
392
393
val (cName, _) = determineProxyUser(config, authInfo, contextName)
393
- val future = supervisor ? StopContext (cName)
394
+ val future = ( supervisor ? StopContext (cName))(contextDeletionTimeout.seconds )
394
395
respondWithMediaType(MediaTypes .`application/json`) { ctx =>
395
396
future.map {
396
397
case ContextStopped => ctx.complete(StatusCodes .OK , successMap(" Context stopped" ))
You can’t perform that action at this time.
0 commit comments