Bläddra i källkod

HUE-2923 [livy] Allow multiple commands to queue up

Erick Tryzelaar 10 år sedan
förälder
incheckning
ecf9eeeb19

+ 1 - 5
apps/spark/java/livy-server/src/main/scala/com/cloudera/hue/livy/server/interactive/InteractiveWebSession.scala

@@ -70,7 +70,7 @@ abstract class InteractiveWebSession(val id: Int, createInteractiveRequest: Crea
   override def state: State = _state
 
   override def executeStatement(content: ExecuteRequest): Statement = {
-    ensureIdle {
+    ensureRunning {
       _state = Busy()
       touchLastActivity()
 
@@ -181,10 +181,6 @@ abstract class InteractiveWebSession(val id: Int, createInteractiveRequest: Crea
     }
   }
 
-  private def ensureIdle[A](f: => A) = {
-    ensureState(Idle(), f)
-  }
-
   private def ensureRunning[A](f: => A) = {
     synchronized {
       _state match {