HDDS-12602. Intermittent failure in TestContainerStateMachine.testWriteFailure (apache#8099)

Author: peterxcli

hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/TestContainerStateMachine.java

@@ -123,6 +123,9 @@ public void testWriteFailure(boolean failWithException) throws ExecutionExceptio
     RaftProtos.LogEntryProto entry = mock(RaftProtos.LogEntryProto.class);
     when(entry.getTerm()).thenReturn(1L);
     when(entry.getIndex()).thenReturn(1L);
+    RaftProtos.LogEntryProto entryNext = mock(RaftProtos.LogEntryProto.class);
+    when(entryNext.getTerm()).thenReturn(1L);
+    when(entryNext.getIndex()).thenReturn(2L);
     TransactionContext trx = mock(TransactionContext.class);
     ContainerStateMachine.Context context = mock(ContainerStateMachine.Context.class);
     when(trx.getStateMachineContext()).thenReturn(context);
@@ -167,7 +170,7 @@ public void testWriteFailure(boolean failWithException) throws ExecutionExceptio
                     ContainerProtos.DatanodeBlockID.newBuilder().setContainerID(2).setLocalID(1).build()).build())
         .setContainerID(2)
         .setDatanodeUuid(UUID.randomUUID().toString()).build());
-    stateMachine.write(entry, trx).exceptionally(throwableSetter).get();
+    stateMachine.write(entryNext, trx).exceptionally(throwableSetter).get();
     verify(dispatcher, times(0)).dispatch(any(ContainerProtos.ContainerCommandRequestProto.class),
         any(DispatcherContext.class));
     assertInstanceOf(StorageContainerException.class, throwable.get());

hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/TestContainerStateMachineFollower.java

@@ -17,12 +17,9 @@
 
 package org.apache.hadoop.ozone.container.common.transport.server.ratis;
 
-import org.apache.ozone.test.tag.Flaky;
-
 /**
  * Test class to ContainerStateMachine class for follower.
  */
-@Flaky("HDDS-12602")
 public class TestContainerStateMachineFollower extends TestContainerStateMachine {
   public TestContainerStateMachineFollower() {
     super(false);

hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/TestContainerStateMachineLeader.java

@@ -17,12 +17,9 @@
 
 package org.apache.hadoop.ozone.container.common.transport.server.ratis;
 
-import org.apache.ozone.test.tag.Flaky;
-
 /**
  * Test class to ContainerStateMachine class for leader.
  */
-@Flaky("HDDS-12602")
 public class TestContainerStateMachineLeader extends TestContainerStateMachine {
   public TestContainerStateMachineLeader() {
     super(true);