Skip to content

Commit 2c35e45

Browse files
authored
HDDS-11353. Intermittent failure in TestOzoneManagerHAWithStoppedNodes#testOMHAMetrics (#9660)
1 parent c386644 commit 2c35e45

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/om/TestOzoneManagerHAWithStoppedNodes.java

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -71,7 +71,6 @@
7171
import org.apache.hadoop.security.UserGroupInformation;
7272
import org.apache.log4j.Logger;
7373
import org.apache.ozone.test.GenericTestUtils;
74-
import org.apache.ozone.test.tag.Flaky;
7574
import org.apache.ratis.client.RaftClient;
7675
import org.apache.ratis.conf.RaftProperties;
7776
import org.apache.ratis.protocol.ClientId;
@@ -495,7 +494,6 @@ void testIncrementalWaitTimeWithSameNodeFailover() throws Exception {
495494
omFailoverProxyProvider.getWaitTime());
496495
}
497496

498-
@Flaky("HDDS-11353")
499497
@Test
500498
void testOMHAMetrics() throws Exception {
501499
// Get leader OM
@@ -513,6 +511,11 @@ void testOMHAMetrics() throws Exception {
513511
getCluster().restartOzoneManager(leaderOM, true);
514512
waitForLeaderToBeReady();
515513

514+
// Do some writes so that the old leader can receive AppendEntries
515+
// which will trigger notifyLeaderChanged, instead of relying on
516+
// AppendEntries
517+
setupBucket();
518+
516519
// Get the new leader
517520
OzoneManager newLeaderOM = getCluster().getOMLeader();
518521
String newLeaderOMId = newLeaderOM.getOMNodeId();

0 commit comments

Comments
 (0)