From cacbd9868733d2e990b7859a6f2c443ee4900997 Mon Sep 17 00:00:00 2001 From: watermelon12138 <49849410+watermelon12138@users.noreply.github.com> Date: Wed, 27 Apr 2022 21:16:09 +0800 Subject: [PATCH] [HUDI-3945] After the async compaction operation is complete, the task should exit. (#5391) Co-authored-by: y00617041 --- .../main/java/org/apache/hudi/utilities/HoodieCompactor.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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 ce2be7d50..7d21140ae 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 class HoodieCompactor { 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); } }