[hudi] branch master updated: [HUDI-1206] Remove unused variable in Compactor (#1994)

[vinoyang]

This is an automated email from the ASF dual-hosted git repository.

vinoyang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new bd7814d  [HUDI-1206] Remove unused variable in Compactor (#1994)
bd7814d is described below

commit bd7814dadf9f6f5faa5b9ab61ff5f6bbfe5da5e2
Author: Mathieu <wxhj...@126.com>
AuthorDate: Thu Aug 20 18:18:36 2020 +0800

    [HUDI-1206] Remove unused variable in Compactor (#1994)
---
 .../src/main/java/org/apache/hudi/async/AsyncCompactService.java     | 2 +-
 hudi-client/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 1c39bb6..391344f 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 1f11620..b235e25 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;
   }