Browse Source

[livy] Handle the Error and NotStarted session states

Erick Tryzelaar 10 years ago
parent
commit
1df4c56

+ 1 - 0
apps/spark/java/livy-server/src/main/scala/com/cloudera/hue/livy/server/sessions/ThreadSession.scala

@@ -41,6 +41,7 @@ private class ThreadSession(val id: String, session: com.cloudera.hue.livy.repl.
       case repl.Session.Busy() => Busy()
       case repl.Session.ShuttingDown() => Dead()
       case repl.Session.ShutDown() => Dead()
+      case repl.Session.Error() => Error()
     }
   }
 

+ 4 - 0
apps/spark/java/livy-server/src/main/scala/com/cloudera/hue/livy/server/sessions/WebSession.scala

@@ -94,6 +94,10 @@ class WebSession(val id: String) extends Session with Logging {
 
             Unit
           }
+        case NotStarted() =>
+          Future {
+            waitForStateChangeFrom(NotStarted(), { stop() })
+          }
         case Starting() =>
           Future {
             waitForStateChangeFrom(Starting(), { stop() })