This is an automated email from the ASF dual-hosted git repository.
sammichen pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/trunk by this push:
new 79641da185b MAPREDUCE-7525. Improve TestDFSIO to support different
InputFormat (#8241)
79641da185b is described below
commit 79641da185be9ac52c7105d08bb3b5aae74b6fbd
Author: zhixingheyi-tian <[email protected]>
AuthorDate: Thu Feb 12 13:02:39 2026 +0800
MAPREDUCE-7525. Improve TestDFSIO to support different InputFormat (#8241)
---
.../src/test/java/org/apache/hadoop/fs/TestDFSIO.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git
a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/fs/TestDFSIO.java
b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/fs/TestDFSIO.java
index 9b9fdacbe57..f1e90b249a2 100644
---
a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/fs/TestDFSIO.java
+++
b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/fs/TestDFSIO.java
@@ -537,7 +537,9 @@ private void runIOTest(
JobConf job = new JobConf(config, TestDFSIO.class);
FileInputFormat.setInputPaths(job, getControlDir(config));
- job.setInputFormat(SequenceFileInputFormat.class);
+ if (null == job.getClass("mapred.input.format.class", null)) {
+ job.setInputFormat(SequenceFileInputFormat.class);
+ }
job.setMapperClass(mapperClass);
job.setReducerClass(AccumulatingReducer.class);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
