diff --git hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/SLSRunner.java hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/SLSRunner.java index ddd35ef..80a89c3 100644 --- hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/SLSRunner.java +++ hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/SLSRunner.java @@ -122,6 +122,8 @@ private final static int DEFAULT_MAPPER_PRIORITY = 20; private final static int DEFAULT_REDUCER_PRIORITY = 10; + private static boolean exitAtTheFinish = false; + /** * The type of trace in input. */ @@ -752,6 +754,9 @@ public static void decreaseRemainingApps() { if (remainingApps == 0) { LOG.info("SLSRunner tears down."); + if (exitAtTheFinish) { + System.exit(0); + } } } @@ -848,6 +853,7 @@ public int run(final String[] argv) throws IOException, InterruptedException, } public static void main(String[] argv) throws Exception { + exitAtTheFinish = true; ToolRunner.run(new Configuration(), new SLSRunner(), argv); }