1919
2020import static org .junit .jupiter .api .Assertions .assertTrue ;
2121import static org .mockito .Mockito .mock ;
22- import static org .mockito .Mockito .mockStatic ;
2322import static org .mockito .Mockito .when ;
2423
2524import org .apache .hadoop .hdds .scm .container .placement .metrics .SCMMetrics ;
2827import org .apache .ratis .proto .RaftProtos ;
2928import org .apache .ratis .server .protocol .TermIndex ;
3029import org .junit .jupiter .api .Test ;
31- import org .mockito .MockedStatic ;
3230
3331/**
3432 * Test SCMStateMachine events recording.
@@ -39,17 +37,15 @@ public class TestSCMStateMachine {
3937 public void testRatisEventsRecording () throws Exception {
4038 StorageContainerManager scm = mock (StorageContainerManager .class );
4139 SCMMetrics metrics = SCMMetrics .create ();
40+ when (scm .getMetrics ()).thenReturn (metrics );
41+
4242 SCMHADBTransactionBuffer buffer = mock (SCMHADBTransactionBuffer .class );
4343 when (buffer .getLatestTrxInfo ()).thenReturn (TransactionInfo .valueOf (TermIndex .valueOf (0 , 0 )));
4444
4545 SCMStateMachine stateMachine = new SCMStateMachine (scm , buffer );
4646
47- try (MockedStatic <StorageContainerManager > scmStaticMock = mockStatic (StorageContainerManager .class )) {
48- scmStaticMock .when (StorageContainerManager ::getMetrics ).thenReturn (metrics );
49-
50- stateMachine .notifyConfigurationChanged (1 , 1 , RaftProtos .RaftConfigurationProto .getDefaultInstance ());
51- assertTrue (metrics .getRatisEvents ().contains ("New peers [] added at term index" ));
52- }
47+ stateMachine .notifyConfigurationChanged (1 , 1 , RaftProtos .RaftConfigurationProto .getDefaultInstance ());
48+ assertTrue (metrics .getRatisEvents ().contains ("Configuration changed at term index" ));
5349
5450 metrics .unRegister ();
5551 }
0 commit comments