lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-2931] Add config to disable table services (#4777)

Browse Source
This commit is contained in:
Raymond Xu
2022-02-15 06:49:53 -08:00
committed by GitHub
parent fe02c64fea
commit 538ec44fa8
12 changed files with 199 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
hudi-flink/src/main/java/org/apache/hudi/sink/compact/HoodieFlinkCompactor.java
View File

@@ -18,7 +18,7 @@
package org.apache.hudi.sink.compact;
import org.apache.hudi.async.HoodieAsyncService;
import org.apache.hudi.async.HoodieAsyncTableService;
import org.apache.hudi.avro.model.HoodieCompactionPlan;
import org.apache.hudi.client.HoodieFlinkWriteClient;
import org.apache.hudi.common.table.HoodieTableMetaClient;
@@ -116,7 +116,7 @@ public class HoodieFlinkCompactor {
/**
* Schedules compaction in service.
*/
public static class AsyncCompactionService extends HoodieAsyncService {
public static class AsyncCompactionService extends HoodieAsyncTableService {
private static final long serialVersionUID = 1L;
/**
@@ -173,6 +173,7 @@ public class HoodieFlinkCompactor {
CompactionUtil.inferChangelogMode(conf, metaClient);
this.writeClient = StreamerUtil.createWriteClient(conf);
this.writeConfig = writeClient.getConfig();
this.table = writeClient.getHoodieTable();
}