diff --git a/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/client/rpc/TestClientRetryTimeout.java b/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/client/rpc/TestClientRetryTimeout.java index 1c08b169c8b..7affac87db9 100644 --- a/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/client/rpc/TestClientRetryTimeout.java +++ b/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/client/rpc/TestClientRetryTimeout.java @@ -62,6 +62,7 @@ import org.junit.jupiter.api.Test; import org.junit.jupiter.api.TestInstance; import org.junit.jupiter.api.TestMethodOrder; +import org.junit.jupiter.api.Timeout; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -83,6 +84,7 @@ */ @TestInstance(TestInstance.Lifecycle.PER_CLASS) @TestMethodOrder(MethodOrderer.OrderAnnotation.class) +@Timeout(900) public class TestClientRetryTimeout { private static final Logger LOG = @@ -150,6 +152,7 @@ public void init() throws Exception { ratisClient.setExponentialPolicyBaseSleep(Duration.ofMillis(500)); ratisClient.setExponentialPolicyMaxSleep(Duration.ofSeconds(1)); ratisClient.setExponentialPolicyMaxRetries(1); + ratisClient.setMultilinearPolicy("500ms, 2"); conf.setFromObject(ratisClient); RatisClientConfig.RaftConfig raftClient = @@ -178,6 +181,9 @@ public void init() throws Exception { cluster = MiniOzoneCluster.newBuilder(conf) .setNumDatanodes(7) .build(); + // waitForClusterToBeReady runs waitForSCMToBeReady and then waits for all + // datanodes and safe mode; each step can use the full budget. + cluster.setWaitForClusterToBeReadyTimeout(300000); cluster.waitForClusterToBeReady(); cluster.waitForPipelineTobeReady(HddsProtos.ReplicationFactor.THREE, 180000);