lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] Fix BatchBootstrapOperator initialization (#3520)

Browse Source
This commit is contained in:
Danny Chan
2021-08-22 13:03:22 +08:00
committed by GitHub
parent be8c1e499f
commit 05e6f44d53
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/batch/BatchBootstrapOperator.java
View File

@@ -42,11 +42,16 @@ import java.util.Set;
public class BatchBootstrapOperator<I, O extends HoodieRecord> public class BatchBootstrapOperator<I, O extends HoodieRecord>
extends BootstrapOperator<I, O> { extends BootstrapOperator<I, O> {
private final Set<String> partitionPathSet; private Set<String> partitionPathSet;
private final boolean haveSuccessfulCommits; private boolean haveSuccessfulCommits;
public BatchBootstrapOperator(Configuration conf) { public BatchBootstrapOperator(Configuration conf) {
super(conf); super(conf);
}
@Override
public void open() throws Exception {
super.open();
this.partitionPathSet = new HashSet<>(); this.partitionPathSet = new HashSet<>();
this.haveSuccessfulCommits = StreamerUtil.haveSuccessfulCommits(hoodieTable.getMetaClient()); this.haveSuccessfulCommits = StreamerUtil.haveSuccessfulCommits(hoodieTable.getMetaClient());
} }