diff --git a/pinot-tools/src/main/java/org/apache/pinot/tools/admin/command/LaunchDataIngestionJobCommand.java b/pinot-tools/src/main/java/org/apache/pinot/tools/admin/command/LaunchDataIngestionJobCommand.java index b661352abaf0..f5085db172af 100644 --- a/pinot-tools/src/main/java/org/apache/pinot/tools/admin/command/LaunchDataIngestionJobCommand.java +++ b/pinot-tools/src/main/java/org/apache/pinot/tools/admin/command/LaunchDataIngestionJobCommand.java @@ -159,6 +159,7 @@ public String description() { public static void main(String[] args) { PluginManager.get().init(); - new CommandLine(new LaunchDataIngestionJobCommand()).execute(args); + int exitCode = new CommandLine(new LaunchDataIngestionJobCommand()).execute(args); + System.exit(exitCode); } } diff --git a/pinot-tools/src/main/java/org/apache/pinot/tools/admin/command/LaunchSparkDataIngestionJobCommand.java b/pinot-tools/src/main/java/org/apache/pinot/tools/admin/command/LaunchSparkDataIngestionJobCommand.java index 42fdf1697b9d..df3e852afee6 100644 --- a/pinot-tools/src/main/java/org/apache/pinot/tools/admin/command/LaunchSparkDataIngestionJobCommand.java +++ b/pinot-tools/src/main/java/org/apache/pinot/tools/admin/command/LaunchSparkDataIngestionJobCommand.java @@ -337,7 +337,8 @@ public String description() { public static void main(String[] args) { PluginManager.get().init(); - new CommandLine(new LaunchSparkDataIngestionJobCommand()).execute(args); + int exitCode = new CommandLine(new LaunchSparkDataIngestionJobCommand()).execute(args); + System.exit(exitCode); } enum SparkType {