Răsfoiți Sursa

[livy] Capture batch stderr in local mode

Erick Tryzelaar 10 ani în urmă
părinte
comite
05a6252

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

@@ -51,6 +51,7 @@ object BatchSessionProcess {
     createBatchRequest.proxyUser.foreach(builder.proxyUser)
 
     builder.redirectOutput(Redirect.PIPE)
+    builder.redirectErrorStream(true)
 
     builder
   }

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

@@ -66,7 +66,7 @@ object InteractiveSessionProcess extends Logging {
     builder.env("LIVY_PORT", "0")
 
     builder.redirectOutput(Redirect.PIPE)
-    builder.redirectError(Redirect.INHERIT)
+    builder.redirectErrorStream(true)
 
     builder.start(AbsolutePath(livyJar(livyConf)), List(createInteractiveRequest.kind.toString))
   }

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

@@ -59,7 +59,7 @@ object InteractiveSessionYarn {
     createInteractiveRequest.pyFiles.map(RelativePath).foreach(builder.pyFile)
 
     builder.redirectOutput(Redirect.PIPE)
-    builder.redirectErrorStream(redirect = true)
+    builder.redirectErrorStream(true)
 
     val process = builder.start(AbsolutePath(livyJar(livyConf)), List(createInteractiveRequest.kind.toString))