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

Revert "HADOOP-18860. Upgrade mockito version to 4.11.0 (#5977)"

Browse Source 
This reverts commit 1046f9cf9888155c27923f3f56efa107d908ad5b.
This commit is contained in:
Steve Loughran 2023-08-31 14:54:53 +01:00
parent 1046f9cf98
commit 28c533a582
17 changed files with 53 additions and 75 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/ipc/TestServer.java
View File

@ -151,7 +151,7 @@ public class TestServer {
// Nothing should be logged for a suppressed exception.
server.logException(logger, new TestException1(), dummyCall);
verifyNoInteractions(logger);
verifyZeroInteractions(logger);
// No stack trace should be logged for a terse exception.
server.logException(logger, new TestException2(), dummyCall);

9
hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/security/http/TestCrossOriginFilter.java
View File

@ -58,7 +58,8 @@ public class TestCrossOriginFilter {
CrossOriginFilter filter = new CrossOriginFilter();
filter.init(filterConfig);
filter.doFilter(mockReq, mockRes, mockChain);
Mockito.verifyNoInteractions(mockRes);
Mockito.verifyZeroInteractions(mockRes);
Mockito.verify(mockChain).doFilter(mockReq, mockRes);
}
@ -223,7 +224,7 @@ public class TestCrossOriginFilter {
filter.init(filterConfig);
filter.doFilter(mockReq, mockRes, mockChain);
Mockito.verifyNoInteractions(mockRes);
Mockito.verifyZeroInteractions(mockRes);
Mockito.verify(mockChain).doFilter(mockReq, mockRes);
}
@ -251,7 +252,7 @@ public class TestCrossOriginFilter {
filter.init(filterConfig);
filter.doFilter(mockReq, mockRes, mockChain);
Mockito.verifyNoInteractions(mockRes);
Mockito.verifyZeroInteractions(mockRes);
Mockito.verify(mockChain).doFilter(mockReq, mockRes);
}
@ -282,7 +283,7 @@ public class TestCrossOriginFilter {
filter.init(filterConfig);
filter.doFilter(mockReq, mockRes, mockChain);
Mockito.verifyNoInteractions(mockRes);
Mockito.verifyZeroInteractions(mockRes);
Mockito.verify(mockChain).doFilter(mockReq, mockRes);
}

10
hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/security/http/TestRestCsrfPreventionFilter.java
View File

@ -75,7 +75,7 @@ public class TestRestCsrfPreventionFilter {
verify(mockRes, atLeastOnce()).sendError(
HttpServletResponse.SC_BAD_REQUEST, EXPECTED_MESSAGE);
Mockito.verifyNoInteractions(mockChain);
Mockito.verifyZeroInteractions(mockChain);
}
@Test
@ -110,7 +110,7 @@ public class TestRestCsrfPreventionFilter {
verify(mockRes, atLeastOnce()).sendError(
HttpServletResponse.SC_BAD_REQUEST, EXPECTED_MESSAGE);
Mockito.verifyNoInteractions(mockChain);
Mockito.verifyZeroInteractions(mockChain);
}
@Test
@ -228,7 +228,7 @@ public class TestRestCsrfPreventionFilter {
filter.init(filterConfig);
filter.doFilter(mockReq, mockRes, mockChain);
Mockito.verifyNoInteractions(mockChain);
Mockito.verifyZeroInteractions(mockChain);
}
@Test
@ -260,7 +260,7 @@ public class TestRestCsrfPreventionFilter {
filter.init(filterConfig);
filter.doFilter(mockReq, mockRes, mockChain);
Mockito.verifyNoInteractions(mockChain);
Mockito.verifyZeroInteractions(mockChain);
}
@Test
@ -356,6 +356,6 @@ public class TestRestCsrfPreventionFilter {
filter.init(filterConfig);
filter.doFilter(mockReq, mockRes, mockChain);
Mockito.verifyNoInteractions(mockChain);
Mockito.verifyZeroInteractions(mockChain);
}
}

