[FLINK-30196][tests] Replace usage of deprecated Mockito methods and update Mockito to 4.11.0

Author: snuyanzin

flink-connectors/flink-hadoop-compatibility/src/test/java/org/apache/flink/api/java/hadoop/mapred/HadoopOutputFormatTest.java

@@ -35,7 +35,7 @@
 import org.apache.hadoop.mapred.TaskAttemptContext;
 import org.apache.hadoop.util.Progressable;
 import org.junit.jupiter.api.Test;
-import org.mockito.Matchers;
+import org.mockito.ArgumentMatchers;
 import org.mockito.Mockito;
 
 import java.io.IOException;
@@ -83,7 +83,7 @@ void testConfigureWithConfigurable() {
         HadoopOutputFormat<String, Long> outputFormat =
                 new HadoopOutputFormat<>(dummyOutputFormat, jobConf);
 
-        outputFormat.configure(Matchers.<org.apache.flink.configuration.Configuration>any());
+        outputFormat.configure(ArgumentMatchers.any());
 
         verify(dummyOutputFormat, times(1)).setConf(any(Configuration.class));
     }
@@ -97,7 +97,7 @@ void testConfigureWithJobConfigurable() {
         HadoopOutputFormat<String, Long> outputFormat =
                 new HadoopOutputFormat<>(dummyOutputFormat, jobConf);
 
-        outputFormat.configure(Matchers.<org.apache.flink.configuration.Configuration>any());
+        outputFormat.configure(ArgumentMatchers.any());
 
         verify(dummyOutputFormat, times(1)).configure(any(JobConf.class));
     }

flink-filesystems/flink-hadoop-fs/src/test/java/org/apache/flink/runtime/fs/hdfs/HadoopDataInputStreamTest.java

@@ -29,7 +29,7 @@
 
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.assertj.core.api.Assertions.assertThatThrownBy;
-import static org.mockito.Matchers.anyLong;
+import static org.mockito.ArgumentMatchers.anyLong;
 import static org.mockito.Mockito.atLeastOnce;
 import static org.mockito.Mockito.never;
 import static org.mockito.Mockito.reset;

flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAITCase.java

