Repository: samza Updated Branches: refs/heads/master 15c5a1a7e -> ff251405b
SAMZA-1756: System exit calls in ApplicationRunnerMain break ProcessJob and cause unit tests to get skipped Author: Cameron Lee <[email protected]> Reviewers: Xinyu Liu <[email protected]> Closes #561 from cameronlee314/app_runner_main_exit Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/ff251405 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/ff251405 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/ff251405 Branch: refs/heads/master Commit: ff251405b745c8aa27a8a490b75c38878b2fb7e4 Parents: 15c5a1a Author: Cameron Lee <[email protected]> Authored: Fri Jun 22 15:46:14 2018 -0700 Committer: xiliu <[email protected]> Committed: Fri Jun 22 15:46:14 2018 -0700 ---------------------------------------------------------------------- .../org/apache/samza/runtime/ApplicationRunnerMain.java | 10 ---------- 1 file changed, 10 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/ff251405/samza-core/src/main/java/org/apache/samza/runtime/ApplicationRunnerMain.java ---------------------------------------------------------------------- diff --git a/samza-core/src/main/java/org/apache/samza/runtime/ApplicationRunnerMain.java b/samza-core/src/main/java/org/apache/samza/runtime/ApplicationRunnerMain.java index f9f7467..13e6d38 100644 --- a/samza-core/src/main/java/org/apache/samza/runtime/ApplicationRunnerMain.java +++ b/samza-core/src/main/java/org/apache/samza/runtime/ApplicationRunnerMain.java @@ -23,7 +23,6 @@ import joptsimple.OptionSet; import joptsimple.OptionSpec; import org.apache.samza.application.StreamApplication; import org.apache.samza.config.Config; -import org.apache.samza.util.SamzaUncaughtExceptionHandler; import org.apache.samza.job.JobRunner$; import org.apache.samza.util.CommandLine; import org.apache.samza.util.Util; @@ -53,12 +52,6 @@ public class ApplicationRunnerMain { } public static void main(String[] args) throws Exception { - Thread.setDefaultUncaughtExceptionHandler( - new SamzaUncaughtExceptionHandler(() -> { - System.out.println("Exiting process now."); - System.exit(1); - })); - ApplicationRunnerCommandLine cmdLine = new ApplicationRunnerCommandLine(); OptionSet options = cmdLine.parser().parse(args); Config orgConfig = cmdLine.loadConfig(options); @@ -85,8 +78,5 @@ public class ApplicationRunnerMain { } else { JobRunner$.MODULE$.main(args); } - - System.exit(0); } } -
