Skip to content

Commit

Permalink
dfsio does not work if mapreduce.output.fileoutputformat.compress is … (
Browse files Browse the repository at this point in the history
  • Loading branch information
kyungwan-nam authored Apr 7, 2024
1 parent b5efe8a commit 2fa065b
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions sdk/java/src/main/java/io/juicefs/bench/TestDFSIO.java
Original file line number Diff line number Diff line change
Expand Up @@ -584,6 +584,7 @@ private void runIOTest(
Class<? extends Mapper<Text, LongWritable, Text, Text>> mapperClass,
Path outputDir) throws IOException {
JobConf job = new JobConf(config, TestDFSIO.class);
job.setBoolean("mapreduce.output.fileoutputformat.compress", false);

FileInputFormat.setInputPaths(job, getControlDir(config));
job.setInputFormat(SequenceFileInputFormat.class);
Expand Down

0 comments on commit 2fa065b

Please sign in to comment.