Skip to content

Commit

Permalink
Nits
Browse files Browse the repository at this point in the history
Signed-off-by: Aliaksandr Sasnouskikh <[email protected]>
  • Loading branch information
jahstreet committed Dec 5, 2019
1 parent b54eee9 commit e3740ae
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -399,8 +399,8 @@ class InteractiveSession(
app = mockApp.orElse {
val driverProcess = client.flatMap { c => Option(c.getDriverProcess) }
.map(new LineBufferedProcess(_, livyConf.getInt(LivyConf.SPARK_LOGS_SIZE)))
driverProcess.map(_ => SparkApp.create(appTag, appId, driverProcess, livyConf, Some(this)))
.orElse {
driverProcess.map(
_ => SparkApp.create(appTag, appId, driverProcess, livyConf, Some(this))).orElse {
if (livyConf.isRunningOnKubernetes()) {
// Create SparkKubernetesApp anyway to recover app monitoring on Livy server restart
Some(SparkApp.create(appTag, appId, driverProcess, livyConf, Some(this)))
Expand Down

0 comments on commit e3740ae

Please sign in to comment.