From bd7814dadf9f6f5faa5b9ab61ff5f6bbfe5da5e2 Mon Sep 17 00:00:00 2001 From: Mathieu Date: Thu, 20 Aug 2020 18:18:36 +0800 Subject: [PATCH] [HUDI-1206] Remove unused variable in Compactor (#1994) --- .../main/java/org/apache/hudi/async/AsyncCompactService.java | 2 +- .../src/main/java/org/apache/hudi/client/Compactor.java | 5 +---- 2 files changed, 2 insertions(+), 5 deletions(-) diff --git a/hudi-client/src/main/java/org/apache/hudi/async/AsyncCompactService.java b/hudi-client/src/main/java/org/apache/hudi/async/AsyncCompactService.java index 1c39bb6cf..391344f16 100644 --- a/hudi-client/src/main/java/org/apache/hudi/async/AsyncCompactService.java +++ b/hudi-client/src/main/java/org/apache/hudi/async/AsyncCompactService.java @@ -64,7 +64,7 @@ public class AsyncCompactService extends AbstractAsyncService { public AsyncCompactService(JavaSparkContext jssc, HoodieWriteClient client, boolean runInDaemonMode) { super(runInDaemonMode); this.jssc = jssc; - this.compactor = new Compactor(client, jssc); + this.compactor = new Compactor(client); this.maxConcurrentCompaction = 1; } diff --git a/hudi-client/src/main/java/org/apache/hudi/client/Compactor.java b/hudi-client/src/main/java/org/apache/hudi/client/Compactor.java index 1f11620c7..b235e25e1 100644 --- a/hudi-client/src/main/java/org/apache/hudi/client/Compactor.java +++ b/hudi-client/src/main/java/org/apache/hudi/client/Compactor.java @@ -25,7 +25,6 @@ import org.apache.hudi.exception.HoodieException; import org.apache.log4j.LogManager; import org.apache.log4j.Logger; import org.apache.spark.api.java.JavaRDD; -import org.apache.spark.api.java.JavaSparkContext; import java.io.IOException; import java.io.Serializable; @@ -39,10 +38,8 @@ public class Compactor implements Serializable { private static final Logger LOG = LogManager.getLogger(Compactor.class); private transient HoodieWriteClient compactionClient; - private transient JavaSparkContext jssc; - public Compactor(HoodieWriteClient compactionClient, JavaSparkContext jssc) { - this.jssc = jssc; + public Compactor(HoodieWriteClient compactionClient) { this.compactionClient = compactionClient; }