MAPREDUCE-7420. Fix CheckStyle.

apache · Feb 8, 2025 · 2b669d2 · 2b669d2
1 parent c16bcc2
commit 2b669d2
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 5 deletions.
diff --git a/...mapreduce-client-core/src/test/java/org/apache/hadoop/mapred/TestFileOutputCommitter.java b/...mapreduce-client-core/src/test/java/org/apache/hadoop/mapred/TestFileOutputCommitter.java
@@ -148,9 +148,9 @@ private void testRecoveryInternal(int commitVersion, int recoveryVersion)
       assertTrue(jtd2.exists(), "Version 1 recovers to " + jtd2);
       validateContent(jobTempDir2);
     } else {
-     assertFalse(jtd2.exists(), "Version 2 commits to output dir " + jtd2);
-     if (commitVersion == 1) {
-       assertEquals(0, jtd1.list().length,
+      assertFalse(jtd2.exists(), "Version 2 commits to output dir " + jtd2);
+      if (commitVersion == 1) {
+        assertEquals(0, jtd1.list().length,
            "Version 2  recovery moves to output dir from " + jtd1);
       }
     }

diff --git a/...client-core/src/test/java/org/apache/hadoop/mapreduce/filecache/TestDistributedCache.java b/...client-core/src/test/java/org/apache/hadoop/mapreduce/filecache/TestDistributedCache.java
@@ -94,7 +94,7 @@ public void testAddFileToClassPath() throws Exception {
     DistributedCache.addFileToClassPath(new Path("file:///a"), conf, fs, true);
     assertEquals("file:/a", conf.get(MRJobConfig.CLASSPATH_FILES),
         "The mapreduce.job.classpath.files property was not set correctly");
-    assertEquals( "file:///a", conf.get(MRJobConfig.CACHE_FILES),
+    assertEquals("file:///a", conf.get(MRJobConfig.CACHE_FILES),
         "The mapreduce.job.cache.files property was not set correctly");
 
     DistributedCache.addFileToClassPath(new Path("file:///b"), conf, fs, true);

diff --git a/...e-client-core/src/test/java/org/apache/hadoop/mapreduce/task/reduce/TestMergeManager.java b/...e-client-core/src/test/java/org/apache/hadoop/mapreduce/task/reduce/TestMergeManager.java
@@ -219,7 +219,8 @@ public void testOnDiskMerger() throws IOException {
 
     MapOutputFile mapOutputFile = new MROutputFiles();
     FileSystem fs = FileSystem.getLocal(jobConf);
-    MergeManagerImpl<IntWritable, IntWritable> manager = new MergeManagerImpl<>(null, jobConf, fs, null,
+    MergeManagerImpl<IntWritable, IntWritable> manager = new MergeManagerImpl<>(
+        null, jobConf, fs, null,
         null, null, null, null, null, null, null, null, null, mapOutputFile);
 
     MergeThread onDiskMerger = manager.getOnDiskMerger();