Skip to content

Commit 7e1dfd1

Browse files
committed
rebasing with master
1 parent b837196 commit 7e1dfd1

File tree

3 files changed

+5
-10
lines changed

3 files changed

+5
-10
lines changed

hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieLogFormatReader.java

Lines changed: 2 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -104,13 +104,8 @@ public boolean hasNext() {
104104
} else {
105105
this.prevReadersInOpenState.add(currentReader);
106106
}
107-
this.currentReader =
108-
//<<<<<<< HEAD
109-
// new HoodieLogFileReader(fs, nextLogFile, readerSchema, bufferSize, readBlocksLazily, false,
110-
// enableInlineReading, recordKeyField);
111-
//=======
112-
new HoodieLogFileReader(fs, nextLogFile, readerSchema, bufferSize, readBlocksLazily, false, enableInlineReading, recordKeyField);
113-
//>>>>>>> 6035d6452 (Removing direct fs call in HoodieLogFileReader)
107+
this.currentReader = new HoodieLogFileReader(fs, nextLogFile, readerSchema, bufferSize, readBlocksLazily, false,
108+
enableInlineReading, recordKeyField);
114109
} catch (IOException io) {
115110
throw new HoodieIOException("unable to initialize read with log file ", io);
116111
}

hudi-common/src/main/java/org/apache/hudi/common/table/log/LogReaderUtils.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -44,10 +44,10 @@
4444
*/
4545
public class LogReaderUtils {
4646

47-
private static Schema readSchemaFromLogFileInReverse(FileSystem fs, HoodieActiveTimeline activeTimeline, Pair<String, Long> logPathFilePathSizePair)
47+
private static Schema readSchemaFromLogFileInReverse(FileSystem fs, HoodieActiveTimeline activeTimeline, Pair<String, Long> logFilePathSizePairs)
4848
throws IOException {
4949
// set length for the HoodieLogFile as it will be leveraged by HoodieLogFormat.Reader with reverseReading enabled
50-
Reader reader = HoodieLogFormat.newReader(fs, new HoodieLogFile(new Path(logPathFilePathSizePair.getKey()), logPathFilePathSizePair.getValue()), null, true, true);
50+
Reader reader = HoodieLogFormat.newReader(fs, new HoodieLogFile(new Path(logFilePathSizePairs.getKey()), logFilePathSizePairs.getValue()), null, true, true);
5151
Schema writerSchema = null;
5252
HoodieTimeline completedTimeline = activeTimeline.getCommitsTimeline().filterCompletedInstants();
5353
while (reader.hasPrev()) {

hudi-common/src/main/java/org/apache/hudi/metadata/HoodieMetadataFileSystemView.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,7 @@ public HoodieMetadataFileSystemView(HoodieEngineContext engineContext,
6161
* @throws IOException
6262
*/
6363
@Override
64-
public FileStatus[] listPartition(Path partitionPath) throws IOException {
64+
protected FileStatus[] listPartition(Path partitionPath) throws IOException {
6565
return tableMetadata.getAllFilesInPartition(partitionPath);
6666
}
6767

0 commit comments

Comments
 (0)