16
hadoop-hdfs-project/hadoop-hdfs-rbf/src/test/java/org/apache/hadoop/hdfs/server/federation/router/TestRouterAdmin.java
View File

@ -25,7 +25,6 @@ import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertTrue;
import java.io.IOException;
import java.lang.reflect.Field;
import java.security.PrivilegedExceptionAction;
import java.util.Collections;
import java.util.HashMap;
@ -69,6 +68,7 @@ import org.junit.Before;
import org.junit.BeforeClass;
import org.junit.Test;
import org.mockito.Mockito;
import org.mockito.internal.util.reflection.FieldSetter;
/**
* The administrator interface of the {@link Router} implemented by
@ -118,20 +118,18 @@ public class TestRouterAdmin {
* @throws IOException
* @throws NoSuchFieldException
*/
private static void setUpMocks() throws IOException, NoSuchFieldException,
IllegalAccessException {
private static void setUpMocks() throws IOException, NoSuchFieldException {
RouterRpcServer spyRpcServer =
Mockito.spy(routerContext.getRouter().createRpcServer());
Field rpcServerField = Router.class.getDeclaredField("rpcServer");
rpcServerField.setAccessible(true);
rpcServerField.set(routerContext.getRouter(), spyRpcServer);
FieldSetter.setField(routerContext.getRouter(),
Router.class.getDeclaredField("rpcServer"), spyRpcServer);
Mockito.doReturn(null).when(spyRpcServer).getFileInfo(Mockito.anyString());
// mock rpc client for destination check when editing mount tables.
mockRpcClient = Mockito.spy(spyRpcServer.getRPCClient());
Field rpcClientField = RouterRpcServer.class.getDeclaredField("rpcClient");
rpcClientField.setAccessible(true);
rpcClientField.set(spyRpcServer, mockRpcClient);
FieldSetter.setField(spyRpcServer,
RouterRpcServer.class.getDeclaredField("rpcClient"),
mockRpcClient);
RemoteLocation remoteLocation0 =
new RemoteLocation("ns0", "/testdir", null);
RemoteLocation remoteLocation1 =

2
hadoop-hdfs-project/hadoop-hdfs-rbf/src/test/java/org/apache/hadoop/hdfs/server/federation/router/TestRouterRpcMultiDestination.java
View File

@ -24,7 +24,7 @@ import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail;
import static org.mockito.ArgumentMatchers.any;
import static org.mockito.Matchers.any;
import static org.mockito.Mockito.doThrow;
import static org.mockito.Mockito.mock;
import static org.apache.hadoop.test.Whitebox.getInternalState;

2
hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/TestCacheDirectives.java
View File

@ -1575,7 +1575,7 @@ public class TestCacheDirectives {
CacheManager cm = cluster.getNamesystem().getCacheManager();
LocatedBlocks locations = Mockito.mock(LocatedBlocks.class);
cm.setCachedLocations(locations);
Mockito.verifyNoInteractions(locations);
Mockito.verifyZeroInteractions(locations);
}
@Test(timeout=120000)

2
hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/TestSnapshotPathINodes.java
View File

@ -447,6 +447,6 @@ public class TestSnapshotPathINodes {
INodesInPath iip = Mockito.mock(INodesInPath.class);
List<INodeDirectory> snapDirs = new ArrayList<>();
FSDirSnapshotOp.checkSnapshot(fsn.getFSDirectory(), iip, snapDirs);
Mockito.verifyNoInteractions(iip);
Mockito.verifyZeroInteractions(iip);
}
}

18
hadoop-project/pom.xml
View File

@ -84,9 +84,6 @@
<!-- com.google.re2j version -->
<re2j.version>1.1</re2j.version>
<!-- org.mockito.mockito-core version -->
<mockito.version>4.11.0</mockito.version>
<!--Protobuf version for backward compatibility-->
<protobuf.version>2.5.0</protobuf.version>
<!-- ProtocolBuffer version, actually used in Hadoop -->
@ -1306,20 +1303,7 @@
<dependency>
<groupId>org.mockito</groupId>
<artifactId>mockito-core</artifactId>
<version>${mockito.version}</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.mockito</groupId>
<artifactId>mockito-inline</artifactId>
<version>${mockito.version}</version>
<scope>test</scope>
<exclusions>
<exclusion>
<groupId>org.mockito</groupId>
<artifactId>mockito-core</artifactId>
</exclusion>
</exclusions>
<version>2.28.2</version>
</dependency>
<dependency>
<groupId>org.mockito</groupId>

4
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-services/hadoop-yarn-services-core/src/test/java/org/apache/hadoop/yarn/service/containerlaunch/TestAbstractLauncher.java
View File

@ -43,7 +43,7 @@ import static org.apache.hadoop.yarn.service.conf.YarnServiceConf
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.reset;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.verifyNoInteractions;
import static org.mockito.Mockito.verifyZeroInteractions;
import static org.mockito.Mockito.when;
/**
@ -90,7 +90,7 @@ public class TestAbstractLauncher {
providerService.buildContainerRetry(mockLauncher, getConfig(),
componentLaunchContext, componentInstance);
verifyNoInteractions(mockLauncher);
verifyZeroInteractions(mockLauncher);
//OnFailure restart policy

8
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/test/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/linux/resources/TestCGroupsHandlerImpl.java
View File

@ -51,8 +51,8 @@ import static org.junit.Assert.assertTrue;
import static org.mockito.ArgumentMatchers.eq;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.verifyNoInteractions;
import static org.mockito.Mockito.verifyNoMoreInteractions;
import static org.mockito.Mockito.verifyZeroInteractions;
/**
* Tests for the CGroups handler implementation.
@ -192,7 +192,7 @@ public class TestCGroupsHandlerImpl {
assertTrue("cgroup dir should be cerated", cgroup.mkdirs());
//Since we enabled (deferred) cgroup controller mounting, no interactions
//should have occurred, with this mock
verifyNoInteractions(privilegedOperationExecutorMock);
verifyZeroInteractions(privilegedOperationExecutorMock);
File emptyMtab = createEmptyCgroups();
try {
@ -238,7 +238,7 @@ public class TestCGroupsHandlerImpl {
public void testCGroupPaths() throws IOException {
//As per junit behavior, we expect a new mock object to be available
//in this test.
verifyNoInteractions(privilegedOperationExecutorMock);
verifyZeroInteractions(privilegedOperationExecutorMock);
CGroupsHandler cGroupsHandler = null;
File mtab = createEmptyCgroups();
@ -281,7 +281,7 @@ public class TestCGroupsHandlerImpl {
public void testCGroupOperations() throws IOException {
//As per junit behavior, we expect a new mock object to be available
//in this test.
verifyNoInteractions(privilegedOperationExecutorMock);
verifyZeroInteractions(privilegedOperationExecutorMock);
CGroupsHandler cGroupsHandler = null;
File mtab = createEmptyCgroups();

4
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/test/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/linux/resources/gpu/TestGpuResourceAllocator.java
View File

@ -27,7 +27,7 @@ import static org.mockito.ArgumentMatchers.eq;
import static org.mockito.Mockito.doThrow;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.verifyNoInteractions;
import static org.mockito.Mockito.verifyZeroInteractions;
import static org.mockito.Mockito.when;
import java.io.IOException;
@ -210,7 +210,7 @@ public class TestGpuResourceAllocator {
private void assertNoAllocation(GpuAllocation allocation) {
assertEquals(1, allocation.getDeniedGPUs().size());
assertEquals(0, allocation.getAllowedGPUs().size());
verifyNoInteractions(nmStateStore);
verifyZeroInteractions(nmStateStore);
}
private void assertAssignmentInStateStore(GpuDevice expectedGpu,

4
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/test/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/linux/runtime/TestDockerContainerRuntime.java
View File

@ -1272,7 +1272,7 @@ public class TestDockerContainerRuntime {
command);
//no --cgroup-parent should be added here
Mockito.verifyNoMoreInteractions(command);
Mockito.verifyZeroInteractions(command);
String resourceOptionsCpu = "/sys/fs/cgroup/cpu/" + hierarchy +
containerIdStr;
@ -1296,7 +1296,7 @@ public class TestDockerContainerRuntime {
command);
//no --cgroup-parent should be added in either case
Mockito.verifyNoMoreInteractions(command);
Mockito.verifyZeroInteractions(command);
}
@Test

6
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/test/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/resourceplugin/com/nec/TestNECVEPlugin.java
View File

@ -25,7 +25,7 @@ import static org.junit.Assert.assertFalse;
import static org.mockito.Mockito.when;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.verifyNoInteractions;
import static org.mockito.Mockito.verifyZeroInteractions;
import static org.mockito.Mockito.verifyNoMoreInteractions;
import static org.mockito.ArgumentMatchers.eq;
import static org.mockito.ArgumentMatchers.anyString;
@ -394,7 +394,7 @@ public class TestNECVEPlugin {
assertEquals("No. of devices", 1, devices.size());
Device device = devices.iterator().next();
assertSame("Device", device, testDevice);
verifyNoInteractions(mockCommandExecutor);
verifyZeroInteractions(mockCommandExecutor);
verify(mockEnvProvider).apply(eq("NEC_USE_UDEV"));
verifyNoMoreInteractions(mockEnvProvider);
}
@ -442,6 +442,6 @@ public class TestNECVEPlugin {
private void verifyBinaryPathSet(Path expectedPath) {
assertEquals("Binary path", expectedPath.toString(),
plugin.getBinaryPath());
verifyNoInteractions(udevUtil);
verifyZeroInteractions(udevUtil);
}
}

6
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/converter/TestFSConfigToCSConfigArgumentHandler.java
View File

@ -23,7 +23,7 @@ import static org.mockito.ArgumentMatchers.any;
import static org.mockito.ArgumentMatchers.anyString;
import static org.mockito.Mockito.doThrow;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.verifyNoInteractions;
import static org.mockito.Mockito.verifyZeroInteractions;
import java.io.File;
import java.io.IOException;
@ -666,7 +666,7 @@ public class TestFSConfigToCSConfigArgumentHandler {
FSConfigConverterTestCommons.FS_ALLOC_FILE, "-s");
argumentHandler.parseAndConvert(args);
verifyNoInteractions(mockValidator);
verifyZeroInteractions(mockValidator);
}
@Test
@ -681,7 +681,7 @@ public class TestFSConfigToCSConfigArgumentHandler {
FSConfigConverterTestCommons.FS_ALLOC_FILE, "-s", "-p");
argumentHandler.parseAndConvert(args);
verifyNoInteractions(mockValidator);
verifyZeroInteractions(mockValidator);
}
@Test

4
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/converter/TestFSConfigToCSConfigConverter.java
View File

@ -36,7 +36,7 @@ import static org.junit.Assert.fail;
import static org.mockito.ArgumentMatchers.any;
import static org.mockito.ArgumentMatchers.anyBoolean;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.verifyNoInteractions;
import static org.mockito.Mockito.verifyZeroInteractions;
import java.io.ByteArrayInputStream;
import java.io.File;
@ -673,7 +673,7 @@ public class TestFSConfigToCSConfigConverter {
converter.setPlacementConverter(placementConverter);
converter.convert(params);
verifyNoInteractions(placementConverter);
verifyZeroInteractions(placementConverter);
}
@Test

26
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/converter/TestQueuePlacementConverter.java
View File

@ -21,7 +21,7 @@ import static org.mockito.ArgumentMatchers.any;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.verifyNoMoreInteractions;
import static org.mockito.Mockito.verifyNoInteractions;
import static org.mockito.Mockito.verifyZeroInteractions;
import static org.mockito.Mockito.when;
import java.util.List;
@ -85,7 +85,7 @@ public class TestQueuePlacementConverter {
MappingRulesDescription description = convert();
assertEquals("Number of rules", 1, description.getRules().size());
verifyRule(description.getRules().get(0), Policy.USER);
verifyNoInteractions(ruleHandler);
verifyZeroInteractions(ruleHandler);
}
@Test
@ -96,7 +96,7 @@ public class TestQueuePlacementConverter {
MappingRulesDescription description = convert();
assertEquals("Number of rules", 1, description.getRules().size());
verifyRule(description.getRules().get(0), Policy.SPECIFIED);
verifyNoInteractions(ruleHandler);
verifyZeroInteractions(ruleHandler);
}
@Test
@ -108,7 +108,7 @@ public class TestQueuePlacementConverter {
assertEquals("Number of rules", 1, description.getRules().size());
verifyRule(description.getRules().get(0), Policy.PRIMARY_GROUP);
verifyNoInteractions(ruleHandler);
verifyZeroInteractions(ruleHandler);
}
@Test
@ -120,7 +120,7 @@ public class TestQueuePlacementConverter {
assertEquals("Number of rules", 1, description.getRules().size());
verifyRule(description.getRules().get(0), Policy.SECONDARY_GROUP);
verifyNoInteractions(ruleHandler);
verifyZeroInteractions(ruleHandler);
}
@Test
@ -134,7 +134,7 @@ public class TestQueuePlacementConverter {
assertEquals("Number of rules", 1, description.getRules().size());
verifyRule(description.getRules().get(0), Policy.CUSTOM);
verifyNoInteractions(ruleHandler);
verifyZeroInteractions(ruleHandler);
}
@Test
@ -147,7 +147,7 @@ public class TestQueuePlacementConverter {
assertEquals("Number of rules", 1, description.getRules().size());
verifyRule(description.getRules().get(0), Policy.DEFAULT_QUEUE);
verifyNoInteractions(ruleHandler);
verifyZeroInteractions(ruleHandler);
}
@Test(expected = IllegalArgumentException.class)
@ -168,7 +168,7 @@ public class TestQueuePlacementConverter {
assertEquals("Number of rules", 1, description.getRules().size());
verifyRule(description.getRules().get(0), Policy.REJECT);
verifyNoInteractions(ruleHandler);
verifyZeroInteractions(ruleHandler);
}
@Test
@ -182,7 +182,7 @@ public class TestQueuePlacementConverter {
assertEquals("Number of rules", 1, description.getRules().size());
verifyRule(description.getRules().get(0), Policy.PRIMARY_GROUP_USER);
verifyNoInteractions(ruleHandler);
verifyZeroInteractions(ruleHandler);
}
@Test
@ -197,7 +197,7 @@ public class TestQueuePlacementConverter {
assertEquals("Number of rules", 1, description.getRules().size());
verifyRule(description.getRules().get(0), Policy.SECONDARY_GROUP_USER);
verifyNoInteractions(ruleHandler);
verifyZeroInteractions(ruleHandler);
}
@Test
@ -215,7 +215,7 @@ public class TestQueuePlacementConverter {
Rule rule = description.getRules().get(0);
verifyRule(description.getRules().get(0), Policy.USER);
assertEquals("Parent path", "root.abc", rule.getParentQueue());
verifyNoInteractions(ruleHandler);
verifyZeroInteractions(ruleHandler);
}
@Test(expected = IllegalArgumentException.class)
@ -245,7 +245,7 @@ public class TestQueuePlacementConverter {
verifyRule(description.getRules().get(0), Policy.USER);
verifyRule(description.getRules().get(1), Policy.PRIMARY_GROUP);
verifyRule(description.getRules().get(2), Policy.SECONDARY_GROUP);
verifyNoInteractions(ruleHandler);
verifyZeroInteractions(ruleHandler);
}
@Test
@ -363,7 +363,7 @@ public class TestQueuePlacementConverter {
any(Policy.class));
verifyNoMoreInteractions(ruleHandler);
} else {
verifyNoInteractions(ruleHandler);
verifyZeroInteractions(ruleHandler);
}
}

5
hadoop-yarn-project/pom.xml
View File

@ -90,11 +90,6 @@
<artifactId>hadoop-yarn-applications-catalog-webapp</artifactId>
<type>war</type>
</dependency>
<dependency>
<groupId>org.mockito</groupId>
<artifactId>mockito-core</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
<build>