From f1bad36a8937fc74ffa1271f6264d097840edb9c Mon Sep 17 00:00:00 2001 From: Kartik Khare Date: Fri, 16 Sep 2022 15:05:51 +0530 Subject: [PATCH] Bug fix: failure status in ingestion jobs doesn't get reflect in exitCode --- .../tools/admin/command/LaunchDataIngestionJobCommand.java | 3 ++- .../admin/command/LaunchSparkDataIngestionJobCommand.java | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) 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 {