lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-1206] Remove unused variable in Compactor (#1994)

Browse Source
This commit is contained in:
Mathieu
2020-08-20 18:18:36 +08:00
committed by GitHub
parent a2312fa1b7
commit bd7814dadf
2 changed files with 2 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
hudi-client/src/main/java/org/apache/hudi/async/AsyncCompactService.java
View File

@@ -64,7 +64,7 @@ public class AsyncCompactService extends AbstractAsyncService {
public AsyncCompactService(JavaSparkContext jssc, HoodieWriteClient client, boolean runInDaemonMode) { public AsyncCompactService(JavaSparkContext jssc, HoodieWriteClient client, boolean runInDaemonMode) {
super(runInDaemonMode); super(runInDaemonMode);
this.jssc = jssc; this.jssc = jssc;
this.compactor = new Compactor(client, jssc); this.compactor = new Compactor(client);
this.maxConcurrentCompaction = 1; this.maxConcurrentCompaction = 1;
} }

5
hudi-client/src/main/java/org/apache/hudi/client/Compactor.java
View File

@@ -25,7 +25,6 @@ import org.apache.hudi.exception.HoodieException;
import org.apache.log4j.LogManager; import org.apache.log4j.LogManager;
import org.apache.log4j.Logger; import org.apache.log4j.Logger;
import org.apache.spark.api.java.JavaRDD; import org.apache.spark.api.java.JavaRDD;
import org.apache.spark.api.java.JavaSparkContext;
import java.io.IOException; import java.io.IOException;
import java.io.Serializable; import java.io.Serializable;
@@ -39,10 +38,8 @@ public class Compactor implements Serializable {
private static final Logger LOG = LogManager.getLogger(Compactor.class); private static final Logger LOG = LogManager.getLogger(Compactor.class);
private transient HoodieWriteClient compactionClient; private transient HoodieWriteClient compactionClient;
private transient JavaSparkContext jssc;
public Compactor(HoodieWriteClient compactionClient, JavaSparkContext jssc) { public Compactor(HoodieWriteClient compactionClient) {
this.jssc = jssc;
this.compactionClient = compactionClient; this.compactionClient = compactionClient;
} }