Skip to content

Commit

Permalink
Fixed error introduced during merge
Browse files Browse the repository at this point in the history
  • Loading branch information
csrster committed Jan 4, 2022
1 parent 7a085bb commit 51e3eaa
Showing 1 changed file with 1 addition and 1 deletion.
Expand Up @@ -61,7 +61,7 @@ protected void map(LongWritable linenumber, Text archiveFilePath, Context contex

try (FileSystem hdfsFileSystem =
FileSystem.newInstance(context.getConfiguration())) {
path = HadoopFileUtils.replaceWithCachedPathIfEnabled(hdfsFileSystem, path);
path = HadoopFileUtils.replaceWithCachedPathIfEnabled(context, path);
List<String> cdxIndexes;
try (InputStream in = new BufferedInputStream(path.getFileSystem(context.getConfiguration()).open(path))) {
log.info("CDX-indexing archive file '{}'", path);
Expand Down

0 comments on commit 51e3eaa

Please sign in to comment.