diff --git a/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieCompactor.java b/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieCompactor.java index ce2be7d5038dc..7d21140ae7105 100644 --- a/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieCompactor.java +++ b/hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieCompactor.java @@ -171,13 +171,15 @@ public static void main(String[] args) { System.exit(1); } final JavaSparkContext jsc = UtilHelpers.buildSparkContext("compactor-" + cfg.tableName, cfg.sparkMaster, cfg.sparkMemory); + int ret = 0; try { HoodieCompactor compactor = new HoodieCompactor(jsc, cfg); - compactor.compact(cfg.retry); + ret = compactor.compact(cfg.retry); } catch (Throwable throwable) { LOG.error("Fail to run compaction for " + cfg.tableName, throwable); } finally { jsc.stop(); + System.exit(ret); } }