This is an automated email from the ASF dual-hosted git repository.
chengpan pushed a commit to branch branch-0.3
in repository https://gitbox.apache.org/repos/asf/incubator-celeborn.git
The following commit(s) were added to refs/heads/branch-0.3 by this push:
new 56ac46434 [CELEBORN-650][TEST] Upgrade scalatest and unify mockito
version
56ac46434 is described below
commit 56ac4643492bd5023a170958c53143cdc7cea4fa
Author: Cheng Pan <[email protected]>
AuthorDate: Fri Jun 9 10:04:14 2023 +0800
[CELEBORN-650][TEST] Upgrade scalatest and unify mockito version
### What changes were proposed in this pull request?
This PR upgrades
- `mockito` from 1.10.19 and 3.6.0 to 4.11.0
- `scalatest` from 3.2.3 to 3.2.16
- `mockito-scalatest` from 1.16.37 to 1.17.14
### Why are the changes needed?
Housekeeping, making test dependencies up-to-date and unified.
### Does this PR introduce _any_ user-facing change?
No, it only affects test.
### How was this patch tested?
Pass GA.
Closes #1562 from pan3793/CELEBORN-650.
Authored-by: Cheng Pan <[email protected]>
Signed-off-by: Cheng Pan <[email protected]>
(cherry picked from commit 76533d73249e6caeac454c0365832e81e5dcbca5)
Signed-off-by: Cheng Pan <[email protected]>
---
.../plugin/flink/FlinkShuffleClientImplSuiteJ.java | 19 +++++++------------
.../flink/RemoteShuffleOutputGateSuiteJ.java | 2 +-
client-flink/flink-1.14/pom.xml | 5 -----
.../flink/RemoteShuffleResultPartitionSuiteJ.java | 6 +++---
.../flink/RemoteShuffleServiceFactorySuitJ.java | 4 ++--
client-flink/flink-1.15/pom.xml | 5 -----
.../flink/RemoteShuffleResultPartitionSuiteJ.java | 6 +++---
.../flink/RemoteShuffleServiceFactorySuitJ.java | 4 ++--
client-flink/flink-1.17/pom.xml | 5 -----
.../flink/RemoteShuffleResultPartitionSuiteJ.java | 6 +++---
.../flink/RemoteShuffleServiceFactorySuitJ.java | 4 ++--
client-spark/spark-2/pom.xml | 15 ---------------
.../celeborn/client/ShuffleClientSuiteJ.java | 4 ++--
.../common/haclient/RssHARetryClientSuiteJ.java | 22 ++++++++++------------
master/pom.xml | 6 ------
pom.xml | 18 +++---------------
tests/flink-it/pom.xml | 17 -----------------
tests/spark-it/pom.xml | 11 -----------
worker/pom.xml | 6 ------
19 files changed, 38 insertions(+), 127 deletions(-)
diff --git
a/client-flink/common/src/test/java/org/apache/celeborn/plugin/flink/FlinkShuffleClientImplSuiteJ.java
b/client-flink/common/src/test/java/org/apache/celeborn/plugin/flink/FlinkShuffleClientImplSuiteJ.java
index e5aa87611..ec495b12e 100644
---
a/client-flink/common/src/test/java/org/apache/celeborn/plugin/flink/FlinkShuffleClientImplSuiteJ.java
+++
b/client-flink/common/src/test/java/org/apache/celeborn/plugin/flink/FlinkShuffleClientImplSuiteJ.java
@@ -17,6 +17,7 @@
package org.apache.celeborn.plugin.flink;
+import static org.mockito.ArgumentMatchers.*;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
@@ -29,8 +30,6 @@ import io.netty.channel.ChannelFuture;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
-import org.mockito.Matchers;
-import org.mockito.Mockito;
import org.apache.celeborn.common.CelebornConf;
import org.apache.celeborn.common.network.client.RpcResponseCallback;
@@ -77,11 +76,10 @@ public class FlinkShuffleClientImplSuiteJ {
@Test
public void testPushDataByteBufSuccess() throws IOException {
ByteBuf byteBuf = createByteBuf();
- Mockito.when(client.pushData(Matchers.any(), Matchers.anyLong(),
Matchers.any()))
+ when(client.pushData(any(), anyLong(), any()))
.thenAnswer(
t -> {
- RpcResponseCallback rpcResponseCallback =
- t.getArgumentAt(1, RpcResponseCallback.class);
+ RpcResponseCallback rpcResponseCallback = t.getArgument(1,
RpcResponseCallback.class);
ByteBuffer byteBuffer = ByteBuffer.wrap(new byte[0]);
rpcResponseCallback.onSuccess(byteBuffer);
return mockedFuture;
@@ -95,11 +93,10 @@ public class FlinkShuffleClientImplSuiteJ {
@Test
public void testPushDataByteBufHardSplit() throws IOException {
ByteBuf byteBuf = Unpooled.wrappedBuffer(TEST_BUF1);
- Mockito.when(client.pushData(Matchers.any(), Matchers.anyLong(),
Matchers.any()))
+ when(client.pushData(any(), anyLong(), any()))
.thenAnswer(
t -> {
- RpcResponseCallback rpcResponseCallback =
- t.getArgumentAt(1, RpcResponseCallback.class);
+ RpcResponseCallback rpcResponseCallback = t.getArgument(1,
RpcResponseCallback.class);
ByteBuffer byteBuffer =
ByteBuffer.wrap(new byte[]
{StatusCode.HARD_SPLIT.getValue()});
rpcResponseCallback.onSuccess(byteBuffer);
@@ -112,12 +109,10 @@ public class FlinkShuffleClientImplSuiteJ {
@Test
public void testPushDataByteBufFail() throws IOException {
ByteBuf byteBuf = Unpooled.wrappedBuffer(TEST_BUF1);
- Mockito.when(
- client.pushData(Matchers.any(), Matchers.anyLong(),
Matchers.any(), Matchers.any()))
+ when(client.pushData(any(), anyLong(), any(), any()))
.thenAnswer(
t -> {
- RpcResponseCallback rpcResponseCallback =
- t.getArgumentAt(1, RpcResponseCallback.class);
+ RpcResponseCallback rpcResponseCallback = t.getArgument(1,
RpcResponseCallback.class);
rpcResponseCallback.onFailure(new Exception("pushDataFailed"));
return mockedFuture;
});
diff --git
a/client-flink/common/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleOutputGateSuiteJ.java
b/client-flink/common/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleOutputGateSuiteJ.java
index 1c168f73f..4d74bd492 100644
---
a/client-flink/common/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleOutputGateSuiteJ.java
+++
b/client-flink/common/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleOutputGateSuiteJ.java
@@ -17,7 +17,7 @@
package org.apache.celeborn.plugin.flink;
-import static org.mockito.Matchers.*;
+import static org.mockito.ArgumentMatchers.*;
import static org.mockito.Mockito.*;
import java.io.IOException;
diff --git a/client-flink/flink-1.14/pom.xml b/client-flink/flink-1.14/pom.xml
index ffa10ba4f..903774e07 100644
--- a/client-flink/flink-1.14/pom.xml
+++ b/client-flink/flink-1.14/pom.xml
@@ -50,11 +50,6 @@
<scope>provided</scope>
</dependency>
<!-- Test dependencies -->
- <dependency>
- <groupId>junit</groupId>
- <artifactId>junit</artifactId>
- <scope>test</scope>
- </dependency>
<dependency>
<groupId>org.mockito</groupId>
<artifactId>mockito-core</artifactId>
diff --git
a/client-flink/flink-1.14/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionSuiteJ.java
b/client-flink/flink-1.14/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionSuiteJ.java
index ea8f896f2..de3190cec 100644
---
a/client-flink/flink-1.14/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionSuiteJ.java
+++
b/client-flink/flink-1.14/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionSuiteJ.java
@@ -19,9 +19,9 @@ package org.apache.celeborn.plugin.flink;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertTrue;
-import static org.mockito.Matchers.anyBoolean;
-import static org.mockito.Matchers.anyInt;
-import static org.mockito.Matchers.anyString;
+import static org.mockito.ArgumentMatchers.anyBoolean;
+import static org.mockito.ArgumentMatchers.anyInt;
+import static org.mockito.ArgumentMatchers.anyString;
import static org.mockito.Mockito.doNothing;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
diff --git
a/client-flink/flink-1.14/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactorySuitJ.java
b/client-flink/flink-1.14/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactorySuitJ.java
index 1ecd9a0ed..cc7663859 100644
---
a/client-flink/flink-1.14/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactorySuitJ.java
+++
b/client-flink/flink-1.14/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactorySuitJ.java
@@ -17,8 +17,8 @@
package org.apache.celeborn.plugin.flink;
-import static org.mockito.Matchers.any;
-import static org.mockito.Matchers.anyString;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.ArgumentMatchers.anyString;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
diff --git a/client-flink/flink-1.15/pom.xml b/client-flink/flink-1.15/pom.xml
index 2cf3d1990..ec9f8ac70 100644
--- a/client-flink/flink-1.15/pom.xml
+++ b/client-flink/flink-1.15/pom.xml
@@ -50,11 +50,6 @@
<scope>provided</scope>
</dependency>
<!-- Test dependencies -->
- <dependency>
- <groupId>junit</groupId>
- <artifactId>junit</artifactId>
- <scope>test</scope>
- </dependency>
<dependency>
<groupId>org.mockito</groupId>
<artifactId>mockito-core</artifactId>
diff --git
a/client-flink/flink-1.15/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionSuiteJ.java
b/client-flink/flink-1.15/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionSuiteJ.java
index ea8f896f2..de3190cec 100644
---
a/client-flink/flink-1.15/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionSuiteJ.java
+++
b/client-flink/flink-1.15/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionSuiteJ.java
@@ -19,9 +19,9 @@ package org.apache.celeborn.plugin.flink;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertTrue;
-import static org.mockito.Matchers.anyBoolean;
-import static org.mockito.Matchers.anyInt;
-import static org.mockito.Matchers.anyString;
+import static org.mockito.ArgumentMatchers.anyBoolean;
+import static org.mockito.ArgumentMatchers.anyInt;
+import static org.mockito.ArgumentMatchers.anyString;
import static org.mockito.Mockito.doNothing;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
diff --git
a/client-flink/flink-1.15/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactorySuitJ.java
b/client-flink/flink-1.15/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactorySuitJ.java
index 9a4f232f7..73dbb6a9d 100644
---
a/client-flink/flink-1.15/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactorySuitJ.java
+++
b/client-flink/flink-1.15/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactorySuitJ.java
@@ -17,8 +17,8 @@
package org.apache.celeborn.plugin.flink;
-import static org.mockito.Matchers.any;
-import static org.mockito.Matchers.anyString;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.ArgumentMatchers.anyString;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
diff --git a/client-flink/flink-1.17/pom.xml b/client-flink/flink-1.17/pom.xml
index 9aa586bce..96d8ff863 100644
--- a/client-flink/flink-1.17/pom.xml
+++ b/client-flink/flink-1.17/pom.xml
@@ -50,11 +50,6 @@
<scope>provided</scope>
</dependency>
<!-- Test dependencies -->
- <dependency>
- <groupId>junit</groupId>
- <artifactId>junit</artifactId>
- <scope>test</scope>
- </dependency>
<dependency>
<groupId>org.mockito</groupId>
<artifactId>mockito-core</artifactId>
diff --git
a/client-flink/flink-1.17/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionSuiteJ.java
b/client-flink/flink-1.17/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionSuiteJ.java
index ea8f896f2..de3190cec 100644
---
a/client-flink/flink-1.17/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionSuiteJ.java
+++
b/client-flink/flink-1.17/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionSuiteJ.java
@@ -19,9 +19,9 @@ package org.apache.celeborn.plugin.flink;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertTrue;
-import static org.mockito.Matchers.anyBoolean;
-import static org.mockito.Matchers.anyInt;
-import static org.mockito.Matchers.anyString;
+import static org.mockito.ArgumentMatchers.anyBoolean;
+import static org.mockito.ArgumentMatchers.anyInt;
+import static org.mockito.ArgumentMatchers.anyString;
import static org.mockito.Mockito.doNothing;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
diff --git
a/client-flink/flink-1.17/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactorySuitJ.java
b/client-flink/flink-1.17/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactorySuitJ.java
index 9a4f232f7..73dbb6a9d 100644
---
a/client-flink/flink-1.17/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactorySuitJ.java
+++
b/client-flink/flink-1.17/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactorySuitJ.java
@@ -17,8 +17,8 @@
package org.apache.celeborn.plugin.flink;
-import static org.mockito.Matchers.any;
-import static org.mockito.Matchers.anyString;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.ArgumentMatchers.anyString;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
diff --git a/client-spark/spark-2/pom.xml b/client-spark/spark-2/pom.xml
index 5e138e5d1..f6062366d 100644
--- a/client-spark/spark-2/pom.xml
+++ b/client-spark/spark-2/pom.xml
@@ -74,25 +74,10 @@
<type>test-jar</type>
<scope>test</scope>
</dependency>
- <dependency>
- <groupId>junit</groupId>
- <artifactId>junit</artifactId>
- <scope>test</scope>
- </dependency>
<dependency>
<groupId>org.mockito</groupId>
<artifactId>mockito-core</artifactId>
<scope>test</scope>
</dependency>
- <dependency>
- <groupId>org.scalatest</groupId>
- <artifactId>scalatest_${scala.binary.version}</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.scalamock</groupId>
- <artifactId>scalamock_${scala.binary.version}</artifactId>
- <scope>test</scope>
- </dependency>
</dependencies>
</project>
diff --git
a/client/src/test/java/org/apache/celeborn/client/ShuffleClientSuiteJ.java
b/client/src/test/java/org/apache/celeborn/client/ShuffleClientSuiteJ.java
index aed1b23ff..a34ca413d 100644
--- a/client/src/test/java/org/apache/celeborn/client/ShuffleClientSuiteJ.java
+++ b/client/src/test/java/org/apache/celeborn/client/ShuffleClientSuiteJ.java
@@ -17,8 +17,8 @@
package org.apache.celeborn.client;
-import static org.mockito.Matchers.any;
-import static org.mockito.Matchers.anyLong;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.ArgumentMatchers.anyLong;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
diff --git
a/common/src/test/java/org/apache/celeborn/common/haclient/RssHARetryClientSuiteJ.java
b/common/src/test/java/org/apache/celeborn/common/haclient/RssHARetryClientSuiteJ.java
index 687c9a661..18feddc5f 100644
---
a/common/src/test/java/org/apache/celeborn/common/haclient/RssHARetryClientSuiteJ.java
+++
b/common/src/test/java/org/apache/celeborn/common/haclient/RssHARetryClientSuiteJ.java
@@ -228,15 +228,15 @@ public class RssHARetryClientSuiteJ {
Mockito.doReturn(
Future$.MODULE$.failed(new MasterNotLeaderException("host1:9097",
"host2:9097")))
.when(master1)
- .ask(Mockito.anyObject(), Mockito.anyObject(), Mockito.anyObject());
+ .ask(Mockito.any(), Mockito.any(), Mockito.any());
Mockito.doReturn(Future$.MODULE$.successful(mockResponse))
.when(master3)
- .ask(Mockito.anyObject(), Mockito.anyObject(), Mockito.anyObject());
+ .ask(Mockito.any(), Mockito.any(), Mockito.any());
Mockito.doAnswer(
(invocation) -> {
- RpcAddress address = invocation.getArgumentAt(0,
RpcAddress.class);
+ RpcAddress address = invocation.getArgument(0, RpcAddress.class);
switch (address.host()) {
case "host1":
return master1;
@@ -276,19 +276,17 @@ public class RssHARetryClientSuiteJ {
Mockito.doReturn(
Future$.MODULE$.failed(new MasterNotLeaderException("host1:9097",
"host2:9097")))
.when(ref1)
- .ask(Mockito.anyObject(), Mockito.anyObject(), Mockito.anyObject());
+ .ask(Mockito.any(), Mockito.any(), Mockito.any());
// Assume host2 down.
Mockito.doReturn(Future$.MODULE$.failed(new IOException("Test
IOException")))
.when(ref2)
- .ask(Mockito.anyObject(), Mockito.anyObject(), Mockito.anyObject());
+ .ask(Mockito.any(), Mockito.any(), Mockito.any());
// master leader switch to host3 after host2 down.
- Mockito.doReturn(supplier.get())
- .when(ref3)
- .ask(Mockito.anyObject(), Mockito.anyObject(), Mockito.anyObject());
+ Mockito.doReturn(supplier.get()).when(ref3).ask(Mockito.any(),
Mockito.any(), Mockito.any());
Mockito.doAnswer(
invocation -> {
- RpcAddress address = invocation.getArgumentAt(0,
RpcAddress.class);
+ RpcAddress address = invocation.getArgument(0, RpcAddress.class);
if (address.port() == masterPort) {
switch (address.host()) {
case "host1":
@@ -316,7 +314,7 @@ public class RssHARetryClientSuiteJ {
private void prepareForRpcEnvWithoutHA() {
Mockito.doAnswer(
(invocationOnMock) -> {
- RpcAddress address = invocationOnMock.getArgumentAt(0,
RpcAddress.class);
+ RpcAddress address = invocationOnMock.getArgument(0,
RpcAddress.class);
if (address.host().equals(masterHost) && address.port() ==
masterPort) {
return endpointRef;
} else {
@@ -350,13 +348,13 @@ public class RssHARetryClientSuiteJ {
}
})
.when(endpointRef)
- .ask(Mockito.anyObject(), Mockito.anyObject(), Mockito.anyObject());
+ .ask(Mockito.any(), Mockito.any(), Mockito.any());
}
private void prepareForEndpointRefWithoutRetry(Supplier<Future<?>> supplier)
{
Mockito.doAnswer(invocation -> supplier.get())
.when(endpointRef)
- .ask(Mockito.anyObject(), Mockito.anyObject(), Mockito.anyObject());
+ .ask(Mockito.any(), Mockito.any(), Mockito.any());
}
private CelebornConf prepareForCelebornConfWithoutHA() {
diff --git a/master/pom.xml b/master/pom.xml
index e79cedd6b..5e0dd78da 100644
--- a/master/pom.xml
+++ b/master/pom.xml
@@ -83,15 +83,9 @@
<artifactId>log4j-1.2-api</artifactId>
</dependency>
- <dependency>
- <groupId>org.mockito</groupId>
- <artifactId>mockito-scala-scalatest_${scala.binary.version}</artifactId>
- <scope>test</scope>
- </dependency>
<dependency>
<groupId>org.mockito</groupId>
<artifactId>mockito-core</artifactId>
- <version>3.6.0</version>
<scope>test</scope>
</dependency>
<dependency>
diff --git a/pom.xml b/pom.xml
index 0250ebb30..b90cc5c95 100644
--- a/pom.xml
+++ b/pom.xml
@@ -79,13 +79,12 @@
<leveldb.version>1.8</leveldb.version>
<log4j2.version>2.17.2</log4j2.version>
<lz4-java.version>1.8.0</lz4-java.version>
- <mockito.version>1.10.19</mockito.version>
- <mockito-scalatest.version>1.16.37</mockito-scalatest.version>
+ <mockito.version>4.11.0</mockito.version>
+ <mockito-scalatest.version>1.17.14</mockito-scalatest.version>
<netty.version>4.1.92.Final</netty.version>
<protobuf.version>3.19.2</protobuf.version>
<ratis.version>2.5.1</ratis.version>
- <scalamock.version>5.1.0</scalamock.version>
- <scalatest.version>3.2.3</scalatest.version>
+ <scalatest.version>3.2.16</scalatest.version>
<slf4j.version>1.7.36</slf4j.version>
<roaringbitmap.version>0.9.32</roaringbitmap.version>
<snakeyaml.version>1.33</snakeyaml.version>
@@ -394,17 +393,6 @@
<version>${scalatest.version}</version>
<scope>test</scope>
</dependency>
- <dependency>
- <groupId>org.scalatest</groupId>
- <artifactId>scalatest-funsuite_${scala.binary.version}</artifactId>
- <version>${scalatest.version}</version>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.scalamock</groupId>
- <artifactId>scalamock_${scala.binary.version}</artifactId>
- <version>${scalamock.version}</version>
- </dependency>
<dependency>
<groupId>org.mockito</groupId>
<artifactId>mockito-core</artifactId>
diff --git a/tests/flink-it/pom.xml b/tests/flink-it/pom.xml
index 19028e476..7067feb4a 100644
--- a/tests/flink-it/pom.xml
+++ b/tests/flink-it/pom.xml
@@ -62,23 +62,6 @@
<type>test-jar</type>
<scope>test</scope>
</dependency>
- <dependency>
- <groupId>org.mockito</groupId>
- <artifactId>mockito-scala-scalatest_${scala.binary.version}</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.mockito</groupId>
- <artifactId>mockito-core</artifactId>
- <version>3.6.0</version>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>junit</groupId>
- <artifactId>junit</artifactId>
- <version>${junit.version}</version>
- <scope>test</scope>
- </dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-runtime</artifactId>
diff --git a/tests/spark-it/pom.xml b/tests/spark-it/pom.xml
index f09114f5f..b3b0b8e92 100644
--- a/tests/spark-it/pom.xml
+++ b/tests/spark-it/pom.xml
@@ -62,17 +62,6 @@
<type>test-jar</type>
<scope>test</scope>
</dependency>
- <dependency>
- <groupId>org.mockito</groupId>
- <artifactId>mockito-scala-scalatest_${scala.binary.version}</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.mockito</groupId>
- <artifactId>mockito-core</artifactId>
- <version>3.6.0</version>
- <scope>test</scope>
- </dependency>
<dependency>
<groupId>org.apache.spark</groupId>
<artifactId>spark-core_${scala.binary.version}</artifactId>
diff --git a/worker/pom.xml b/worker/pom.xml
index 07e189657..3d7ab4675 100644
--- a/worker/pom.xml
+++ b/worker/pom.xml
@@ -94,12 +94,6 @@
<artifactId>mockito-scala-scalatest_${scala.binary.version}</artifactId>
<scope>test</scope>
</dependency>
- <dependency>
- <groupId>org.mockito</groupId>
- <artifactId>mockito-core</artifactId>
- <version>3.6.0</version>
- <scope>test</scope>
- </dependency>
</dependencies>
<build>
