|
@@ -86,8 +86,10 @@ private class YarnSession(id: Int,
|
|
|
super.stop().andThen {
|
|
super.stop().andThen {
|
|
|
case _ =>
|
|
case _ =>
|
|
|
try {
|
|
try {
|
|
|
- val job_ = Await.result(job, Duration(1, TimeUnit.SECONDS))
|
|
|
|
|
- job_.waitForFinish(10000)
|
|
|
|
|
|
|
+ val job_ = Await.result(job, Duration(10, TimeUnit.SECONDS))
|
|
|
|
|
+ job_.waitForFinish(10000).getOrElse {
|
|
|
|
|
+ job_.stop()
|
|
|
|
|
+ }
|
|
|
} catch {
|
|
} catch {
|
|
|
case e: Throwable =>
|
|
case e: Throwable =>
|
|
|
_state = Error()
|
|
_state = Error()
|