Skip to content

Commit 2c234af

Browse files
author
Alexey Kudinkin
committed
Fixing compilation
1 parent f0cc4ca commit 2c234af

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/commit/BaseMergeHelper.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@ public abstract class BaseMergeHelper {
5555
protected ClosableIterator<GenericRecord> getMergingIterator(HoodieTable<?, ?, ?, ?> table,
5656
HoodieMergeHandle<?, ?, ?, ?> mergeHandle,
5757
Path bootstrapFilePath,
58-
Iterator<GenericRecord> recordIterator) throws IOException {
58+
ClosableIterator<GenericRecord> recordIterator) throws IOException {
5959
Configuration bootstrapFileConfig = new Configuration(table.getHadoopConf());
6060
HoodieFileReader<GenericRecord> bootstrapReader =
6161
HoodieFileReaderFactory.getFileReader(bootstrapFileConfig, bootstrapFilePath);

hudi-common/src/main/java/org/apache/hudi/common/util/collection/ClosableMappingIterator.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,6 @@ public ClosableMappingIterator(ClosableIterator<T> sourceIterator, Function<T, R
3030

3131
@Override
3232
public void close() {
33-
((ClosableIterator<T>) sourceIterator).close();
33+
((ClosableIterator<T>) source).close();
3434
}
3535
}

0 commit comments

Comments
 (0)