Przeglądaj źródła

[spark] More logging tweaks

Erick Tryzelaar 11 lat temu
rodzic
commit
6e9a03c

+ 3 - 2
apps/spark/java/sparker-server/src/main/java/com/cloudera/hue/sparker/server/SparkerSession.java

@@ -85,7 +85,8 @@ public class SparkerSession implements Session {
                         }
                     }
 
-                    process.waitFor();
+                    int exitCode = process.waitFor();
+                    logger.info("[" + key + "]: process exited with " + exitCode);
                 } catch (IOException e) {
                     e.printStackTrace();
                 } catch (InterruptedException e) {
@@ -165,7 +166,7 @@ public class SparkerSession implements Session {
             throw new TimeoutException();
         }
 
-        logger.info("[" + key + "]: shell closed");
+        logger.info("[" + key + "]: shell closed with " + process.exitValue());
     }
 
     protected long lastActivity = Long.MAX_VALUE;