big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

MAPREDUCE-6945. TestMapFileOutputFormat missing @after annotation. Contributed by Ajay Kumar

Browse Source
This commit is contained in:
Mingliang Liu 2017-08-27 15:19:55 -07:00
parent 077a5eed9f
commit ae7abad3d9
2 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapred/TestMapFileOutputFormat.java
View File

@ -24,6 +24,7 @@
import org.apache.hadoop.io.Writable; import org.apache.hadoop.io.Writable;
import org.apache.hadoop.io.WritableComparable; import org.apache.hadoop.io.WritableComparable;
import org.apache.hadoop.io.MapFile.Reader; import org.apache.hadoop.io.MapFile.Reader;
import org.junit.After;
import org.junit.Test; import org.junit.Test;
import org.mockito.Mockito; import org.mockito.Mockito;
@ -40,9 +41,10 @@ public void testPartitionerShouldNotBeCalledWhenOneReducerIsPresent()
assertTrue(!MyPartitioner.isGetPartitionCalled()); assertTrue(!MyPartitioner.isGetPartitionCalled());
} }
protected void tearDown() throws Exception { @After
public void tearDown() throws Exception {
MyPartitioner.setGetPartitionCalled(false); MyPartitioner.setGetPartitionCalled(false);
}; }
private static class MyPartitioner private static class MyPartitioner
implements implements
Partitioner<WritableComparable, Writable> { Partitioner<WritableComparable, Writable> {

2
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapreduce/lib/output/TestMapFileOutputFormat.java
View File

@ -25,6 +25,7 @@
import org.apache.hadoop.io.WritableComparable; import org.apache.hadoop.io.WritableComparable;
import org.apache.hadoop.io.MapFile.Reader; import org.apache.hadoop.io.MapFile.Reader;
import org.apache.hadoop.mapreduce.Partitioner; import org.apache.hadoop.mapreduce.Partitioner;
import org.junit.After;
import org.junit.Test; import org.junit.Test;
import org.mockito.Mockito; import org.mockito.Mockito;
@ -41,6 +42,7 @@ public void testPartitionerShouldNotBeCalledWhenOneReducerIsPresent()
assertTrue(!MyPartitioner.isGetPartitionCalled()); assertTrue(!MyPartitioner.isGetPartitionCalled());
} }
@After
public void tearDown() throws Exception { public void tearDown() throws Exception {
MyPartitioner.setGetPartitionCalled(false); MyPartitioner.setGetPartitionCalled(false);
} }