Browse Source

[livy] Log the spark-submit commands

Erick Tryzelaar 10 years ago
parent
commit
2e30b4f262

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

@@ -47,6 +47,8 @@ object ProcessSession extends Logging {
     args += livyJar(livyConf)
     args += kind.toString
 
+    debug("Running %s", args.mkString(" "))
+
     val pb = new ProcessBuilder(args)
 
     livyConf.getOption(CONF_LIVY_REPL_CALLBACK_URL).foreach { case callbackUrl =>

+ 2 - 0
apps/spark/java/livy-yarn/src/main/scala/com/cloudera/hue/livy/yarn/Client.scala

@@ -60,6 +60,8 @@ class Client(livyConf: LivyConf) extends Logging {
     args += livyJar(livyConf)
     args += kind
 
+    debug("Running %s", args.mkString(" "))
+
     val builder: ProcessBuilder = new ProcessBuilder(args)
 
     builder.redirectOutput(Redirect.PIPE)