@@ -59,7 +59,7 @@
 import static org.hamcrest.CoreMatchers.equalTo;
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertThat;
-import static org.mockito.Matchers.anyLong;
+import static org.mockito.ArgumentMatchers.anyLong;
 
 /**
  * General tests for {@link NFA} features. See also {@link IterativeConditionsITCase}, {@link

flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorMasterHooksTest.java

@@ -55,8 +55,8 @@
 import static org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTestingUtils.StringSerializer;
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.assertj.core.api.Assertions.fail;
-import static org.mockito.Matchers.eq;
-import static org.mockito.Matchers.isNull;
+import static org.mockito.ArgumentMatchers.eq;
+import static org.mockito.ArgumentMatchers.isNull;
 import static org.mockito.Mockito.any;
 import static org.mockito.Mockito.anyLong;
 import static org.mockito.Mockito.mock;

flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTest.java

@@ -139,9 +139,9 @@
 import static org.apache.flink.util.Preconditions.checkState;
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.assertj.core.api.Assertions.fail;
+import static org.mockito.ArgumentMatchers.any;
 import static org.mockito.ArgumentMatchers.anyList;
 import static org.mockito.ArgumentMatchers.anyLong;
-import static org.mockito.Matchers.any;
 import static org.mockito.Mockito.eq;
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.never;

flink-runtime/src/test/java/org/apache/flink/runtime/highavailability/nonha/embedded/EmbeddedHaServicesTest.java

@@ -37,7 +37,7 @@
 import static junit.framework.TestCase.assertTrue;
 import static org.hamcrest.Matchers.is;
 import static org.junit.Assert.assertThat;
-import static org.mockito.Matchers.any;
+import static org.mockito.ArgumentMatchers.any;
 import static org.mockito.Mockito.atLeast;
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.verify;

flink-runtime/src/test/java/org/apache/flink/runtime/highavailability/nonha/standalone/StandaloneHaServicesTest.java

@@ -30,7 +30,7 @@
 import org.junit.Before;
 import org.junit.Test;
 
-import static org.mockito.Matchers.eq;
+import static org.mockito.ArgumentMatchers.eq;
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.verify;
 

flink-runtime/src/test/java/org/apache/flink/runtime/io/network/api/reader/AbstractReaderTest.java

@@ -27,7 +27,7 @@
 import org.apache.flink.runtime.util.event.EventListener;
 
 import org.junit.jupiter.api.Test;
-import org.mockito.Matchers;
+import org.mockito.ArgumentMatchers;
 
 import java.io.IOException;
 
@@ -57,9 +57,9 @@ void testTaskEvent() throws Exception {
         reader.handleEvent(new TestTaskEvent1()); // for listener1 only
         reader.handleEvent(new TestTaskEvent2()); // for listener2 only
 
-        verify(listener1, times(1)).onEvent(Matchers.any(TaskEvent.class));
-        verify(listener2, times(1)).onEvent(Matchers.any(TaskEvent.class));
-        verify(listener3, times(0)).onEvent(Matchers.any(TaskEvent.class));
+        verify(listener1, times(1)).onEvent(ArgumentMatchers.any(TaskEvent.class));
+        verify(listener2, times(1)).onEvent(ArgumentMatchers.any(TaskEvent.class));
+        verify(listener3, times(0)).onEvent(ArgumentMatchers.any(TaskEvent.class));
     }
 
     @Test

flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/InputChannelTestUtils.java

@@ -45,7 +45,7 @@
 import java.util.function.Consumer;
 
 import static org.apache.flink.runtime.io.network.buffer.BufferBuilderTestUtils.createFilledFinishedBufferConsumer;
-import static org.mockito.Matchers.any;
+import static org.mockito.ArgumentMatchers.any;
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.when;
 

flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java

@@ -101,7 +101,7 @@
 import static org.apache.flink.util.Preconditions.checkNotNull;
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.assertj.core.api.Assertions.assertThatThrownBy;
-import static org.mockito.Matchers.any;
+import static org.mockito.ArgumentMatchers.any;
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.spy;
 import static org.mockito.Mockito.times;

flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/ZooKeeperExecutionPlansStoreITCase.java

@@ -52,7 +52,7 @@
 
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.assertj.core.api.Assertions.assertThatExceptionOfType;
-import static org.mockito.Matchers.any;
+import static org.mockito.ArgumentMatchers.any;
 import static org.mockito.Mockito.atMost;
 import static org.mockito.Mockito.doAnswer;
 import static org.mockito.Mockito.mock;

flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/AbstractHandlerTest.java

@@ -74,8 +74,8 @@
 
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.assertj.core.api.Assertions.assertThatThrownBy;
+import static org.mockito.ArgumentMatchers.any;
 import static org.mockito.ArgumentMatchers.eq;
-import static org.mockito.Matchers.any;
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.when;
 

flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java

@@ -125,8 +125,8 @@
 import static org.assertj.core.api.Assertions.assertThatThrownBy;
 import static org.assertj.core.api.Assertions.fail;
 import static org.assertj.core.api.Assumptions.assumeThat;
-import static org.mockito.Matchers.any;
-import static org.mockito.Matchers.eq;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.ArgumentMatchers.eq;
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.times;
 import static org.mockito.Mockito.verify;

flink-runtime/src/test/java/org/apache/flink/runtime/state/filesystem/FsCheckpointStateOutputStreamTest.java

@@ -60,9 +60,9 @@
 import static org.junit.Assert.assertFalse;
 import static org.junit.Assert.assertThrows;
 import static org.junit.Assert.assertTrue;
-import static org.mockito.Matchers.any;
-import static org.mockito.Matchers.anyBoolean;
-import static org.mockito.Matchers.eq;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.ArgumentMatchers.anyBoolean;
+import static org.mockito.ArgumentMatchers.eq;
 import static org.mockito.Mockito.doAnswer;
 import static org.mockito.Mockito.doThrow;
 import static org.mockito.Mockito.mock;

flink-runtime/src/test/java/org/apache/flink/streaming/api/operators/StreamingRuntimeContextTest.java

@@ -70,7 +70,7 @@
 import org.apache.flink.streaming.util.MockStreamTaskBuilder;
 
 import org.junit.jupiter.api.Test;
-import org.mockito.Matchers;
+import org.mockito.ArgumentMatchers;
 import org.mockito.invocation.InvocationOnMock;
 import org.mockito.stubbing.Answer;
 
@@ -483,7 +483,9 @@ public <T> TypeSerializer<T> createSerializer(
                                 })
                 .when(keyedStateBackend)
                 .getPartitionedState(
-                        Matchers.any(), any(TypeSerializer.class), any(StateDescriptor.class));
+                        ArgumentMatchers.any(),
+                        any(TypeSerializer.class),
+                        any(StateDescriptor.class));
 
         doAnswer(
                         (Answer<Object>)
@@ -572,7 +574,9 @@ public ListState<String> answer(InvocationOnMock invocationOnMock)
                         })
                 .when(keyedStateBackend)
                 .getPartitionedState(
-                        Matchers.any(), any(TypeSerializer.class), any(ListStateDescriptor.class));
+                        ArgumentMatchers.any(),
+                        any(TypeSerializer.class),
+                        any(ListStateDescriptor.class));
 
         when(operatorMock.getKeyedStateStore()).thenReturn(keyedStateStore);
         when(operatorMock.getOperatorID()).thenReturn(new OperatorID());
@@ -643,7 +647,9 @@ public MapState<Integer, String> answer(
                         })
                 .when(keyedStateBackend)
                 .getPartitionedState(
-                        Matchers.any(), any(TypeSerializer.class), any(MapStateDescriptor.class));
+                        ArgumentMatchers.any(),
+                        any(TypeSerializer.class),
+                        any(MapStateDescriptor.class));
 
         when(operatorMock.getKeyedStateStore()).thenReturn(keyedStateStore);
         when(operatorMock.getOperatorID()).thenReturn(new OperatorID());

flink-runtime/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/PurgingTriggerTest.java

@@ -25,7 +25,7 @@
 import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;
 
 import org.junit.jupiter.api.Test;
-import org.mockito.Matchers;
+import org.mockito.ArgumentMatchers;
 import org.mockito.invocation.InvocationOnMock;
 import org.mockito.stubbing.Answer;
 
@@ -36,7 +36,7 @@
 import static org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorContractTest.anyTimeWindow;
 import static org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorContractTest.anyTriggerContext;
 import static org.assertj.core.api.Assertions.assertThat;
-import static org.mockito.Matchers.anyLong;
+import static org.mockito.ArgumentMatchers.anyLong;
 import static org.mockito.Mockito.doAnswer;
 import static org.mockito.Mockito.eq;
 import static org.mockito.Mockito.mock;
@@ -69,25 +69,25 @@ void testForwarding() throws Exception {
                         PurgingTrigger.of(mockTrigger), new TimeWindow.Serializer());
 
         when(mockTrigger.onElement(
-                        Matchers.anyObject(), anyLong(), anyTimeWindow(), anyTriggerContext()))
+                        ArgumentMatchers.any(), anyLong(), anyTimeWindow(), anyTriggerContext()))
                 .thenReturn(TriggerResult.CONTINUE);
         assertThat(testHarness.processElement(new StreamRecord<>(1), new TimeWindow(0, 2)))
                 .isEqualTo(TriggerResult.CONTINUE);
 
         when(mockTrigger.onElement(
-                        Matchers.anyObject(), anyLong(), anyTimeWindow(), anyTriggerContext()))
+                        ArgumentMatchers.any(), anyLong(), anyTimeWindow(), anyTriggerContext()))
                 .thenReturn(TriggerResult.FIRE);
         assertThat(testHarness.processElement(new StreamRecord<>(1), new TimeWindow(0, 2)))
                 .isEqualTo(TriggerResult.FIRE_AND_PURGE);
 
         when(mockTrigger.onElement(
-                        Matchers.anyObject(), anyLong(), anyTimeWindow(), anyTriggerContext()))
+                        ArgumentMatchers.any(), anyLong(), anyTimeWindow(), anyTriggerContext()))
                 .thenReturn(TriggerResult.FIRE_AND_PURGE);
         assertThat(testHarness.processElement(new StreamRecord<>(1), new TimeWindow(0, 2)))
                 .isEqualTo(TriggerResult.FIRE_AND_PURGE);
 
         when(mockTrigger.onElement(
-                        Matchers.anyObject(), anyLong(), anyTimeWindow(), anyTriggerContext()))
+                        ArgumentMatchers.any(), anyLong(), anyTimeWindow(), anyTriggerContext()))
                 .thenReturn(TriggerResult.PURGE);
         assertThat(testHarness.processElement(new StreamRecord<>(1), new TimeWindow(0, 2)))
                 .isEqualTo(TriggerResult.PURGE);
@@ -111,11 +111,7 @@ public TriggerResult answer(InvocationOnMock invocation)
                             }
                         })
                 .when(mockTrigger)
-                .onElement(
-                        Matchers.<Integer>anyObject(),
-                        anyLong(),
-                        anyTimeWindow(),
-                        anyTriggerContext());
+                .onElement(ArgumentMatchers.any(), anyLong(), anyTimeWindow(), anyTriggerContext());
 
         // set up our timers
         testHarness.processElement(new StreamRecord<>(1), new TimeWindow(0, 2));
@@ -161,11 +157,7 @@ public TriggerResult answer(InvocationOnMock invocation)
                             }
                         })
                 .when(mockTrigger)
-                .onElement(
-                        Matchers.<Integer>anyObject(),
-                        anyLong(),
-                        anyTimeWindow(),
-                        anyTriggerContext());
+                .onElement(ArgumentMatchers.any(), anyLong(), anyTimeWindow(), anyTriggerContext());
 
         // set up our timers
         testHarness.processElement(new StreamRecord<>(1), new TimeWindow(0, 2));

flink-runtime/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/RegularWindowOperatorContractTest.java

@@ -40,16 +40,16 @@
 import org.apache.flink.util.OutputTag;
 
 import org.junit.jupiter.api.Test;
-import org.mockito.Matchers;
+import org.mockito.ArgumentMatchers;
 import org.mockito.invocation.InvocationOnMock;
 import org.mockito.stubbing.Answer;
 
 import java.util.Arrays;
 
 import static org.assertj.core.api.Assertions.assertThat;
-import static org.mockito.Matchers.anyInt;
-import static org.mockito.Matchers.anyLong;
-import static org.mockito.Matchers.eq;
+import static org.mockito.ArgumentMatchers.anyInt;
+import static org.mockito.ArgumentMatchers.anyLong;
+import static org.mockito.ArgumentMatchers.eq;
 import static org.mockito.Mockito.doAnswer;
 import static org.mockito.Mockito.never;
 import static org.mockito.Mockito.times;
@@ -119,11 +119,7 @@ public TriggerResult answer(InvocationOnMock invocation)
                             }
                         })
                 .when(mockTrigger)
-                .onElement(
-                        Matchers.<Integer>anyObject(),
-                        anyLong(),
-                        anyTimeWindow(),
-                        anyTriggerContext());
+                .onElement(ArgumentMatchers.any(), anyLong(), anyTimeWindow(), anyTriggerContext());
 
         testHarness.processElement(new StreamRecord<>(1, 0L));