Bladeren bron

[livy] Fix spark sessions

Erick Tryzelaar 10 jaren geleden
bovenliggende
commit
10a13e8

+ 1 - 1
apps/spark/java/livy-repl/src/main/scala/com/cloudera/hue/livy/repl/Main.scala

@@ -27,7 +27,7 @@ object Main extends Logging {
     val session_kind = args(0)
 
     session_kind match {
-      case PYTHON_SESSION | PYSPARK_SESSION | SPARK_SESSION =>
+      case PYTHON_SESSION | PYSPARK_SESSION | SCALA_SESSION | SPARK_SESSION =>
       case _ =>
         println("Unknown session kind: " + session_kind)
         sys.exit(1)

+ 1 - 1
apps/spark/java/livy-repl/src/main/scala/com/cloudera/hue/livy/repl/scala/SparkSession.scala

@@ -60,7 +60,7 @@ private class SparkSession extends Session {
         parse(write(Map(
           "status" -> "ok",
           "execution_count" -> x,
-          "payload" -> Map(
+          "data" -> Map(
             "text/plain" -> rep.output
           )
         )))